Lines Matching refs:init_server
31 struct init_rpc_server *init_server; in rpc_subsystem_poll_servers() local
33 STAILQ_FOREACH(init_server, &g_init_rpc_servers, link) { in rpc_subsystem_poll_servers()
34 if (init_server->active) { in rpc_subsystem_poll_servers()
35 spdk_rpc_server_accept(init_server->server); in rpc_subsystem_poll_servers()
118 struct init_rpc_server *init_server; in get_server_by_addr() local
120 STAILQ_FOREACH(init_server, &g_init_rpc_servers, link) { in get_server_by_addr()
121 if (strcmp(listen_addr, init_server->listen_addr) == 0) { in get_server_by_addr()
122 return init_server; in get_server_by_addr()
132 struct init_rpc_server *init_server; in spdk_rpc_initialize() local
149 init_server = calloc(1, sizeof(struct init_rpc_server)); in spdk_rpc_initialize()
150 if (init_server == NULL) { in spdk_rpc_initialize()
155 rc = snprintf(init_server->listen_addr, sizeof(init_server->listen_addr), "%s", in spdk_rpc_initialize()
159 free(init_server); in spdk_rpc_initialize()
164 init_server->server = spdk_rpc_server_listen(listen_addr); in spdk_rpc_initialize()
165 if (init_server->server == NULL) { in spdk_rpc_initialize()
167 free(init_server); in spdk_rpc_initialize()
172 init_server->active = true; in spdk_rpc_initialize()
174 STAILQ_INSERT_TAIL(&g_init_rpc_servers, init_server, link); in spdk_rpc_initialize()
186 struct init_rpc_server *init_server; in spdk_rpc_server_finish() local
188 init_server = get_server_by_addr(listen_addr); in spdk_rpc_server_finish()
189 if (!init_server) { in spdk_rpc_server_finish()
194 spdk_rpc_server_close(init_server->server); in spdk_rpc_server_finish()
195 STAILQ_REMOVE(&g_init_rpc_servers, init_server, init_rpc_server, link); in spdk_rpc_server_finish()
196 free(init_server); in spdk_rpc_server_finish()
206 struct init_rpc_server *init_server, *tmp; in spdk_rpc_finish() local
208 STAILQ_FOREACH_SAFE(init_server, &g_init_rpc_servers, link, tmp) { in spdk_rpc_finish()
209 spdk_rpc_server_finish(init_server->listen_addr); in spdk_rpc_finish()
216 struct init_rpc_server *init_server; in set_server_active_flag() local
218 init_server = get_server_by_addr(listen_addr); in set_server_active_flag()
219 if (!init_server) { in set_server_active_flag()
224 init_server->active = is_active; in set_server_active_flag()