70 	struct tipc_subscriber *subscriber = sub->subscriber;  in subscr_send_event()  local
80 	tipc_conn_sendmsg(tn->topsrv, subscriber->conid, NULL,  in subscr_send_event()
121 	struct tipc_subscriber *subscriber = sub->subscriber;  in subscr_timeout()  local
125 	spin_lock_bh(&subscriber->lock);  in subscr_timeout()
129 		spin_unlock_bh(&subscriber->lock);  in subscr_timeout()
139 	spin_unlock_bh(&subscriber->lock);  in subscr_timeout()
165 static void subscr_release(struct tipc_subscriber *subscriber)  in subscr_release()  argument
170 	spin_lock_bh(&subscriber->lock);  in subscr_release()
173 	list_for_each_entry_safe(sub, sub_temp, &subscriber->subscription_list,  in subscr_release()
176 			spin_unlock_bh(&subscriber->lock);  in subscr_release()
178 			spin_lock_bh(&subscriber->lock);  in subscr_release()
182 	spin_unlock_bh(&subscriber->lock);  in subscr_release()
185 	kfree(subscriber);  in subscr_release()
198 			  struct tipc_subscriber *subscriber)  in subscr_cancel()  argument
205 	list_for_each_entry_safe(sub, sub_temp, &subscriber->subscription_list,  in subscr_cancel()
218 		spin_unlock_bh(&subscriber->lock);  in subscr_cancel()
220 		spin_lock_bh(&subscriber->lock);  in subscr_cancel()
231 			    struct tipc_subscriber *subscriber,  in subscr_subscribe()  argument
244 		subscr_cancel(s, subscriber);  in subscr_subscribe()
276 	list_add(&sub->subscription_list, &subscriber->subscription_list);  in subscr_subscribe()
277 	sub->subscriber = subscriber;  in subscr_subscribe()
300 	struct tipc_subscriber *subscriber = usr_data;  in subscr_conn_msg_event()  local
304 	spin_lock_bh(&subscriber->lock);  in subscr_conn_msg_event()
305 	if (subscr_subscribe(net, (struct tipc_subscr *)buf, subscriber, &sub))  in subscr_conn_msg_event()
306 		tipc_conn_terminate(tn->topsrv, subscriber->conid);  in subscr_conn_msg_event()
309 	spin_unlock_bh(&subscriber->lock);  in subscr_conn_msg_event()
315 	struct tipc_subscriber *subscriber;  in subscr_named_msg_event()  local
318 	subscriber = kzalloc(sizeof(struct tipc_subscriber), GFP_ATOMIC);  in subscr_named_msg_event()
319 	if (subscriber == NULL) {  in subscr_named_msg_event()
323 	INIT_LIST_HEAD(&subscriber->subscription_list);  in subscr_named_msg_event()
324 	subscriber->conid = conid;  in subscr_named_msg_event()
325 	spin_lock_init(&subscriber->lock);  in subscr_named_msg_event()
327 	return (void *)subscriber;  in subscr_named_msg_event()