Lines Matching refs:topsrv
80 tipc_conn_sendmsg(tn->topsrv, subscriber->conid, NULL, in subscr_send_event()
306 tipc_conn_terminate(tn->topsrv, subscriber->conid); in subscr_conn_msg_event()
334 struct tipc_server *topsrv; in tipc_subscr_start() local
347 topsrv = kzalloc(sizeof(*topsrv), GFP_ATOMIC); in tipc_subscr_start()
348 if (!topsrv) { in tipc_subscr_start()
352 topsrv->net = net; in tipc_subscr_start()
353 topsrv->saddr = saddr; in tipc_subscr_start()
354 topsrv->imp = TIPC_CRITICAL_IMPORTANCE; in tipc_subscr_start()
355 topsrv->type = SOCK_SEQPACKET; in tipc_subscr_start()
356 topsrv->max_rcvbuf_size = sizeof(struct tipc_subscr); in tipc_subscr_start()
357 topsrv->tipc_conn_recvmsg = subscr_conn_msg_event; in tipc_subscr_start()
358 topsrv->tipc_conn_new = subscr_named_msg_event; in tipc_subscr_start()
359 topsrv->tipc_conn_shutdown = subscr_conn_shutdown_event; in tipc_subscr_start()
361 strncpy(topsrv->name, name, strlen(name) + 1); in tipc_subscr_start()
362 tn->topsrv = topsrv; in tipc_subscr_start()
365 return tipc_server_start(topsrv); in tipc_subscr_start()
371 struct tipc_server *topsrv = tn->topsrv; in tipc_subscr_stop() local
373 tipc_server_stop(topsrv); in tipc_subscr_stop()
374 kfree(topsrv->saddr); in tipc_subscr_stop()
375 kfree(topsrv); in tipc_subscr_stop()