| /third_party/mbedtls/programs/ssl/ |
| D | ssl_pthread_server.c | 138 mbedtls_net_context client_fd; member
156 mbedtls_net_context *client_fd = &thread_info->client_fd; in handle_ssl_connection() local
176 mbedtls_ssl_set_bio( &ssl, client_fd, mbedtls_net_send, mbedtls_net_recv, NULL ); in handle_ssl_connection()
297 mbedtls_net_free( client_fd ); in handle_ssl_connection()
305 static int thread_create( mbedtls_net_context *client_fd ) in thread_create() argument
334 memcpy( &threads[i].data.client_fd, client_fd, sizeof( mbedtls_net_context ) ); in thread_create()
348 mbedtls_net_context listen_fd, client_fd; in main() local
379 mbedtls_net_init( &client_fd ); in main()
509 if( ( ret = mbedtls_net_accept( &listen_fd, &client_fd, in main()
519 if( ( ret = thread_create( &client_fd ) ) != 0 ) in main()
[all …]
|
| D | ssl_server.c | 125 mbedtls_net_context listen_fd, client_fd; in main() local
140 mbedtls_net_init( &client_fd ); in main()
271 mbedtls_net_free( &client_fd ); in main()
281 if( ( ret = mbedtls_net_accept( &listen_fd, &client_fd, in main()
288 mbedtls_ssl_set_bio( &ssl, &client_fd, mbedtls_net_send, mbedtls_net_recv, NULL ); in main()
407 mbedtls_net_free( &client_fd ); in main()
|
| D | ssl_fork_server.c | 130 mbedtls_net_context listen_fd, client_fd; in main() local
142 mbedtls_net_init( &client_fd ); in main()
251 mbedtls_net_init( &client_fd ); in main()
257 if( ( ret = mbedtls_net_accept( &listen_fd, &client_fd, in main()
322 mbedtls_ssl_set_bio( &ssl, &client_fd, mbedtls_net_send, mbedtls_net_recv, NULL ); in main()
429 mbedtls_net_free( &client_fd ); in main()
|
| D | dtls_server.c | 134 mbedtls_net_context listen_fd, client_fd; in main() local
153 mbedtls_net_init( &client_fd ); in main()
299 mbedtls_net_free( &client_fd ); in main()
309 if( ( ret = mbedtls_net_accept( &listen_fd, &client_fd, in main()
325 mbedtls_ssl_set_bio( &ssl, &client_fd, in main()
437 mbedtls_net_free( &client_fd ); in main()
|
| D | ssl_server2.c | 917 static mbedtls_net_context listen_fd, client_fd; variable
927 mbedtls_net_free( &client_fd ); /* causes net_read() to abort */ in term_handler()
1313 mbedtls_net_init( &client_fd ); in main()
2614 mbedtls_ssl_set_bio( &ssl, &client_fd, my_send, my_recv, NULL ); in main()
2616 mbedtls_ssl_set_bio( &ssl, &client_fd, mbedtls_net_send, mbedtls_net_recv, in main()
2658 mbedtls_net_free( &client_fd ); in main()
2668 if( ( ret = mbedtls_net_accept( &listen_fd, &client_fd, in main()
2687 ret = mbedtls_net_set_nonblock( &client_fd ); in main()
2689 ret = mbedtls_net_set_block( &client_fd ); in main()
2751 ret = idle( &client_fd, &timer, ret ); in main()
[all …]
|
| /third_party/libuv/test/ |
| D | test-poll-oob.c | 38 static uv_os_fd_t client_fd; variable
78 n = recv(client_fd, &buffer, 5, MSG_OOB); in poll_cb()
88 if (fd == client_fd) { in poll_cb()
90 n = recv(client_fd, &buffer, 5, 0); in poll_cb()
129 n = send(client_fd, "foo", 3, 0); in poll_cb()
141 ASSERT(0 == uv_poll_init_socket(uv_default_loop(), &poll_req[0], client_fd)); in connection_cb()
181 client_fd = socket(PF_INET, SOCK_STREAM, 0); in TEST_IMPL()
182 ASSERT(client_fd >= 0); in TEST_IMPL()
185 r = connect(client_fd, (const struct sockaddr*)&addr, sizeof(addr)); in TEST_IMPL()
|
| /third_party/mbedtls/programs/pkey/ |
| D | dh_server.c | 108 mbedtls_net_context listen_fd, client_fd; in main() local
124 mbedtls_net_init( &client_fd ); in main()
225 if( ( ret = mbedtls_net_accept( &listen_fd, &client_fd, in main()
270 if( ( ret = mbedtls_net_send( &client_fd, buf2, 2 ) ) != 2 || in main()
271 ( ret = mbedtls_net_send( &client_fd, buf, buflen ) ) != (int) buflen ) in main()
286 if( ( ret = mbedtls_net_recv( &client_fd, buf, n ) ) != (int) n ) in main()
329 if( ( ret = mbedtls_net_send( &client_fd, buf, 16 ) ) != 16 ) in main()
344 mbedtls_net_free( &client_fd ); in main()
|
| /third_party/mbedtls/programs/test/ |
| D | udp_proxy.c | 799 mbedtls_net_context listen_fd, client_fd, server_fd; in main() local
811 mbedtls_net_init( &client_fd ); in main()
868 mbedtls_net_free( &client_fd ); in main()
873 if( ( ret = mbedtls_net_accept( &listen_fd, &client_fd, in main()
888 nb_fds = client_fd.fd; in main()
903 outbuf[1].ctx = &client_fd; in main()
950 FD_SET( client_fd.fd, &read_fds ); in main()
962 if( FD_ISSET( client_fd.fd, &read_fds ) ) in main()
965 &server_fd, &client_fd ) ) != 0 ) in main()
972 &client_fd, &server_fd ) ) != 0 ) in main()
[all …]
|
| /third_party/grpc/test/core/bad_client/ |
| D | bad_client.cc | 79 static void shutdown_client(grpc_endpoint** client_fd) { in shutdown_client() argument
80 if (*client_fd != nullptr) { in shutdown_client()
82 *client_fd, GRPC_ERROR_CREATE_FROM_STATIC_STRING("Forced Disconnect")); in shutdown_client()
83 grpc_endpoint_destroy(*client_fd); in shutdown_client()
85 *client_fd = nullptr; in shutdown_client()
|
| /third_party/grpc/test/core/network_benchmarks/ |
| D | low_level_ping_pong.cc | 419 int client_fd = -1; in create_sockets_tcp() local
435 client_fd = connect_client(sa_port, sizeof(port)); in create_sockets_tcp()
436 if (client_fd == -1) { in create_sockets_tcp()
447 client_fds->read_fd = client_fd; in create_sockets_tcp()
448 client_fds->write_fd = client_fd; in create_sockets_tcp()
458 if (client_fd != -1) { in create_sockets_tcp()
459 close(client_fd); in create_sockets_tcp()
|
| /third_party/ltp/testcases/network/netstress/ |
| D | netstress.c | 636 static pthread_t server_thread_add(intptr_t client_fd) in server_thread_add() argument
639 SAFE_PTHREAD_CREATE(&id, &attr, server_fn, (void *) client_fd); in server_thread_add()
750 int client_fd = accept(sfd, (struct sockaddr *)&addr6, in server_run() local
753 if (client_fd == -1) in server_run()
756 server_thread_add(client_fd); in server_run()
|
| /third_party/nghttp2/src/ |
| D | shrpx_worker.cc | 437 WLOG(INFO, this) << "WorkerEvent: client_fd=" << wev.client_fd in process_events()
447 close(wev.client_fd); in process_events()
453 tls::accept_connection(this, wev.client_fd, &wev.client_addr.sa, in process_events()
459 close(wev.client_fd); in process_events()
|
| D | shrpx_worker.h | 259 int client_fd; member
|
| D | shrpx_connection_handler.cc | 434 wev.client_fd = fd; in handle_connection()
|
| /third_party/wayland_standard/src/ |
| D | wayland-server.c | 1417 int client_fd; in socket_data() local
1420 client_fd = wl_os_accept_cloexec(fd, (struct sockaddr *) &name, in socket_data()
1422 if (client_fd < 0) in socket_data()
1425 if (!wl_client_create(display, client_fd)) in socket_data()
1426 close(client_fd); in socket_data()
|