Searched refs:recv_offset (Results 1 – 4 of 4) sorted by relevance
| /spdk/lib/jsonrpc/ |
| H A D | jsonrpc_client_tcp.c | 90 client->recv_offset = 0; in jsonrpc_client_recv()
91 } else if (client->recv_offset == client->recv_buf_size - 1) { in jsonrpc_client_recv()
98 rc = recv(client->sockfd, client->recv_buf + client->recv_offset, in jsonrpc_client_recv()
99 client->recv_buf_size - client->recv_offset - 1, 0); in jsonrpc_client_recv()
113 client->recv_offset += rc; in jsonrpc_client_recv()
114 client->recv_buf[client->recv_offset] = '\0'; in jsonrpc_client_recv()
|
| H A D | jsonrpc_client.c | 62 rc = spdk_json_parse(client->recv_buf, client->recv_offset, NULL, 0, &end, 0); in jsonrpc_parse_response()
92 buf_len = client->recv_offset; in jsonrpc_parse_response()
96 client->recv_offset = 0; in jsonrpc_parse_response()
|
| H A D | jsonrpc_internal.h | 106 size_t recv_offset; member
|
| /spdk/module/sock/uring/ |
| H A D | uring.c | 77 size_t recv_offset;
898 *_buf = tr->buf + sock->recv_offset; in uring_sock_readv_no_pipe()
909 return tr->len - sock->recv_offset; in uring_sock_readv_no_pipe()
955 len = spdk_min(iov.iov_len, tr->len - sock->recv_offset); in uring_sock_readv_no_pipe()
956 memcpy(iov.iov_base, tr->buf + sock->recv_offset, len); in uring_sock_readv_no_pipe()
959 sock->recv_offset += len; in uring_sock_readv_no_pipe()
963 if (sock->recv_offset == tr->len) { in uring_sock_readv_no_pipe()
964 sock->recv_offset = 0; in uring_sock_readv_no_pipe()
76 size_t recv_offset; global() member
|