Home
last modified time | relevance | path

Searched refs:server (Results 1 – 25 of 26) sorted by relevance

12

/spdk/lib/rpc/
H A Drpc.c149 _spdk_rpc_listen(const char *listen_addr, struct spdk_rpc_server *server) in _spdk_rpc_listen() argument
155 server->listen_addr_unix.sun_family = AF_UNIX; in _spdk_rpc_listen()
156 rc = snprintf(server->listen_addr_unix.sun_path, in _spdk_rpc_listen()
157 sizeof(server->listen_addr_unix.sun_path), in _spdk_rpc_listen()
159 if (rc < 0 || (size_t)rc >= sizeof(server->listen_addr_unix.sun_path)) { in _spdk_rpc_listen()
164 rc = snprintf(server->lock_path, sizeof(server->lock_path), "%s.lock", in _spdk_rpc_listen()
165 server->listen_addr_unix.sun_path); in _spdk_rpc_listen()
166 if (rc < 0 || (size_t)rc >= sizeof(server->lock_path)) { in _spdk_rpc_listen()
171 server->lock_fd = open(server->lock_path, O_RDWR | O_CREAT, 0600); in _spdk_rpc_listen()
172 if (server->lock_fd == -1) { in _spdk_rpc_listen()
[all …]
/spdk/lib/jsonrpc/
H A Djsonrpc_server_tcp.c15 struct spdk_jsonrpc_server *server; in spdk_jsonrpc_server_listen() local
18 server = calloc(1, sizeof(struct spdk_jsonrpc_server)); in spdk_jsonrpc_server_listen()
19 if (server == NULL) { in spdk_jsonrpc_server_listen()
23 TAILQ_INIT(&server->free_conns); in spdk_jsonrpc_server_listen()
24 TAILQ_INIT(&server->conns); in spdk_jsonrpc_server_listen()
27 TAILQ_INSERT_TAIL(&server->free_conns, &server->conns_array[i], link); in spdk_jsonrpc_server_listen()
30 server->handle_request = handle_request; in spdk_jsonrpc_server_listen()
32 server->sockfd = socket(domain, SOCK_STREAM | SOCK_NONBLOCK | SOCK_CLOEXEC, protocol); in spdk_jsonrpc_server_listen()
33 if (server->sockfd < 0) { in spdk_jsonrpc_server_listen()
35 free(server); in spdk_jsonrpc_server_listen()
[all …]
H A Djsonrpc_internal.h49 struct spdk_jsonrpc_server *server; member
/spdk/test/unit/lib/jsonrpc/jsonrpc_server.c/
H A Djsonrpc_server_ut.c168 struct spdk_jsonrpc_server *server; in test_parse_request() local
171 server = calloc(1, sizeof(*server)); in test_parse_request()
172 SPDK_CU_ASSERT_FATAL(server != NULL); in test_parse_request()
179 conn->server = server; in test_parse_request()
299 free(server); in test_parse_request()
305 struct spdk_jsonrpc_server *server; in test_parse_request_streaming() local
310 server = calloc(1, sizeof(*server)); in test_parse_request_streaming()
[all...]
/spdk/test/unit/lib/init/rpc.c/
H A Drpc_ut.c19 DEFINE_STUB_V(spdk_rpc_server_accept, (struct spdk_rpc_server *server));
20 DEFINE_STUB_V(spdk_rpc_server_close, (struct spdk_rpc_server *server));
55 struct init_rpc_server *server; in server_exists() local
57 STAILQ_FOREACH(server, &g_init_rpc_servers, link) { in server_exists()
58 if (strcmp(addr, server->listen_addr) == 0) { in server_exists()
69 struct init_rpc_server *server; in server_paused() local
71 STAILQ_FOREACH(server, &g_init_rpc_servers, link) { in server_paused()
72 if (strcmp(addr, server->listen_addr) == 0 && !server->active) { in server_paused()
/spdk/lib/init/
H A Drpc.c19 struct spdk_rpc_server *server; member
35 spdk_rpc_server_accept(init_server->server); in rpc_subsystem_poll_servers()
164 init_server->server = spdk_rpc_server_listen(listen_addr); in spdk_rpc_initialize()
165 if (init_server->server == NULL) { in spdk_rpc_initialize()
194 spdk_rpc_server_close(init_server->server); in spdk_rpc_server_finish()
/spdk/test/rpc/
H A Dskip_rpc.sh15 $SPDK_BIN_DIR/spdk_tgt --no-rpc-server -m 0x1 &
46 $SPDK_BIN_DIR/spdk_tgt --no-rpc-server -m 0x1 --json $CONFIG_PATH &> $LOG_PATH &
57 NOT $SPDK_BIN_DIR/spdk_tgt --no-rpc-server -m 0x1 --wait-for-rpc
/spdk/include/spdk/
H A Drpc.h71 void spdk_rpc_server_accept(struct spdk_rpc_server *server);
78 void spdk_rpc_server_close(struct spdk_rpc_server *server);
H A Djsonrpc.h105 int spdk_jsonrpc_server_poll(struct spdk_jsonrpc_server *server);
112 void spdk_jsonrpc_server_shutdown(struct spdk_jsonrpc_server *server);
/spdk/doc/
H A Djsonrpc_proxy.md3 SPDK provides a sample python script `rpc_http_proxy.py`, that provides http server which listens f…
11 server IP | Required | string | IP address that JSON objects shall be received on
12 server port | Required | number | Port number that JSON objects shall be received …
H A Dnvmf_multipath_howto.md23 This should be run once on each server (and after reboots):
77 …ommand will return, leaving the test to run for 90 seconds in the background. On the target server,
87 This can be done on the target server by setting the first path's ANA to `non_optimized`:
H A Devent.md4 shared-nothing server applications. The event framework is intended to be
19 Simple server applications can be written in a single-threaded fashion. This
41 thread-per-connection server design, which achieves concurrency by depending
H A Dvhost_processing.md64 > server (listening) in the socket communication.
66 SPDK vhost is a Vhost-user back-end server. It exposes Unix domain sockets and
190 notifications, drastically increasing the vhost server throughput and decreasing
H A Dspdk_top.md18 …unicate with the app it is viewing, so it will work only with those that run RPC server and support
H A Dapplications.md75 framework initialization. This state is called `STARTUP`. The JSON RPC server is
H A Discsi.md187 Assuming we have one iSCSI Target server with portal at 10.0.0.1:3200, two LUNs (Malloc0 and Malloc…
H A Dvhost.md240 VHOST_CONFIG: vhost-user server: socket created, fd: 21
/spdk/scripts/
H A Drpc_http_proxy.py18 from http.server import HTTPServer
19 from http.server import BaseHTTPRequestHandler
H A Drpc.py45 help='Retry connecting to the RPC server N times with 0.2s interval. Default: 0',
55 parser.add_argument('--server', dest='is_server', action='store_true',
58 **STATUS=0 if the command succeeded or **STATUS=1 if it failed. --server is meant \
143 p.add_argument('sig_name', help='signal will be sent to server.')
3754 p.add_argument('--enable-zerocopy-send-server', help='Enable zerocopy on send for server sockets',
3756 p.add_argument('--disable-zerocopy-send-server', help='Disable zerocopy on send for server sockets',
/spdk/test/unit/lib/rpc/rpc.c/
H A Drpc_ut.c30 DEFINE_STUB(spdk_jsonrpc_server_poll, int, (struct spdk_jsonrpc_server *server), 0);
31 DEFINE_STUB_V(spdk_jsonrpc_server_shutdown, (struct spdk_jsonrpc_server *server));
/spdk/test/nvmf/target/
H A Dperf_adq.sh43 $rpc_py sock_impl_set_options --enable-placement-id $1 --enable-zerocopy-send-server -i $socket_impl
/spdk/python/spdk/sma/
H A Dsma.py22 self._server = grpc.server(futures.ThreadPoolExecutor(max_workers=1))
/spdk/test/vhost/
H A Dcommon.sh678 cmd+=(-monitor "telnet:127.0.0.1:$monitor_port,server,nowait")
995 notice "Starting fio server on VM$vm_num"
998 vm_exec $vm_num /root/fio $readonly --eta=never --server --daemonize=/root/fio.pid
1000 vm_exec $vm_num fio $readonly --eta=never --server --daemonize=/root/fio.pid
1077 notice "Using plugin mode. Disabling server mode."
1165 # Fio in client-server mode produces a lot of "trash" output
1177 # Parsing fio results for json output and client-server mode only!
/spdk/scripts/vagrant/
H A DVagrantfile12 'ubuntu2004' => 'peru/ubuntu-20.04-server-amd64',
/spdk/test/common/
H A Dautotest_common.sh334 coproc RPC_PIPE { PYTHONPATH="$PYTHONPATH" "$rootdir/scripts/rpc.py" --server; }

12