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