/third_party/node/deps/ngtcp2/ngtcp2/lib/ |
H A D | ngtcp2_idtr.c | 29 void ngtcp2_idtr_init(ngtcp2_idtr *idtr, int server, const ngtcp2_mem *mem) { in ngtcp2_idtr_init() argument 32 idtr->server = server; in ngtcp2_idtr_init() 54 assert((idtr->server && (stream_id % 2)) || in ngtcp2_idtr_open() 55 (!idtr->server && (stream_id % 2)) == 0); in ngtcp2_idtr_open() 69 assert((idtr->server && (stream_id % 2)) || in ngtcp2_idtr_is_open() 70 (!idtr->server && (stream_id % 2)) == 0); in ngtcp2_idtr_is_open()
|
/third_party/node/deps/ngtcp2/nghttp3/lib/ |
H A D | nghttp3_idtr.c | 30 void nghttp3_idtr_init(nghttp3_idtr *idtr, int server, const nghttp3_mem *mem) { in nghttp3_idtr_init() argument 33 idtr->server = server; in nghttp3_idtr_init() 55 assert((idtr->server && (stream_id % 2)) || in nghttp3_idtr_open() 56 (!idtr->server && (stream_id % 2)) == 0); in nghttp3_idtr_open() 70 assert((idtr->server && (stream_id % 2)) || in nghttp3_idtr_is_open() 71 (!idtr->server && (stream_id % 2)) == 0); in nghttp3_idtr_is_open()
|
/third_party/libuv/test/ |
H A D | test-delayed-accept.c | 49 uv_tcp_t* server; in do_accept() local 59 server = (uv_tcp_t*)timer_handle->data; in do_accept() 60 r = uv_accept((uv_stream_t*)server, (uv_stream_t*)accepted_handle); in do_accept() 68 /* After accepting the two clients close the server handle */ in do_accept() 70 uv_close((uv_handle_t*)server, close_cb); in do_accept() 102 uv_tcp_t* server = (uv_tcp_t*)malloc(sizeof *server); in start_server() local 106 ASSERT_NOT_NULL(server); in start_server() 108 r = uv_tcp_init(uv_default_loop(), server); in start_server() 110 r = uv_tcp_bind(server, (cons in start_server() [all...] |
H A D | test-tcp-connect6-error.c | 49 uv_tcp_t server; in TEST_IMPL() local 58 r = uv_tcp_init(uv_default_loop(), &server); in TEST_IMPL() 61 &server, in TEST_IMPL() 66 uv_close((uv_handle_t*)&server, close_cb); in TEST_IMPL() 83 uv_tcp_t server; in TEST_IMPL() local 111 ASSERT_OK(uv_tcp_init(uv_default_loop(), &server)); in TEST_IMPL() 120 &server, in TEST_IMPL() 124 uv_close((uv_handle_t*) &server, NULL); in TEST_IMPL()
|
H A D | test-udp-multicast-join.c | 30 ASSERT_NE((uv_udp_t*)(handle) == &server || (uv_udp_t*)(handle) == &client, 0) 34 static uv_udp_t server; variable 117 /* we are done with the server handle, we can close it */ in cl_recv_cb() 118 uv_close((uv_handle_t*) &server, close_cb); in cl_recv_cb() 126 r = uv_udp_set_membership(&server, MULTICAST_ADDR, NULL, UV_LEAVE_GROUP); in cl_recv_cb() 130 r = uv_udp_set_source_membership(&server, MULTICAST_ADDR, NULL, source_addr, UV_JOIN_GROUP); in cl_recv_cb() 149 r = uv_udp_init(uv_default_loop(), &server); in TEST_IMPL() 156 r = uv_udp_bind(&server, (const struct sockaddr*) &addr, 0); in TEST_IMPL() 160 r = uv_udp_set_membership(&server, MULTICAST_ADDR, NULL, UV_JOIN_GROUP); in TEST_IMPL() 165 r = uv_udp_recv_start(&server, alloc_c in TEST_IMPL() [all...] |
H A D | test-tcp-create-socket-early.c | 40 static void on_connection(uv_stream_t* server, int status) { in on_connection() argument 49 r = uv_tcp_init_ex(server->loop, handle, AF_INET); in on_connection() 52 r = uv_accept(server, (uv_stream_t*)handle); in on_connection() 55 uv_close((uv_handle_t*) server, NULL); in on_connection() 60 static void tcp_listener(uv_loop_t* loop, uv_tcp_t* server) { in tcp_listener() argument 66 r = uv_tcp_init(loop, server); in tcp_listener() 69 r = uv_tcp_bind(server, (const struct sockaddr*) &addr, 0); in tcp_listener() 72 r = uv_listen((uv_stream_t*) server, 128, on_connection); in tcp_listener() 203 uv_tcp_t client, server; in TEST_IMPL() local 206 tcp_listener(uv_default_loop(), &server); in TEST_IMPL() local [all...] |
H A D | test-udp-multicast-interface6.c | 30 ASSERT_NE((uv_udp_t*)(handle) == &server || (uv_udp_t*)(handle) == &client, 0) 32 static uv_udp_t server; variable 73 r = uv_udp_init(uv_default_loop(), &server); in TEST_IMPL() 77 r = uv_udp_bind(&server, (const struct sockaddr*)&baddr, 0); in TEST_IMPL() 81 r = uv_udp_set_multicast_interface(&server, "::1%lo0"); in TEST_IMPL() 83 r = uv_udp_set_multicast_interface(&server, NULL); in TEST_IMPL() 87 /* server sends "PING" */ in TEST_IMPL() 90 &server, in TEST_IMPL()
|
H A D | test-udp-multicast-interface.c | 30 ASSERT_NE((uv_udp_t*)(handle) == &server || (uv_udp_t*)(handle) == &client, 0) 32 static uv_udp_t server; variable 70 r = uv_udp_init(uv_default_loop(), &server); in TEST_IMPL() 74 r = uv_udp_bind(&server, (const struct sockaddr*)&baddr, 0); in TEST_IMPL() 77 r = uv_udp_set_multicast_interface(&server, "0.0.0.0"); in TEST_IMPL() 80 /* server sends "PING" */ in TEST_IMPL() 83 &server, in TEST_IMPL() 100 ASSERT_OK(server.send_queue_size); in TEST_IMPL()
|
/third_party/node/test/parallel/ |
H A D | test-https-insecure-parse-per-stream.js | 23 // Test 1: The server sends an invalid header. 66 const server = https.createServer( 75 server.on('clientError', common.mustNotCall()); 77 server.listen(0, common.mustCall(() => { 79 port: server.address().port, 90 server.close(); 97 const server = https.createServer( 101 server.on('clientError', common.mustCall()); 103 server.listen(0, common.mustCall(() => { 105 port: server [all...] |
H A D | test-https-max-header-size-per-stream.js | 25 // Test 1: The server sends larger headers than what would otherwise be allowed. 66 const server = https.createServer( 75 server.on('clientError', common.mustNotCall()); 77 server.listen(0, common.mustCall(() => { 79 port: server.address().port, 90 server.close(); 97 const server = https.createServer({ ...certFixture }, common.mustNotCall()); 101 server.on('clientError', common.mustCallAtLeast(1)); 103 server.listen(0, common.mustCall(() => { 105 port: server [all...] |
H A D | test-http-generic-streams.js | 10 const server = http.createServer(common.mustCall((req, res) => { 17 server.emit('connection', serverSide); 34 const server = http.createServer(common.mustCall((req, res) => { 41 server.emit('connection', serverSide); 66 const server = http.createServer(common.mustCall((req, res) => { 81 server.emit('connection', serverSide); 104 const server = http.createServer(common.mustCall((req, res) => { 121 server.emit('connection', serverSide); 144 const server = http.createServer(common.mustNotCall()); 147 server [all...] |
H A D | test-net-server-max-connections.js | 28 // This test creates 20 connections to a server and sets the server's 36 const server = net.createServer(common.mustCall(function(connection) { 41 server.listen(0, function() { 45 server.maxConnections = N / 2; 49 const c = net.createConnection(server.address().port); 63 server.maxConnections <= index, 74 server.close(); 77 if (index < server.maxConnections) { 98 c.connect(server [all...] |
H A D | test-tls-sni-server-client.js | 103 const server = tls.createServer(serverOptions, (c) => { 108 server.addContext('a.example.com', SNIContexts['a.example.com']); 109 server.addContext('*.test.com', SNIContexts['asterisk.test.com']); 110 server.addContext('chain.example.com', SNIContexts['chain.example.com']); 112 server.on('tlsClientError', common.mustNotCall()); 114 server.listen(0, () => { 117 port: server.address().port, 127 server.close();
|
H A D | test-diagnostics-channel-http-server-start.js | 13 dc.subscribe('http.server.request.start', common.mustCall((message) => { 20 dc.subscribe('http.server.response.finish', common.mustCall((message) => { 24 server, 38 const server = http.createServer(common.mustCall((req, res) => { 47 server.listen(() => { 48 const { port } = server.address(); 52 server.close(); 61 assert.strictEqual(a.server, b.server);
|
H A D | test-http-agent-scheduling.js | 47 const server = createServer(8); 48 server.listen(0, onListen); 51 const url = `http://localhost:${server.address().port}`; 64 server.close(); 74 const server = createServer(8); 75 server.listen(0, onListen); 78 const url = `http://localhost:${server.address().port}`; 92 server.close(); 102 const server = createServer(8); 103 server [all...] |
H A D | test-net-connect-options-allowhalfopen.js | 36 console.log(`'connection' ${++serverConnections} emitted on server`); 42 `server connection ${srvConn} is started by client ${this.clientId}`); 49 server.close(); 50 console.log(`connection ${this.clientId} is closing the server: 51 FIN ${serverReceivedFIN} received by server, 54 FIN ${serverConnections} sent by server`.replace(/ {3,}/g, '')); 71 // after the server closes the connections, but not readable 92 FIN ${serverReceivedFIN} received by server 95 FIN ${serverConnections} sent by server`.replace(/ {3,}/g, '')); 99 const port = server [all...] |
H A D | test-http-keep-alive-drop-requests.js | 14 const server = http.createServer(common.mustCall((req, res) => { 18 server.on('dropRequest', common.mustCall((request, socket) => { 21 server.close(); 24 server.listen(0, common.mustCall(() => { 25 const socket = net.connect(server.address().port); 34 server.maxRequestsPerSocket = 1;
|
H A D | test-http-nodelay.js | 15 const server = http.createServer(common.mustCall((req, res) => { 18 server.close(); 21 server.listen(0, common.mustCall(() => { 22 assert.strictEqual(server.noDelay, true); 26 port: server.address().port 29 server.close();
|
/third_party/typescript/tests/baselines/reference/ |
H A D | exportEqualMemberMissing.js | 4 module server { 12 var server: { 13 (): server.connectExport; 16 export = server; 26 var server;
variable 27 module.exports = server;
|
H A D | exportAssignValueAndType.js | 6 interface server { 12 var server = new Date(); 13 export = server; 20 var server = new Date();
21 module.exports = server;
|
/third_party/ltp/testcases/realtime/func/async_handler/ |
H A D | async_handler_jk.c | 24 * An async event server thread is created that goes to sleep waiting 103 // Reset Priority to original async server priority in async_event_server() 113 struct thread *server = (struct thread *)thread->arg; in user_thread() local 117 /* Change the async server thread priority to be the priority in user_thread() 119 set_thread_priority(server->pthread, thread->priority); in user_thread() 121 /* Clear the THREAD_FLAG_SUSPENDED flag of the server before signal */ in user_thread() 122 server->flags &= ~THREAD_FLAG_SUSPENDED; in user_thread() 124 /* Signal the async server thread - simulates firing of an event */ in user_thread() 125 pthread_cond_broadcast(&server->cond); in user_thread() 138 int aes_id; // asynchronous event server i in main() 141 struct thread *server; main() local [all...] |
/third_party/ltp/testcases/network/stress/ns-tools/ |
H A D | ns-tcpserver.c | 26 * This is TCP traffic server. 68 * This structure stores the information of a server 74 int concurrent; /* if non-zero, act as a concurrent server */ 108 "\t-c\twork in the concurrent server mode\n" in usage() 111 "\t-o\tfilename where the server infomation is outputted\n" in usage() 161 * info_p: pointer to a server infomation 198 * info_p: pointer to a server infomation 217 /* Translate the network and service information of the server */ in create_listen_socket() 285 * info_p: pointer to a server infomation 374 * info_p: pointer to a server infomatio 534 struct server_info server; /* server information */ main() local [all...] |
/third_party/python/Lib/test/ |
H A D | test_asyncore.py | 344 # wait a little longer for the server to initialize (it sometimes 471 """A server which listens on an address and dispatches the 528 server = BaseServer(self.family, self.addr) 529 client = TestClient(self.family, server.address) 547 server = TestListener(self.family, self.addr) 548 client = BaseClient(self.family, server.address) 549 self.loop_waiting_for_flag(server) 570 server = TestListener(self.family, self.addr) 571 client = BaseClient(self.family, server.address) 572 self.loop_waiting_for_flag(server) [all...] |
/third_party/curl/lib/ |
H A D | ldap.c | 221 static int ldap_win_bind_auth(LDAP *server, const char *user, in ldap_win_bind_auth() argument 255 rc = ldap_bind_s(server, NULL, (TCHAR *)&cred, method); in ldap_win_bind_auth() 262 rc = ldap_bind_s(server, NULL, NULL, method); in ldap_win_bind_auth() 268 static int ldap_win_bind(struct Curl_easy *data, LDAP *server, in ldap_win_bind() argument 280 rc = ldap_simple_bind_s(server, inuser, inpass); in ldap_win_bind() 287 rc = ldap_win_bind_auth(server, user, passwd, data->set.httpauth); in ldap_win_bind() 306 LDAP *server = NULL; in ldap_do() local 374 server = ldap_sslinit(host, conn->port, 1); in ldap_do() 375 ldap_set_option(server, LDAP_OPT_SSL, LDAP_OPT_ON); in ldap_do() 420 server in ldap_do() [all...] |
/third_party/openssl/test/helpers/ |
H A D | handshake.c | 96 /* Select the appropriate server CTX. 202 * If the server understood the ClientHello extension but 203 * does not recognize the server name, the server SHOULD take one of two 388 * The client SHOULD select the first protocol advertised by the server that it 389 * also supports. In the event that the client doesn't support any of server's 390 * protocols, or the server doesn't advertise any, it SHOULD select the first 419 * The server SHOULD select the most highly preferred protocol that it supports 420 * and that is also advertised by the client. In the event that the server 421 * supports no protocols that the client advertises, then the server SHAL 700 configure_handshake_ssl(SSL *server, SSL *client, const SSL_TEST_EXTRA_CONF *extra) configure_handshake_ssl() argument 1399 PEER server, client; do_handshake_internal() local [all...] |