15 	ssize_t rc;  in jsonrpc_client_send_request()  local
23 		rc = send(client->sockfd, request->send_buf + request->send_offset,  in jsonrpc_client_send_request()
25 		if (rc < 0) {  in jsonrpc_client_send_request()
28 				rc = 0;  in jsonrpc_client_send_request()
30 				rc = -errno;  in jsonrpc_client_send_request()
34 			return rc;  in jsonrpc_client_send_request()
37 		request->send_offset += rc;  in jsonrpc_client_send_request()
38 		request->send_len -= rc;  in jsonrpc_client_send_request()
80 	ssize_t rc;  in jsonrpc_client_recv()  local
85 			rc = errno;  in jsonrpc_client_recv()
86 			SPDK_ERRLOG("malloc() failed (%d): %s\n", (int)rc, spdk_strerror(rc));  in jsonrpc_client_recv()
87 			return -rc;  in jsonrpc_client_recv()
92 		rc = recv_buf_expand(client);  in jsonrpc_client_recv()
93 		if (rc) {  in jsonrpc_client_recv()
94 			return rc;  in jsonrpc_client_recv()
98 	rc = recv(client->sockfd, client->recv_buf + client->recv_offset,  in jsonrpc_client_recv()
100 	if (rc < 0) {  in jsonrpc_client_recv()
105 			rc = -errno;  in jsonrpc_client_recv()
107 			return rc;  in jsonrpc_client_recv()
109 	} else if (rc == 0) {  in jsonrpc_client_recv()
113 	client->recv_offset += rc;  in jsonrpc_client_recv()
123 	int rc;  in jsonrpc_client_poll()  local
126 	rc = poll(&pfd, 1, timeout);  in jsonrpc_client_poll()
127 	if (rc == -1) {  in jsonrpc_client_poll()
130 			rc = 0;  in jsonrpc_client_poll()
132 			rc = -errno;  in jsonrpc_client_poll()
135 	} else if (rc > 0) {  in jsonrpc_client_poll()
136 		rc = 0;  in jsonrpc_client_poll()
139 			rc = jsonrpc_client_send_request(client);  in jsonrpc_client_poll()
142 		if (rc == 0 && (pfd.revents & POLLIN)) {  in jsonrpc_client_poll()
143 			rc = jsonrpc_client_recv(client);  in jsonrpc_client_poll()
145 			if (rc == -EAGAIN) {  in jsonrpc_client_poll()
146 				rc = 0;  in jsonrpc_client_poll()
151 	return rc ? rc : jsonrpc_client_resp_ready_count(client);  in jsonrpc_client_poll()
158 	int rc;  in jsonrpc_client_poll_connecting()  local
165 	rc = poll(&pfd, 1, timeout);  in jsonrpc_client_poll_connecting()
166 	if (rc == 0) {  in jsonrpc_client_poll_connecting()
168 	} else if (rc == -1) {  in jsonrpc_client_poll_connecting()
186 	if (getsockopt(client->sockfd, SOL_SOCKET, SO_ERROR, &rc, &rc_len) == -1) {  in jsonrpc_client_poll_connecting()
190 	if (rc == 0) {  in jsonrpc_client_poll_connecting()
203 	int rc;  in jsonrpc_client_connect()  local
207 		rc = errno;  in jsonrpc_client_connect()
209 		return -rc;  in jsonrpc_client_connect()
212 	rc = connect(client->sockfd, server_addr, addrlen);  in jsonrpc_client_connect()
213 	if (rc != 0) {  in jsonrpc_client_connect()
214 		rc = errno;  in jsonrpc_client_connect()
215 		if (rc != EINPROGRESS) {  in jsonrpc_client_connect()
223 	return -rc;  in jsonrpc_client_connect()
227 	return -rc;  in jsonrpc_client_connect()
237 	int rc;  in spdk_jsonrpc_client_connect()  local
246 		rc = snprintf(addr_un.sun_path, sizeof(addr_un.sun_path), "%s", addr);  in spdk_jsonrpc_client_connect()
247 		if (rc < 0 || (size_t)rc >= sizeof(addr_un.sun_path)) {  in spdk_jsonrpc_client_connect()
248 			rc = -EINVAL;  in spdk_jsonrpc_client_connect()
253 		rc = jsonrpc_client_connect(client, AF_UNIX, 0, (struct sockaddr *)&addr_un, sizeof(addr_un));  in spdk_jsonrpc_client_connect()
262 			rc = -errno;  in spdk_jsonrpc_client_connect()
267 		rc = spdk_parse_ip_addr(add_in, &host, &port);  in spdk_jsonrpc_client_connect()
268 		if (rc) {  in spdk_jsonrpc_client_connect()
282 		rc = getaddrinfo(host, port, &hints, &res);  in spdk_jsonrpc_client_connect()
283 		if (rc != 0) {  in spdk_jsonrpc_client_connect()
284 			SPDK_ERRLOG("Unable to look up RPC connect address '%s' (%d): %s\n", addr, rc, gai_strerror(rc));  in spdk_jsonrpc_client_connect()
285 			rc = -(abs(rc));  in spdk_jsonrpc_client_connect()
289 		rc = jsonrpc_client_connect(client, res->ai_family, res->ai_protocol, res->ai_addr,  in spdk_jsonrpc_client_connect()
295 	if (rc != 0 && rc != -EINPROGRESS) {  in spdk_jsonrpc_client_connect()
298 		errno = -rc;  in spdk_jsonrpc_client_connect()