Lines Matching refs:port
72 unsigned int port; member
163 srv->service, srv->instance, srv->node, srv->port); in service_announce_new()
169 cmsg.server.port = cpu_to_le32(srv->port); in service_announce_new()
187 srv->service, srv->instance, srv->node, srv->port); in service_announce_del()
193 cmsg.server.port = cpu_to_le32(srv->port); in service_announce_del()
214 pkt.server.port = cpu_to_le32(srv->port); in lookup_notify()
247 unsigned int node_id, unsigned int port) in server_add() argument
254 if (!service || !port) in server_add()
264 srv->port = port; in server_add()
270 rc = map_reput(&node->services, hash_u32(port), &srv->mi, &mi); in server_add()
275 srv->node, srv->port); in server_add()
289 static int server_del(struct context *ctx, struct node *node, unsigned int port) in server_del() argument
296 mi = map_get(&node->services, hash_u32(port)); in server_del()
352 server_del(ctx, node, srv->port); in ctrl_cmd_bye()
369 sq.sq_port = srv->port; in ctrl_cmd_bye()
381 unsigned node_id, unsigned port) in ctrl_cmd_del_client() argument
399 if (from->sq_node == ctx->local_node && from->sq_port != port) in ctrl_cmd_del_client()
407 if (lookup->sq.sq_port != port) in ctrl_cmd_del_client()
417 server_del(ctx, node, port); in ctrl_cmd_del_client()
426 pkt.client.port = port; in ctrl_cmd_del_client()
433 sq.sq_port = srv->port; in ctrl_cmd_del_client()
446 unsigned int node_id, unsigned int port) in ctrl_cmd_new_server() argument
456 port = from->sq_port; in ctrl_cmd_new_server()
463 srv = server_add(service, instance, node_id, port); in ctrl_cmd_new_server()
486 unsigned int node_id, unsigned int port) in ctrl_cmd_del_server() argument
493 port = from->sq_port; in ctrl_cmd_del_server()
501 if (from->sq_node == ctx->local_node && from->sq_port != port) in ctrl_cmd_del_server()
508 return server_del(ctx, node, port); in ctrl_cmd_del_server()
618 le32_to_cpu(msg->client.port)); in ctrl_port_fn()
625 le32_to_cpu(msg->server.port)); in ctrl_port_fn()
632 le32_to_cpu(msg->server.port)); in ctrl_port_fn()