Lines Matching defs:server_sock

343 	struct spdk_sock *server_sock;
355 	server_sock = spdk_sock_accept(listen_sock);
356 	CU_ASSERT(server_sock == NULL);
368 	server_sock = spdk_sock_accept(listen_sock);
369 	SPDK_CU_ASSERT_FATAL(server_sock != NULL);
371 	CU_ASSERT(spdk_sock_is_connected(server_sock) == true);
411 	bytes_read = spdk_sock_recv(server_sock, buffer, 2);
416 	bytes_read += spdk_sock_recv(server_sock, buffer + 2, 5);
431 	bytes_read = spdk_sock_readv(server_sock, &iov, 1);
438 	bytes_read += spdk_sock_readv(server_sock, &iov, 1);
454 	CU_ASSERT(spdk_sock_is_connected(server_sock) == false);
456 	rc = spdk_sock_close(&server_sock);
457 	CU_ASSERT(server_sock == NULL);
480 	struct spdk_sock *server_sock = cb_arg;
482 	CU_ASSERT(server_sock == sock);
485 	g_bytes_read += spdk_sock_recv(server_sock, g_buf + g_bytes_read, sizeof(g_buf) - g_bytes_read);
494 	struct spdk_sock *server_sock;
504 	server_sock = spdk_sock_accept(listen_sock);
505 	CU_ASSERT(server_sock == NULL);
513 	server_sock = spdk_sock_accept(listen_sock);
514 	SPDK_CU_ASSERT_FATAL(server_sock != NULL);
523 	rc = spdk_sock_group_add_sock(group, server_sock, NULL, NULL);
527 	rc = spdk_sock_group_add_sock(group, server_sock, read_data, server_sock);
531 	rc = spdk_sock_group_add_sock(group, server_sock, read_data, server_sock);
564 	rc = spdk_sock_get_optimal_sock_group(server_sock, &group, hint);
573 	rc = spdk_sock_close(&server_sock);
577 	rc = spdk_sock_group_remove_sock(group, server_sock);
588 	rc = spdk_sock_close(&server_sock);
589 	CU_ASSERT(server_sock == NULL);
612 	struct spdk_sock *server_sock = cb_arg;
617 	CU_ASSERT(server_sock == sock);
619 	g_server_sock_read = server_sock;
620 	bytes_read = spdk_sock_recv(server_sock, buf, 1);
629 	struct spdk_sock *server_sock[3];
648 		server_sock[i] = spdk_sock_accept(listen_sock);
649 		SPDK_CU_ASSERT_FATAL(server_sock[i] != NULL);
651 		rc = spdk_sock_group_add_sock(group, server_sock[i],
652 					      read_data_fairness, server_sock[i]);
673 	CU_ASSERT(g_server_sock_read == server_sock[0]);
688 	CU_ASSERT(g_server_sock_read == server_sock[1]);
693 	CU_ASSERT(g_server_sock_read == server_sock[2]);
698 	CU_ASSERT(g_server_sock_read == server_sock[0]);
701 		rc = spdk_sock_group_remove_sock(group, server_sock[i]);
708 		rc = spdk_sock_close(&server_sock[i]);
709 		CU_ASSERT(server_sock[i] == NULL);
756 	struct spdk_sock *server_sock;
772 	server_sock = spdk_sock_accept(listen_sock);
773 	SPDK_CU_ASSERT_FATAL(server_sock != NULL);
778 	rc = spdk_sock_group_add_sock(group, server_sock, read_data, server_sock);
788 	ctx.sock = server_sock;
793 	spdk_sock_writev_async(server_sock, req1);
803 	spdk_sock_writev_async(server_sock, req2);