Lines Matching refs:portid

88 	u32 portid;  member
117 static struct tipc_sock *tipc_sk_lookup(struct net *net, u32 portid);
379 msg_set_origport(msg, tsk->portid); in tipc_sk_create()
456 tipc_node_remove_conn(net, dnode, tsk->portid); in tipc_release()
469 tsk->portid, TIPC_ERR_NO_PORT); in tipc_release()
471 tipc_node_xmit_skb(net, skb, dnode, tsk->portid); in tipc_release()
472 tipc_node_remove_conn(net, dnode, tsk->portid); in tipc_release()
573 addr->addr.id.ref = tsk->portid; in tipc_getname()
731 u32 portid; in tipc_sk_mcast_rcv() local
752 portid = tipc_plist_pop(&dports); in tipc_sk_mcast_rcv()
753 for (; portid; portid = tipc_plist_pop(&dports)) { in tipc_sk_mcast_rcv()
756 msg_set_destport(buf_msg(_skb), portid); in tipc_sk_mcast_rcv()
932 mtu = tipc_node_get_mtu(net, dnode, tsk->portid); in __tipc_sendmsg()
940 rc = tipc_node_xmit(net, &pktchain, dnode, tsk->portid); in __tipc_sendmsg()
1024 u32 portid = tsk->portid; in __tipc_send_stream() local
1062 rc = tipc_node_xmit(net, &pktchain, dnode, portid); in __tipc_send_stream()
1073 portid); in __tipc_send_stream()
1126 tipc_node_add_conn(net, peer_node, tsk->portid, peer_port); in tipc_sk_finish_conn()
1127 tsk->max_pkt = tipc_node_get_mtu(net, peer_node, tsk->portid); in tipc_sk_finish_conn()
1236 tsk->portid, TIPC_OK); in tipc_sk_send_ack()
1556 tsk->portid); in filter_connect()
2086 u32 oport = tsk->portid; in tipc_shutdown()
2114 tipc_node_xmit_skb(net, skb, dnode, tsk->portid); in tipc_shutdown()
2118 tipc_node_remove_conn(net, dnode, tsk->portid); in tipc_shutdown()
2170 peer_port, tsk->portid, TIPC_OK); in tipc_sk_timeout()
2176 tipc_node_xmit_skb(sock_net(sk), skb, peer_node, tsk->portid); in tipc_sk_timeout()
2190 key = tsk->portid + tsk->pub_count + 1; in tipc_sk_publish()
2191 if (key == tsk->portid) in tipc_sk_publish()
2195 scope, tsk->portid, key); in tipc_sk_publish()
2263 static struct tipc_sock *tipc_sk_lookup(struct net *net, u32 portid) in tipc_sk_lookup() argument
2269 tsk = rhashtable_lookup_fast(&tn->sk_rht, &portid, tsk_rht_params); in tipc_sk_lookup()
2283 u32 portid = prandom_u32() % remaining + TIPC_MIN_PORT; in tipc_sk_insert() local
2286 portid++; in tipc_sk_insert()
2287 if ((portid < TIPC_MIN_PORT) || (portid > TIPC_MAX_PORT)) in tipc_sk_insert()
2288 portid = TIPC_MIN_PORT; in tipc_sk_insert()
2289 tsk->portid = portid; in tipc_sk_insert()
2314 .key_offset = offsetof(struct tipc_sock, portid),
2647 hdr = genlmsg_put(skb, NETLINK_CB(cb->skb).portid, cb->nlh->nlmsg_seq, in __tipc_nl_add_sk()
2655 if (nla_put_u32(skb, TIPC_NLA_SOCK_REF, tsk->portid)) in __tipc_nl_add_sk()
2697 if (prev_portid && prev_portid != tsk->portid) { in tipc_nl_sk_dump()
2704 prev_portid = tsk->portid; in tipc_nl_sk_dump()
2728 hdr = genlmsg_put(skb, NETLINK_CB(cb->skb).portid, cb->nlh->nlmsg_seq, in __tipc_nl_add_sk_publ()