Lines Matching refs:sub
234 struct tipc_subscription *sub, *tmp; in tipc_conn_delete_sub() local
237 list_for_each_entry_safe(sub, tmp, sub_list, sub_list) { in tipc_conn_delete_sub()
238 if (!s || !memcmp(s, &sub->evt.s, sizeof(*s))) { in tipc_conn_delete_sub()
239 tipc_sub_unsubscribe(sub); in tipc_conn_delete_sub()
365 struct tipc_subscription *sub; in tipc_conn_rcv_sub() local
377 sub = tipc_sub_subscribe(srv->net, s, con->conid); in tipc_conn_rcv_sub()
378 if (!sub) in tipc_conn_rcv_sub()
382 list_add(&sub->sub_list, &con->sub_list); in tipc_conn_rcv_sub()
571 struct tipc_subscr sub; in tipc_topsrv_kern_subscr() local
575 sub.seq.type = type; in tipc_topsrv_kern_subscr()
576 sub.seq.lower = lower; in tipc_topsrv_kern_subscr()
577 sub.seq.upper = upper; in tipc_topsrv_kern_subscr()
578 sub.timeout = TIPC_WAIT_FOREVER; in tipc_topsrv_kern_subscr()
579 sub.filter = filter; in tipc_topsrv_kern_subscr()
580 *(u64 *)&sub.usr_handle = (u64)port; in tipc_topsrv_kern_subscr()
587 rc = tipc_conn_rcv_sub(tipc_topsrv(net), con, &sub); in tipc_topsrv_kern_subscr()