Home
last modified time | relevance | path

Searched refs:incoming (Results 1 - 25 of 44) sorted by relevance

12

/third_party/node/lib/
H A D_http_common.js36 const incoming = require('_http_incoming');
41 } = incoming;
93 const incoming = parser.incoming = new ParserIncomingMessage(socket);
94 incoming.httpVersionMajor = versionMajor;
95 incoming.httpVersionMinor = versionMinor;
96 incoming.httpVersion = `${versionMajor}.${versionMinor}`;
97 incoming.joinDuplicateHeaders = socket?.server?.joinDuplicateHeaders ||
99 incoming.url = url;
100 incoming
[all...]
H A D_http_server.js682 incoming: [],
763 const req = this.parser && this.parser.incoming;
776 abortIncoming(state.incoming);
779 function abortIncoming(incoming) {
780 while (incoming.length) {
781 const req = incoming.shift();
913 } else if (parser.incoming && parser.incoming.upgrade) {
915 const req = parser.incoming;
944 } else if (parser.incoming
[all...]
H A D_http_client.js551 } else if (parser.incoming && parser.incoming.upgrade) {
554 const res = parser.incoming;
589 } else if (parser.incoming && parser.incoming.complete &&
595 !statusIsInformational(parser.incoming.statusCode)) {
616 debug('AGENT incoming response!');
/third_party/node/test/parallel/
H A Dtest-tls-onread-static-buffer.js50 let incoming = new Uint8Array(0);
60 const newIncoming = new Uint8Array(incoming.length + nread);
61 newIncoming.set(incoming);
62 newIncoming.set(buf.slice(0, nread), incoming.length);
63 incoming = newIncoming;
68 assert.deepStrictEqual(incoming, new Uint8Array(smallMessage));
78 const incoming = [];
94 incoming.push(Buffer.from(buf.slice(0, nread)));
99 assert.deepStrictEqual(Buffer.concat(incoming), smallMessage);
110 let incoming
[all...]
/third_party/libuv/test/
H A Dtest-pipe-sendmsg.c38 static uv_pipe_t incoming[4]; variable
88 ASSERT_LT(incoming_count, ARRAY_SIZE(incoming)); in read_cb()
89 inc = &incoming[incoming_count++]; in read_cb()
94 if (incoming_count != ARRAY_SIZE(incoming)) in read_cb()
99 for (i = 0; i < ARRAY_SIZE(incoming); i++) in read_cb()
100 uv_close((uv_handle_t*) &incoming[i], close_cb); in read_cb()
111 int send_fds[ARRAY_SIZE(incoming)]; in TEST_IMPL()
157 ASSERT_EQ(ARRAY_SIZE(incoming), incoming_count); in TEST_IMPL()
158 ASSERT_EQ(ARRAY_SIZE(incoming) + 1, close_called); in TEST_IMPL()
H A Dtest-tcp-close-accept.c63 * Time to finish the test: close both the check and pending incoming in connect_cb()
119 uv_tcp_t* incoming; in connection_cb() local
128 incoming = &tcp_incoming[got_connections++]; in connection_cb()
129 ASSERT_OK(uv_tcp_init(server->loop, incoming)); in connection_cb()
130 ASSERT_OK(uv_accept(server, (uv_stream_t*) incoming)); in connection_cb()
137 incoming = &tcp_incoming[i]; in connection_cb()
138 ASSERT_OK(uv_read_start((uv_stream_t*) incoming, alloc_cb, read_cb)); in connection_cb()
160 * receive stale event of second incoming and invoke `connect_cb` with zero in TEST_IMPL()
H A Dtest-tcp-alloc-cb-fail.c31 static uv_tcp_t incoming; variable
59 uv_close((uv_handle_t*) &incoming, close_cb); in conn_read_cb()
80 ASSERT_OK(uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
81 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
82 ASSERT_OK(uv_read_start((uv_stream_t*) &incoming, in connection_cb()
H A Dtest-tcp-write-in-a-row.c31 static uv_tcp_t incoming; variable
55 uv_close((uv_handle_t*) &incoming, close_cb); in write_cb()
99 ASSERT_OK(uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
100 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
101 ASSERT_OK(uv_read_start((uv_stream_t*) &incoming, alloc_cb, read_cb)); in connection_cb()
H A Dtest-tcp-try-write-error.c31 static uv_tcp_t incoming; variable
65 ASSERT_OK(uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
66 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
69 uv_close((uv_handle_t*) &incoming, incoming_close_cb); in connection_cb()
H A Dtest-tcp-write-queue-order.c34 static uv_tcp_t incoming; variable
52 uv_close((uv_handle_t*) &incoming, close_cb); in timer_cb()
89 ASSERT_OK(uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
90 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
H A Dtest-tcp-try-write.c33 static uv_tcp_t incoming; variable
92 ASSERT_OK(uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
93 ASSERT_OK(uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
96 ASSERT_OK(uv_read_start((uv_stream_t*) &incoming, alloc_cb, read_cb)); in connection_cb()
/third_party/node/deps/v8/src/maglev/
H A Dmaglev-regalloc.cc773 MergePointRegisterState& target_state, ValueNode* incoming) { in EnsureInRegister()
780 if (node == incoming) found = true; in EnsureInRegister()
822 ValueNode* incoming = nullptr; in MergeRegisterValues() local
824 incoming = GetRegisterValue(reg); in MergeRegisterValues()
825 if (!IsLiveAtTarget(incoming, control, target)) { in MergeRegisterValues()
826 incoming = nullptr; in MergeRegisterValues()
830 if (incoming == node) { in MergeRegisterValues()
839 // where that node is allocated on the incoming branch. in MergeRegisterValues()
842 // If there's a value in the incoming state, that value is either in MergeRegisterValues()
844 if (incoming ! in MergeRegisterValues()
772 EnsureInRegister( MergePointRegisterState& target_state, ValueNode* incoming) EnsureInRegister() argument
[all...]
H A Dmaglev-regalloc.h91 ValueNode* incoming);
/third_party/curl/tests/libtest/
H A Dlib2302.c82 size_t incoming = nitems; in writecb() local
87 incoming = add_data(ws_data, buffer, incoming, meta); in writecb()
89 if(nitems != incoming) in writecb()
H A Dlib2301.c103 size_t incoming = nitems; in writecb() local
117 if(nitems != incoming) in writecb()
/third_party/python/Lib/
H A Dasynchat.py81 self.incoming = []
92 self.incoming.append(data)
95 d = b''.join(self.incoming)
96 del self.incoming[:]
274 del self.incoming[:]
H A Dssl.py527 def wrap_bio(self, incoming, outgoing, server_side=False,
532 incoming, outgoing, server_side=server_side,
867 def _create(cls, incoming, outgoing, server_side=False,
871 incoming, outgoing, server_side=server_side,
/third_party/skia/third_party/externals/angle2/src/libANGLE/renderer/
H A Drenderer_utils.cpp235 const gl::Rectangle &incoming, in RotateRectangle()
243 outgoing->x = incoming.x; in RotateRectangle()
244 outgoing->y = flipY ? framebufferHeight - incoming.y - incoming.height : incoming.y; in RotateRectangle()
245 outgoing->width = incoming.width; in RotateRectangle()
246 outgoing->height = incoming.height; in RotateRectangle()
250 outgoing->x = incoming.y; in RotateRectangle()
251 outgoing->y = flipY ? incoming.x : framebufferWidth - incoming in RotateRectangle()
231 RotateRectangle(const SurfaceRotation rotation, const bool flipY, const int framebufferWidth, const int framebufferHeight, const gl::Rectangle &incoming, gl::Rectangle *outgoing) RotateRectangle() argument
[all...]
/third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/Transforms/Scalar/
H A DLoopDeletion.cpp55 Value *incoming = P.getIncomingValueForBlock(ExitingBlocks[0]); in isLoopDead() local
57 // Make sure all exiting blocks produce the same incoming value for the exit in isLoopDead()
58 // block. If there are different incoming values for different exiting in isLoopDead()
63 return incoming == P.getIncomingValueForBlock(BB); in isLoopDead()
69 if (Instruction *I = dyn_cast<Instruction>(incoming)) in isLoopDead()
162 // Set incoming value to undef for phi nodes in the exit block. in deleteLoopIfDead()
/third_party/mesa3d/src/intel/compiler/
H A Dbrw_clip_util.c415 struct brw_reg incoming = get_element_ud(c->reg.R0, 2); in brw_clip_init_clipmask() local
419 brw_SHR(p, c->reg.planemask, incoming, brw_imm_ud(26)); in brw_clip_init_clipmask()
428 brw_AND(p, tmp, incoming, brw_imm_ud(0xff<<14)); in brw_clip_init_clipmask()
430 brw_AND(p, tmp, incoming, brw_imm_ud(0x3f<<14)); in brw_clip_init_clipmask()
/third_party/libcoap/examples/
H A Dcoap-server.c641 coap_session_t *incoming; /* Incoming session */ member
785 if (proxy_list[i].incoming == session) { in get_proxy_session()
798 proxy_list[i].incoming = session; in get_proxy_session()
832 if (proxy_list[i].incoming == session) { in remove_proxy_association()
844 coap_new_message_id(proxy_list[i].incoming), in remove_proxy_association()
845 coap_session_max_pdu_size(proxy_list[i].incoming)); in remove_proxy_association()
854 coap_log_debug("Cannot add token to incoming proxy response PDU\n"); in remove_proxy_association()
857 if (coap_send(proxy_list[i].incoming, response) == in remove_proxy_association()
1602 coap_session_t *incoming = NULL; in proxy_response_handler() local
1622 incoming in proxy_response_handler()
[all...]
/third_party/musl/src/thread/sh/
H A Dclone.s6 ! incoming: fn stack flags arg ptid tls ctid
/third_party/python/Lib/test/test_asyncio/
H A Dtest_ssl.py1101 incoming = ssl.MemoryBIO()
1103 sslobj = client_sslctx_2.wrap_bio(incoming, outgoing)
1113 incoming.write(sock.recv(65536))
1319 incoming = ssl.MemoryBIO()
1321 sslobj = sslctx.wrap_bio(incoming, outgoing, server_side=True)
1329 incoming.write(sock.recv(16384))
1339 incoming.write(sock.recv(16384))
1361 incoming.write(sock.recv(16384))
1555 # pause reading would make incoming data stay in the sslobj
/third_party/mesa3d/src/microsoft/compiler/
H A Ddxil_internal.h166 } *incoming; member
/third_party/node/deps/v8/src/compiler/
H A Dlinkage.h489 // for incoming parameters and return value(s) as well as the outgoing calling
504 explicit Linkage(CallDescriptor* incoming) : incoming_(incoming) {} in Linkage() argument
512 // of incoming parameters and the outgoing return value(s).
546 // Get the location of an (incoming) parameter to this function.
551 // Get the machine type of an (incoming) parameter to this function.
571 // Get the location where an incoming OSR value is stored.

Completed in 19 milliseconds

12