Lines Matching defs:sock
12 #include "spdk_internal/sock.h"
14 #include "sock/sock.c"
15 #include "sock/posix/posix.c"
42 struct spdk_ut_sock *sock;
45 #define __ut_sock(sock) (struct spdk_ut_sock *)sock
58 struct spdk_ut_sock *sock;
66 sock = calloc(1, sizeof(*sock));
67 SPDK_CU_ASSERT_FATAL(sock != NULL);
68 g_ut_listen_sock = sock;
70 return &sock->base;
76 struct spdk_ut_sock *sock;
82 sock = calloc(1, sizeof(*sock));
83 SPDK_CU_ASSERT_FATAL(sock != NULL);
86 g_ut_client_sock = sock;
88 return &sock->base;
94 struct spdk_ut_sock *sock = __ut_sock(_sock);
97 CU_ASSERT(sock == g_ut_listen_sock);
105 new_sock = calloc(1, sizeof(*sock));
107 SPDK_ERRLOG("sock allocation failed\n");
121 struct spdk_ut_sock *sock = __ut_sock(_sock);
123 if (sock == g_ut_listen_sock) {
126 if (sock == g_ut_client_sock) {
130 if (sock->peer != NULL) {
131 sock->peer->peer = NULL;
142 struct spdk_ut_sock *sock = __ut_sock(_sock);
145 len = spdk_min(len, sock->bytes_avail);
152 memcpy(buf, sock->buf, len);
153 memcpy(tmp, &sock->buf[len], sock->bytes_avail - len);
154 memcpy(sock->buf, tmp, sock->bytes_avail - len);
155 sock->bytes_avail -= len;
163 struct spdk_ut_sock *sock = __ut_sock(_sock);
170 len = spdk_min(iov[0].iov_len, sock->bytes_avail);
177 memcpy(iov[0].iov_base, sock->buf, len);
178 memcpy(tmp, &sock->buf[len], sock->bytes_avail - len);
179 memcpy(sock->buf, tmp, sock->bytes_avail - len);
180 sock->bytes_avail -= len;
188 struct spdk_ut_sock *sock = __ut_sock(_sock);
191 SPDK_CU_ASSERT_FATAL(sock->peer != NULL);
192 peer = sock->peer;
204 spdk_ut_sock_flush(struct spdk_sock *sock)
242 struct spdk_ut_sock *sock = __ut_sock(_sock);
244 return (sock->peer != NULL);
268 struct spdk_ut_sock *sock = __ut_sock(_sock);
270 group->sock = sock;
279 struct spdk_ut_sock *sock = __ut_sock(_sock);
281 CU_ASSERT(group->sock == sock);
282 group->sock = NULL;
293 if (group->sock != NULL && group->sock->bytes_avail > 0) {
294 socks[0] = &group->sock->base;
306 CU_ASSERT(group->sock == NULL);
478 read_data(void *cb_arg, struct spdk_sock_group *group, struct spdk_sock *sock)
482 CU_ASSERT(server_sock == sock);
530 /* try adding sock a second time */
572 /* Try to close sock while it is still part of a sock_group. */
610 read_data_fairness(void *cb_arg, struct spdk_sock_group *group, struct spdk_sock *sock)
617 CU_ASSERT(server_sock == sock);
667 * Poll for just one event - this should be server sock 0, since that
668 * is the peer of the first client sock that we wrote to.
676 * Now write another byte to client sock 0. We want to ensure that
677 * the sock group does not unfairly process the event for this sock
724 struct spdk_sock *sock;
737 rc = spdk_sock_group_remove_sock(ctx->group, ctx->sock);
739 spdk_sock_close(&ctx->sock);
781 /* Submit multiple async writevs on the server sock */
788 ctx.sock = server_sock;
806 /* Test spdk_sock_flush when sock is NULL */
811 /* Test spdk_sock_flush when sock is not NULL */
1294 suite = CU_add_suite("sock", NULL, NULL);