117 static void tipc_conn_delete_sub(struct tipc_conn *con, struct tipc_subscr *s);
127 	struct tipc_topsrv *s = con->server;  in tipc_conn_kref_release()  local
130 	spin_lock_bh(&s->idr_lock);  in tipc_conn_kref_release()
131 	idr_remove(&s->conn_idr, con->conid);  in tipc_conn_kref_release()
132 	s->idr_in_use--;  in tipc_conn_kref_release()
133 	spin_unlock_bh(&s->idr_lock);  in tipc_conn_kref_release()
180 static struct tipc_conn *tipc_conn_alloc(struct tipc_topsrv *s)  in tipc_conn_alloc()  argument
197 	spin_lock_bh(&s->idr_lock);  in tipc_conn_alloc()
198 	ret = idr_alloc(&s->conn_idr, con, 0, 0, GFP_ATOMIC);  in tipc_conn_alloc()
201 		spin_unlock_bh(&s->idr_lock);  in tipc_conn_alloc()
205 	s->idr_in_use++;  in tipc_conn_alloc()
206 	spin_unlock_bh(&s->idr_lock);  in tipc_conn_alloc()
209 	con->server = s;  in tipc_conn_alloc()
214 static struct tipc_conn *tipc_conn_lookup(struct tipc_topsrv *s, int conid)  in tipc_conn_lookup()  argument
218 	spin_lock_bh(&s->idr_lock);  in tipc_conn_lookup()
219 	con = idr_find(&s->conn_idr, conid);  in tipc_conn_lookup()
222 	spin_unlock_bh(&s->idr_lock);  in tipc_conn_lookup()
229 static void tipc_conn_delete_sub(struct tipc_conn *con, struct tipc_subscr *s)  in tipc_conn_delete_sub()  argument
237 		if (!s || !memcmp(s, &sub->evt.s, sizeof(*s))) {  in tipc_conn_delete_sub()
240 		} else if (s) {  in tipc_conn_delete_sub()
266 			tipc_conn_delete_sub(con, &evt->s);  in tipc_conn_send_to_sock()
361 			     struct tipc_subscr *s)  in tipc_conn_rcv_sub()  argument
366 	if (tipc_sub_read(s, filter) & TIPC_SUB_CANCEL) {  in tipc_conn_rcv_sub()
367 		s->filter &= __constant_ntohl(~TIPC_SUB_CANCEL);  in tipc_conn_rcv_sub()
368 		tipc_conn_delete_sub(con, s);  in tipc_conn_rcv_sub()
375 	sub = tipc_sub_subscribe(srv->net, s, con->conid);  in tipc_conn_rcv_sub()
390 	struct tipc_subscr s;  in tipc_conn_rcv_from_sock()  local
394 	iov.iov_base = &s;  in tipc_conn_rcv_from_sock()
395 	iov.iov_len = sizeof(s);  in tipc_conn_rcv_from_sock()
401 	if (ret == sizeof(s)) {  in tipc_conn_rcv_from_sock()
403 		ret = tipc_conn_rcv_sub(srv, con, &s);  in tipc_conn_rcv_from_sock()
599 	u32 port = *(u32 *)&evt->s.usr_handle;  in tipc_topsrv_kern_evt()
616 static int tipc_topsrv_work_start(struct tipc_topsrv *s)  in tipc_topsrv_work_start()  argument
618 	s->rcv_wq = alloc_ordered_workqueue("tipc_rcv", 0);  in tipc_topsrv_work_start()
619 	if (!s->rcv_wq) {  in tipc_topsrv_work_start()
624 	s->send_wq = alloc_ordered_workqueue("tipc_send", 0);  in tipc_topsrv_work_start()
625 	if (!s->send_wq) {  in tipc_topsrv_work_start()
627 		destroy_workqueue(s->rcv_wq);  in tipc_topsrv_work_start()
634 static void tipc_topsrv_work_stop(struct tipc_topsrv *s)  in tipc_topsrv_work_stop()  argument
636 	destroy_workqueue(s->rcv_wq);  in tipc_topsrv_work_stop()
637 	destroy_workqueue(s->send_wq);  in tipc_topsrv_work_stop()