xref: /spdk/lib/jsonrpc/jsonrpc_client_tcp.c (revision f6866117acb32c78d5ea7bd76ba330284655af35)
1488570ebSJim Harris /*   SPDX-License-Identifier: BSD-3-Clause
2a6dbe372Spaul luse  *   Copyright (C) 2018 Intel Corporation.
3c10f8e16SLiu Xiaodong  *   All rights reserved.
4c10f8e16SLiu Xiaodong  */
5a6dbe372Spaul luse 
6c10f8e16SLiu Xiaodong #include "spdk/string.h"
7c10f8e16SLiu Xiaodong #include "jsonrpc_internal.h"
85d0f2620SPawel Wodkowski #include "spdk/util.h"
9c10f8e16SLiu Xiaodong 
10c10f8e16SLiu Xiaodong #define RPC_DEFAULT_PORT	"5260"
11c10f8e16SLiu Xiaodong 
124734811dSPawel Wodkowski static int
jsonrpc_client_send_request(struct spdk_jsonrpc_client * client)131a9ed697SSeth Howell jsonrpc_client_send_request(struct spdk_jsonrpc_client *client)
144734811dSPawel Wodkowski {
154734811dSPawel Wodkowski 	ssize_t rc;
164734811dSPawel Wodkowski 	struct spdk_jsonrpc_client_request *request = client->request;
174734811dSPawel Wodkowski 
184734811dSPawel Wodkowski 	if (!request) {
194734811dSPawel Wodkowski 		return 0;
204734811dSPawel Wodkowski 	}
214734811dSPawel Wodkowski 
227d38f166SPawel Wodkowski 	if (request->send_len > 0) {
234734811dSPawel Wodkowski 		rc = send(client->sockfd, request->send_buf + request->send_offset,
244734811dSPawel Wodkowski 			  request->send_len, 0);
257d38f166SPawel Wodkowski 		if (rc < 0) {
267d38f166SPawel Wodkowski 			/* For EINTR we pretend that nothing was send. */
277d38f166SPawel Wodkowski 			if (errno == EINTR) {
284734811dSPawel Wodkowski 				rc = 0;
294734811dSPawel Wodkowski 			} else {
307d38f166SPawel Wodkowski 				rc = -errno;
317d38f166SPawel Wodkowski 				SPDK_ERRLOG("poll() failed (%d): %s\n", errno, spdk_strerror(errno));
324734811dSPawel Wodkowski 			}
337d38f166SPawel Wodkowski 
347d38f166SPawel Wodkowski 			return rc;
354734811dSPawel Wodkowski 		}
364734811dSPawel Wodkowski 
374734811dSPawel Wodkowski 		request->send_offset += rc;
384734811dSPawel Wodkowski 		request->send_len -= rc;
394734811dSPawel Wodkowski 	}
404734811dSPawel Wodkowski 
417d38f166SPawel Wodkowski 	if (request->send_len == 0) {
424734811dSPawel Wodkowski 		client->request = NULL;
434734811dSPawel Wodkowski 		spdk_jsonrpc_client_free_request(request);
447d38f166SPawel Wodkowski 	}
457d38f166SPawel Wodkowski 
464734811dSPawel Wodkowski 	return 0;
474734811dSPawel Wodkowski }
484734811dSPawel Wodkowski 
494734811dSPawel Wodkowski static int
recv_buf_expand(struct spdk_jsonrpc_client * client)504734811dSPawel Wodkowski recv_buf_expand(struct spdk_jsonrpc_client *client)
514734811dSPawel Wodkowski {
524734811dSPawel Wodkowski 	uint8_t *new_buf;
534734811dSPawel Wodkowski 
544734811dSPawel Wodkowski 	if (client->recv_buf_size * 2 > SPDK_JSONRPC_SEND_BUF_SIZE_MAX) {
554734811dSPawel Wodkowski 		return -ENOSPC;
564734811dSPawel Wodkowski 	}
574734811dSPawel Wodkowski 
584734811dSPawel Wodkowski 	new_buf = realloc(client->recv_buf, client->recv_buf_size * 2);
594734811dSPawel Wodkowski 	if (new_buf == NULL) {
604734811dSPawel Wodkowski 		SPDK_ERRLOG("Resizing recv_buf failed (current size %zu, new size %zu)\n",
614734811dSPawel Wodkowski 			    client->recv_buf_size, client->recv_buf_size * 2);
624734811dSPawel Wodkowski 		return -ENOMEM;
634734811dSPawel Wodkowski 	}
644734811dSPawel Wodkowski 
654734811dSPawel Wodkowski 	client->recv_buf = new_buf;
664734811dSPawel Wodkowski 	client->recv_buf_size *= 2;
674734811dSPawel Wodkowski 
684734811dSPawel Wodkowski 	return 0;
694734811dSPawel Wodkowski }
704734811dSPawel Wodkowski 
714734811dSPawel Wodkowski static int
jsonrpc_client_resp_ready_count(struct spdk_jsonrpc_client * client)721a9ed697SSeth Howell jsonrpc_client_resp_ready_count(struct spdk_jsonrpc_client *client)
734734811dSPawel Wodkowski {
747d38f166SPawel Wodkowski 	return client->resp != NULL && client->resp->ready ? 1 : 0;
757d38f166SPawel Wodkowski }
764734811dSPawel Wodkowski 
777d38f166SPawel Wodkowski static int
jsonrpc_client_recv(struct spdk_jsonrpc_client * client)781a9ed697SSeth Howell jsonrpc_client_recv(struct spdk_jsonrpc_client *client)
797d38f166SPawel Wodkowski {
807d38f166SPawel Wodkowski 	ssize_t rc;
814734811dSPawel Wodkowski 
824734811dSPawel Wodkowski 	if (client->recv_buf == NULL) {
834734811dSPawel Wodkowski 		client->recv_buf = malloc(SPDK_JSONRPC_SEND_BUF_SIZE_INIT);
844734811dSPawel Wodkowski 		if (!client->recv_buf) {
854734811dSPawel Wodkowski 			rc = errno;
864734811dSPawel Wodkowski 			SPDK_ERRLOG("malloc() failed (%d): %s\n", (int)rc, spdk_strerror(rc));
874734811dSPawel Wodkowski 			return -rc;
884734811dSPawel Wodkowski 		}
894734811dSPawel Wodkowski 		client->recv_buf_size = SPDK_JSONRPC_SEND_BUF_SIZE_INIT;
904734811dSPawel Wodkowski 		client->recv_offset = 0;
917d38f166SPawel Wodkowski 	} else if (client->recv_offset == client->recv_buf_size - 1) {
927d38f166SPawel Wodkowski 		rc = recv_buf_expand(client);
937d38f166SPawel Wodkowski 		if (rc) {
947d38f166SPawel Wodkowski 			return rc;
957d38f166SPawel Wodkowski 		}
964734811dSPawel Wodkowski 	}
974734811dSPawel Wodkowski 
987d38f166SPawel Wodkowski 	rc = recv(client->sockfd, client->recv_buf + client->recv_offset,
997d38f166SPawel Wodkowski 		  client->recv_buf_size - client->recv_offset - 1, 0);
1004734811dSPawel Wodkowski 	if (rc < 0) {
101cc6920a4SJosh Soref 		/* For EINTR we pretend that nothing was received. */
1024734811dSPawel Wodkowski 		if (errno == EINTR) {
1037d38f166SPawel Wodkowski 			return 0;
1044734811dSPawel Wodkowski 		} else {
1057d38f166SPawel Wodkowski 			rc = -errno;
1067d38f166SPawel Wodkowski 			SPDK_ERRLOG("recv() failed (%d): %s\n", errno, spdk_strerror(errno));
1077d38f166SPawel Wodkowski 			return rc;
1084734811dSPawel Wodkowski 		}
1094734811dSPawel Wodkowski 	} else if (rc == 0) {
1104734811dSPawel Wodkowski 		return -EIO;
1114734811dSPawel Wodkowski 	}
1124734811dSPawel Wodkowski 
1134734811dSPawel Wodkowski 	client->recv_offset += rc;
1144734811dSPawel Wodkowski 	client->recv_buf[client->recv_offset] = '\0';
1154734811dSPawel Wodkowski 
1164734811dSPawel Wodkowski 	/* Check to see if we have received a full JSON value. */
117134590a2SSeth Howell 	return jsonrpc_parse_response(client);
1187d38f166SPawel Wodkowski }
1197d38f166SPawel Wodkowski 
1207d38f166SPawel Wodkowski static int
jsonrpc_client_poll(struct spdk_jsonrpc_client * client,int timeout)1211a9ed697SSeth Howell jsonrpc_client_poll(struct spdk_jsonrpc_client *client, int timeout)
1227d38f166SPawel Wodkowski {
1237d38f166SPawel Wodkowski 	int rc;
1247d38f166SPawel Wodkowski 	struct pollfd pfd = { .fd = client->sockfd, .events = POLLIN | POLLOUT };
1257d38f166SPawel Wodkowski 
1267d38f166SPawel Wodkowski 	rc = poll(&pfd, 1, timeout);
1277d38f166SPawel Wodkowski 	if (rc == -1) {
1287d38f166SPawel Wodkowski 		if (errno == EINTR) {
1297d38f166SPawel Wodkowski 			/* For EINTR we pretend that nothing was received nor send. */
1307d38f166SPawel Wodkowski 			rc = 0;
1317d38f166SPawel Wodkowski 		} else {
1327d38f166SPawel Wodkowski 			rc = -errno;
1337d38f166SPawel Wodkowski 			SPDK_ERRLOG("poll() failed (%d): %s\n", errno, spdk_strerror(errno));
1347d38f166SPawel Wodkowski 		}
1357d38f166SPawel Wodkowski 	} else if (rc > 0) {
1367d38f166SPawel Wodkowski 		rc = 0;
1377d38f166SPawel Wodkowski 
1387d38f166SPawel Wodkowski 		if (pfd.revents & POLLOUT) {
1391a9ed697SSeth Howell 			rc = jsonrpc_client_send_request(client);
1407d38f166SPawel Wodkowski 		}
1417d38f166SPawel Wodkowski 
1427d38f166SPawel Wodkowski 		if (rc == 0 && (pfd.revents & POLLIN)) {
1431a9ed697SSeth Howell 			rc = jsonrpc_client_recv(client);
1447d38f166SPawel Wodkowski 			/* Incomplete message in buffer isn't an error. */
1457d38f166SPawel Wodkowski 			if (rc == -EAGAIN) {
1467d38f166SPawel Wodkowski 				rc = 0;
1477d38f166SPawel Wodkowski 			}
1487d38f166SPawel Wodkowski 		}
1497d38f166SPawel Wodkowski 	}
1507d38f166SPawel Wodkowski 
1511a9ed697SSeth Howell 	return rc ? rc : jsonrpc_client_resp_ready_count(client);
1527d38f166SPawel Wodkowski }
1537d38f166SPawel Wodkowski 
1547d38f166SPawel Wodkowski static int
jsonrpc_client_poll_connecting(struct spdk_jsonrpc_client * client,int timeout)1551a9ed697SSeth Howell jsonrpc_client_poll_connecting(struct spdk_jsonrpc_client *client, int timeout)
1567d38f166SPawel Wodkowski {
1577d38f166SPawel Wodkowski 	socklen_t rc_len;
1587d38f166SPawel Wodkowski 	int rc;
1597d38f166SPawel Wodkowski 
1607d38f166SPawel Wodkowski 	struct pollfd pfd = {
1617d38f166SPawel Wodkowski 		.fd = client->sockfd,
1627d38f166SPawel Wodkowski 		.events = POLLOUT
1637d38f166SPawel Wodkowski 	};
1647d38f166SPawel Wodkowski 
1657d38f166SPawel Wodkowski 	rc = poll(&pfd, 1, timeout);
1664734811dSPawel Wodkowski 	if (rc == 0) {
1677d38f166SPawel Wodkowski 		return -ENOTCONN;
1687d38f166SPawel Wodkowski 	} else if (rc == -1) {
1697d38f166SPawel Wodkowski 		if (errno != EINTR) {
1707d38f166SPawel Wodkowski 			SPDK_ERRLOG("poll() failed (%d): %s\n", errno, spdk_strerror(errno));
1717d38f166SPawel Wodkowski 			goto err;
1724734811dSPawel Wodkowski 		}
1734734811dSPawel Wodkowski 
1747d38f166SPawel Wodkowski 		/* We are still not connected. Caller will have to call us again. */
1757d38f166SPawel Wodkowski 		return -ENOTCONN;
1767d38f166SPawel Wodkowski 	} else if (pfd.revents & ~POLLOUT) {
1777d38f166SPawel Wodkowski 		/* We only poll for POLLOUT */
1787d38f166SPawel Wodkowski 		goto err;
1797d38f166SPawel Wodkowski 	} else if ((pfd.revents & POLLOUT) == 0) {
1807d38f166SPawel Wodkowski 		/* Is this even possible to get here? */
1817d38f166SPawel Wodkowski 		return -ENOTCONN;
1824734811dSPawel Wodkowski 	}
1834734811dSPawel Wodkowski 
1847d38f166SPawel Wodkowski 	rc_len = sizeof(int);
1857d38f166SPawel Wodkowski 	/* connection might fail so need to check SO_ERROR. */
1867d38f166SPawel Wodkowski 	if (getsockopt(client->sockfd, SOL_SOCKET, SO_ERROR, &rc, &rc_len) == -1) {
1877d38f166SPawel Wodkowski 		goto err;
1887d38f166SPawel Wodkowski 	}
1897d38f166SPawel Wodkowski 
1907d38f166SPawel Wodkowski 	if (rc == 0) {
1917d38f166SPawel Wodkowski 		client->connected = true;
1924734811dSPawel Wodkowski 		return 0;
1934734811dSPawel Wodkowski 	}
1942f557958SPawel Wodkowski 
1957d38f166SPawel Wodkowski err:
1967d38f166SPawel Wodkowski 	return -EIO;
1977d38f166SPawel Wodkowski }
1987d38f166SPawel Wodkowski 
199edf2305dSPawel Wodkowski static int
jsonrpc_client_connect(struct spdk_jsonrpc_client * client,int domain,int protocol,struct sockaddr * server_addr,socklen_t addrlen)2001a9ed697SSeth Howell jsonrpc_client_connect(struct spdk_jsonrpc_client *client, int domain, int protocol,
201c10f8e16SLiu Xiaodong 		       struct sockaddr *server_addr, socklen_t addrlen)
202c10f8e16SLiu Xiaodong {
20332999ab9SJim Harris 	int rc;
204c10f8e16SLiu Xiaodong 
20532999ab9SJim Harris 	client->sockfd = socket(domain, SOCK_STREAM | SOCK_NONBLOCK, protocol);
206c10f8e16SLiu Xiaodong 	if (client->sockfd < 0) {
207edf2305dSPawel Wodkowski 		rc = errno;
208c10f8e16SLiu Xiaodong 		SPDK_ERRLOG("socket() failed\n");
209edf2305dSPawel Wodkowski 		return -rc;
210c10f8e16SLiu Xiaodong 	}
211c10f8e16SLiu Xiaodong 
2127d38f166SPawel Wodkowski 	rc = connect(client->sockfd, server_addr, addrlen);
2137d38f166SPawel Wodkowski 	if (rc != 0) {
2147d38f166SPawel Wodkowski 		rc = errno;
2157d38f166SPawel Wodkowski 		if (rc != EINPROGRESS) {
2167d38f166SPawel Wodkowski 			SPDK_ERRLOG("could not connect to JSON-RPC server: %s\n", spdk_strerror(errno));
2177d38f166SPawel Wodkowski 			goto err;
2187d38f166SPawel Wodkowski 		}
2197d38f166SPawel Wodkowski 	} else {
2207d38f166SPawel Wodkowski 		client->connected = true;
2217d38f166SPawel Wodkowski 	}
2227d38f166SPawel Wodkowski 
2237d38f166SPawel Wodkowski 	return -rc;
224edf2305dSPawel Wodkowski err:
225edf2305dSPawel Wodkowski 	close(client->sockfd);
226edf2305dSPawel Wodkowski 	client->sockfd = -1;
227edf2305dSPawel Wodkowski 	return -rc;
228c10f8e16SLiu Xiaodong }
229c10f8e16SLiu Xiaodong 
230c10f8e16SLiu Xiaodong struct spdk_jsonrpc_client *
spdk_jsonrpc_client_connect(const char * addr,int addr_family)231edf2305dSPawel Wodkowski spdk_jsonrpc_client_connect(const char *addr, int addr_family)
232c10f8e16SLiu Xiaodong {
233edf2305dSPawel Wodkowski 	struct spdk_jsonrpc_client *client = calloc(1, sizeof(struct spdk_jsonrpc_client));
234c10f8e16SLiu Xiaodong 	/* Unix Domain Socket */
235edf2305dSPawel Wodkowski 	struct sockaddr_un addr_un = {};
236edf2305dSPawel Wodkowski 	char *add_in = NULL;
237c10f8e16SLiu Xiaodong 	int rc;
238c10f8e16SLiu Xiaodong 
239edf2305dSPawel Wodkowski 	if (client == NULL) {
240edf2305dSPawel Wodkowski 		SPDK_ERRLOG("%s\n", spdk_strerror(errno));
241c10f8e16SLiu Xiaodong 		return NULL;
242c10f8e16SLiu Xiaodong 	}
243c10f8e16SLiu Xiaodong 
244edf2305dSPawel Wodkowski 	if (addr_family == AF_UNIX) {
245edf2305dSPawel Wodkowski 		addr_un.sun_family = AF_UNIX;
246edf2305dSPawel Wodkowski 		rc = snprintf(addr_un.sun_path, sizeof(addr_un.sun_path), "%s", addr);
247edf2305dSPawel Wodkowski 		if (rc < 0 || (size_t)rc >= sizeof(addr_un.sun_path)) {
248edf2305dSPawel Wodkowski 			rc = -EINVAL;
249edf2305dSPawel Wodkowski 			SPDK_ERRLOG("RPC Listen address Unix socket path too long\n");
250edf2305dSPawel Wodkowski 			goto err;
251edf2305dSPawel Wodkowski 		}
252edf2305dSPawel Wodkowski 
2531a9ed697SSeth Howell 		rc = jsonrpc_client_connect(client, AF_UNIX, 0, (struct sockaddr *)&addr_un, sizeof(addr_un));
254c10f8e16SLiu Xiaodong 	} else {
255c10f8e16SLiu Xiaodong 		/* TCP/IP socket */
256c10f8e16SLiu Xiaodong 		struct addrinfo		hints;
257c10f8e16SLiu Xiaodong 		struct addrinfo		*res;
258c10f8e16SLiu Xiaodong 		char *host, *port;
259c10f8e16SLiu Xiaodong 
260edf2305dSPawel Wodkowski 		add_in = strdup(addr);
261edf2305dSPawel Wodkowski 		if (!add_in) {
262edf2305dSPawel Wodkowski 			rc = -errno;
263edf2305dSPawel Wodkowski 			SPDK_ERRLOG("%s\n", spdk_strerror(errno));
264edf2305dSPawel Wodkowski 			goto err;
265c10f8e16SLiu Xiaodong 		}
266c10f8e16SLiu Xiaodong 
267edf2305dSPawel Wodkowski 		rc = spdk_parse_ip_addr(add_in, &host, &port);
268edf2305dSPawel Wodkowski 		if (rc) {
269edf2305dSPawel Wodkowski 			SPDK_ERRLOG("Invalid listen address '%s'\n", addr);
270edf2305dSPawel Wodkowski 			goto err;
271c10f8e16SLiu Xiaodong 		}
272c10f8e16SLiu Xiaodong 
273c10f8e16SLiu Xiaodong 		if (port == NULL) {
274c10f8e16SLiu Xiaodong 			port = RPC_DEFAULT_PORT;
275c10f8e16SLiu Xiaodong 		}
276c10f8e16SLiu Xiaodong 
277c10f8e16SLiu Xiaodong 		memset(&hints, 0, sizeof(hints));
278c10f8e16SLiu Xiaodong 		hints.ai_family = AF_UNSPEC;
279c10f8e16SLiu Xiaodong 		hints.ai_socktype = SOCK_STREAM;
280c10f8e16SLiu Xiaodong 		hints.ai_protocol = IPPROTO_TCP;
281c10f8e16SLiu Xiaodong 
282edf2305dSPawel Wodkowski 		rc = getaddrinfo(host, port, &hints, &res);
283edf2305dSPawel Wodkowski 		if (rc != 0) {
284cc6920a4SJosh Soref 			SPDK_ERRLOG("Unable to look up RPC connect address '%s' (%d): %s\n", addr, rc, gai_strerror(rc));
285*f6866117STomasz Zawadzki 			rc = -(abs(rc));
286edf2305dSPawel Wodkowski 			goto err;
287c10f8e16SLiu Xiaodong 		}
288c10f8e16SLiu Xiaodong 
2891a9ed697SSeth Howell 		rc = jsonrpc_client_connect(client, res->ai_family, res->ai_protocol, res->ai_addr,
290edf2305dSPawel Wodkowski 					    res->ai_addrlen);
291c10f8e16SLiu Xiaodong 		freeaddrinfo(res);
292c10f8e16SLiu Xiaodong 	}
293c10f8e16SLiu Xiaodong 
294edf2305dSPawel Wodkowski err:
2957d38f166SPawel Wodkowski 	if (rc != 0 && rc != -EINPROGRESS) {
296edf2305dSPawel Wodkowski 		free(client);
297edf2305dSPawel Wodkowski 		client = NULL;
298edf2305dSPawel Wodkowski 		errno = -rc;
299edf2305dSPawel Wodkowski 	}
300edf2305dSPawel Wodkowski 
301edf2305dSPawel Wodkowski 	free(add_in);
302c10f8e16SLiu Xiaodong 	return client;
303c10f8e16SLiu Xiaodong }
304c10f8e16SLiu Xiaodong 
305c10f8e16SLiu Xiaodong void
spdk_jsonrpc_client_close(struct spdk_jsonrpc_client * client)306c10f8e16SLiu Xiaodong spdk_jsonrpc_client_close(struct spdk_jsonrpc_client *client)
307c10f8e16SLiu Xiaodong {
308c10f8e16SLiu Xiaodong 	if (client->sockfd >= 0) {
309c10f8e16SLiu Xiaodong 		close(client->sockfd);
3105d0f2620SPawel Wodkowski 	}
3115d0f2620SPawel Wodkowski 
312c10f8e16SLiu Xiaodong 	free(client->recv_buf);
3135d0f2620SPawel Wodkowski 	if (client->resp) {
3145d0f2620SPawel Wodkowski 		spdk_jsonrpc_client_free_response(&client->resp->jsonrpc);
315c10f8e16SLiu Xiaodong 	}
316c10f8e16SLiu Xiaodong 
317c10f8e16SLiu Xiaodong 	free(client);
318c10f8e16SLiu Xiaodong }
319c10f8e16SLiu Xiaodong 
320c10f8e16SLiu Xiaodong struct spdk_jsonrpc_client_request *
spdk_jsonrpc_client_create_request(void)321c10f8e16SLiu Xiaodong spdk_jsonrpc_client_create_request(void)
322c10f8e16SLiu Xiaodong {
323c10f8e16SLiu Xiaodong 	struct spdk_jsonrpc_client_request *request;
324c10f8e16SLiu Xiaodong 
325c10f8e16SLiu Xiaodong 	request = calloc(1, sizeof(*request));
326c10f8e16SLiu Xiaodong 	if (request == NULL) {
327c10f8e16SLiu Xiaodong 		return NULL;
328c10f8e16SLiu Xiaodong 	}
329c10f8e16SLiu Xiaodong 
330c10f8e16SLiu Xiaodong 	/* memory malloc for send-buf */
331c10f8e16SLiu Xiaodong 	request->send_buf = malloc(SPDK_JSONRPC_SEND_BUF_SIZE_INIT);
332c10f8e16SLiu Xiaodong 	if (!request->send_buf) {
333c10f8e16SLiu Xiaodong 		SPDK_ERRLOG("memory malloc for send-buf failed\n");
334c10f8e16SLiu Xiaodong 		free(request);
335c10f8e16SLiu Xiaodong 		return NULL;
336c10f8e16SLiu Xiaodong 	}
337c10f8e16SLiu Xiaodong 	request->send_buf_size = SPDK_JSONRPC_SEND_BUF_SIZE_INIT;
338c10f8e16SLiu Xiaodong 
339c10f8e16SLiu Xiaodong 	return request;
340c10f8e16SLiu Xiaodong }
341c10f8e16SLiu Xiaodong 
342c10f8e16SLiu Xiaodong void
spdk_jsonrpc_client_free_request(struct spdk_jsonrpc_client_request * req)343c10f8e16SLiu Xiaodong spdk_jsonrpc_client_free_request(struct spdk_jsonrpc_client_request *req)
344c10f8e16SLiu Xiaodong {
345c10f8e16SLiu Xiaodong 	free(req->send_buf);
346c10f8e16SLiu Xiaodong 	free(req);
347c10f8e16SLiu Xiaodong }
348c10f8e16SLiu Xiaodong 
3492f557958SPawel Wodkowski int
spdk_jsonrpc_client_poll(struct spdk_jsonrpc_client * client,int timeout)3507d38f166SPawel Wodkowski spdk_jsonrpc_client_poll(struct spdk_jsonrpc_client *client, int timeout)
3512f557958SPawel Wodkowski {
3527d38f166SPawel Wodkowski 	if (client->connected) {
3531a9ed697SSeth Howell 		return jsonrpc_client_poll(client, timeout);
3547d38f166SPawel Wodkowski 	} else {
3551a9ed697SSeth Howell 		return jsonrpc_client_poll_connecting(client, timeout);
3567d38f166SPawel Wodkowski 	}
3572f557958SPawel Wodkowski }
3582f557958SPawel Wodkowski 
3598dd1cd21SBen Walker int
spdk_jsonrpc_client_send_request(struct spdk_jsonrpc_client * client,struct spdk_jsonrpc_client_request * req)3608dd1cd21SBen Walker spdk_jsonrpc_client_send_request(struct spdk_jsonrpc_client *client,
3612f557958SPawel Wodkowski 				 struct spdk_jsonrpc_client_request *req)
3622f557958SPawel Wodkowski {
3632f557958SPawel Wodkowski 	if (client->request != NULL) {
3642f557958SPawel Wodkowski 		return -ENOSPC;
3652f557958SPawel Wodkowski 	}
3662f557958SPawel Wodkowski 
3672f557958SPawel Wodkowski 	client->request = req;
3682f557958SPawel Wodkowski 	return 0;
3692f557958SPawel Wodkowski }
3702f557958SPawel Wodkowski 
3715d0f2620SPawel Wodkowski struct spdk_jsonrpc_client_response *
spdk_jsonrpc_client_get_response(struct spdk_jsonrpc_client * client)3725d0f2620SPawel Wodkowski spdk_jsonrpc_client_get_response(struct spdk_jsonrpc_client *client)
3735d0f2620SPawel Wodkowski {
3742f557958SPawel Wodkowski 	struct spdk_jsonrpc_client_response_internal *r;
3755d0f2620SPawel Wodkowski 
3762f557958SPawel Wodkowski 	r = client->resp;
3772f557958SPawel Wodkowski 	if (r == NULL || r->ready == false) {
3785d0f2620SPawel Wodkowski 		return NULL;
3795d0f2620SPawel Wodkowski 	}
3805d0f2620SPawel Wodkowski 
3815d0f2620SPawel Wodkowski 	client->resp = NULL;
3825d0f2620SPawel Wodkowski 	return &r->jsonrpc;
3835d0f2620SPawel Wodkowski }
3845d0f2620SPawel Wodkowski 
3855d0f2620SPawel Wodkowski void
spdk_jsonrpc_client_free_response(struct spdk_jsonrpc_client_response * resp)3865d0f2620SPawel Wodkowski spdk_jsonrpc_client_free_response(struct spdk_jsonrpc_client_response *resp)
3875d0f2620SPawel Wodkowski {
3885d0f2620SPawel Wodkowski 	struct spdk_jsonrpc_client_response_internal *r;
3895d0f2620SPawel Wodkowski 
3905d0f2620SPawel Wodkowski 	if (!resp) {
3915d0f2620SPawel Wodkowski 		return;
3925d0f2620SPawel Wodkowski 	}
3935d0f2620SPawel Wodkowski 
3945d0f2620SPawel Wodkowski 	r = SPDK_CONTAINEROF(resp, struct spdk_jsonrpc_client_response_internal, jsonrpc);
3955d0f2620SPawel Wodkowski 	free(r->buf);
3965d0f2620SPawel Wodkowski 	free(r);
3975d0f2620SPawel Wodkowski }
398