Lines Matching refs:sub
334 struct tipc_subscription *sub, *tmp; in tipc_service_insert_publ() local
365 list_for_each_entry_safe(sub, tmp, &sc->subscriptions, service_list) { in tipc_service_insert_publ()
366 tipc_sub_report_overlap(sub, p, TIPC_PUBLISHED, first); in tipc_service_insert_publ()
422 struct tipc_subscription *sub) in tipc_service_subscribe() argument
429 filter = sub->s.filter; in tipc_service_subscribe()
430 lower = sub->s.seq.lower; in tipc_service_subscribe()
431 upper = sub->s.seq.upper; in tipc_service_subscribe()
433 tipc_sub_get(sub); in tipc_service_subscribe()
434 list_add(&sub->service_list, &service->subscriptions); in tipc_service_subscribe()
456 tipc_sub_report_overlap(sub, p, TIPC_PUBLISHED, true); in tipc_service_subscribe()
502 struct tipc_subscription *sub, *tmp; in tipc_nametbl_remove_publ() local
522 list_for_each_entry_safe(sub, tmp, &sc->subscriptions, service_list) { in tipc_nametbl_remove_publ()
523 tipc_sub_report_overlap(sub, p, TIPC_WITHDRAWN, last); in tipc_nametbl_remove_publ()
827 bool tipc_nametbl_subscribe(struct tipc_subscription *sub) in tipc_nametbl_subscribe() argument
829 struct tipc_net *tn = tipc_net(sub->net); in tipc_nametbl_subscribe()
830 u32 type = sub->s.seq.type; in tipc_nametbl_subscribe()
836 sub->s.seq.lower, sub->s.seq.upper); in tipc_nametbl_subscribe()
838 sc = tipc_service_find(sub->net, &ua); in tipc_nametbl_subscribe()
840 sc = tipc_service_create(sub->net, &ua); in tipc_nametbl_subscribe()
843 tipc_service_subscribe(sc, sub); in tipc_nametbl_subscribe()
847 type, sub->s.seq.lower, sub->s.seq.upper); in tipc_nametbl_subscribe()
858 void tipc_nametbl_unsubscribe(struct tipc_subscription *sub) in tipc_nametbl_unsubscribe() argument
860 struct tipc_net *tn = tipc_net(sub->net); in tipc_nametbl_unsubscribe()
865 sub->s.seq.type, sub->s.seq.lower, sub->s.seq.upper); in tipc_nametbl_unsubscribe()
867 sc = tipc_service_find(sub->net, &ua); in tipc_nametbl_unsubscribe()
872 list_del_init(&sub->service_list); in tipc_nametbl_unsubscribe()
873 tipc_sub_put(sub); in tipc_nametbl_unsubscribe()