Lines Matching refs:topsrv
73 static struct top_srv topsrv; variable
199 atomic_dec(&topsrv.subscription_count); in subscr_timeout()
213 atomic_dec(&topsrv.subscription_count); in subscr_del()
257 spin_lock_bh(&topsrv.lock); in subscr_terminate()
259 spin_unlock_bh(&topsrv.lock); in subscr_terminate()
337 if (atomic_read(&topsrv.subscription_count) >= tipc_max_subscriptions) { in subscr_subscribe()
373 atomic_inc(&topsrv.subscription_count); in subscr_subscribe()
512 spin_lock_bh(&topsrv.lock); in subscr_named_msg_event()
513 list_add(&subscriber->subscriber_list, &topsrv.subscriber_list); in subscr_named_msg_event()
514 spin_unlock_bh(&topsrv.lock); in subscr_named_msg_event()
538 memset(&topsrv, 0, sizeof(topsrv)); in tipc_subscr_start()
539 spin_lock_init(&topsrv.lock); in tipc_subscr_start()
540 INIT_LIST_HEAD(&topsrv.subscriber_list); in tipc_subscr_start()
551 &topsrv.setup_port); in tipc_subscr_start()
555 res = tipc_publish(topsrv.setup_port, TIPC_NODE_SCOPE, &seq); in tipc_subscr_start()
557 tipc_deleteport(topsrv.setup_port); in tipc_subscr_start()
558 topsrv.setup_port = 0; in tipc_subscr_start()
575 if (topsrv.setup_port) { in tipc_subscr_stop()
576 tipc_deleteport(topsrv.setup_port); in tipc_subscr_stop()
577 topsrv.setup_port = 0; in tipc_subscr_stop()
580 &topsrv.subscriber_list, in tipc_subscr_stop()