Home
last modified time | relevance | path

Searched refs:send (Results 1 - 25 of 470) sorted by relevance

12345678910>>...19

/third_party/node/test/parallel/
H A Dtest-repl.js50 for (const { send, expect } of tests) {
54 console.error('out:', JSON.stringify(send));
55 socket.write(`${send}\n`);
60 expectedLine = send;
104 send: '',
108 send: 'message',
112 send: 'invoke_me(987)',
116 send: 'a = 12345',
120 send: '{a:1}',
127 send
[all...]
H A Dtest-dgram-send-bad-arguments.js34 () => { sock.send(); },
43 // send(buf, offset, length, port, host)
46 () => { sock.send(buf, 1, 1, -1, host); },
55 () => { sock.send(buf, 1, 1, 0, host); },
64 () => { sock.send(buf, 1, 1, 65536, host); },
73 () => { sock.send(buf, 1234, '127.0.0.1', common.mustNotCall()); },
95 () => { sock.send(input, 6, 0); },
104 () => { sock.send(input, 0, 6); },
113 () => { sock.send(input, 3, 4); },
122 assert.throws(() => { sock.send(bu
[all...]
H A Dtest-cluster-bind-twice.js56 b.send('QUIT');
63 a.send('QUIT');
71 b.send({ msg: 'START', port: m.port });
76 a.send('QUIT');
77 b.send('QUIT');
85 process.send({ msg: 'READY', port: server.address().port });
101 process.send(e.code);
111 worker.on('message', process.send.bind(process));
112 process.on('message', worker.send.bind(worker));
H A Dtest-inspector.js78 await session.send(commands);
92 await session.send(commands);
93 const { scriptSource } = await session.send({
105 const response = await session.send({
116 let { result } = await session.send({
134 result = (await session.send({
150 session.send({
173 let result = await session.send(
184 result = await session.send(
198 result = await session.send(
[all...]
H A Dtest-child-process-fork-net.js100 child1.send('end', socket); break;
102 child1.send('write', socket); break;
104 child2.send('end', socket); break;
106 child2.send('write', socket); break;
108 child3.send('end', socket); break;
110 child3.send('write', socket); break;
161 child1.send('close');
162 child2.send('close');
H A Dtest-child-process-send-returns-boolean.js4 // subprocess.send() will return false if the channel has closed or when the
5 // backlog of unsent messages exceeds a threshold that makes it unwise to send
17 // Test `send` return value on `fork` that opens and IPC by default.
19 // `subprocess.send` should always return `true` for the first send.
20 const rv = n.send({ h: 'w' }, assert.ifError);
26 // Test `send` return value on `spawn` and saturate backlog with handles.
36 const rv1 = s.send('one', handle, (err) => { if (err) assert.fail(err); });
38 // Since the first `send` included a handle (should be unacknowledged),
40 const rv2 = s.send('tw
[all...]
H A Dtest-inspector-open.js26 child.send({ cmd: 'open', args: [kFirstOpen] });
37 child.send({ cmd: 'open', args: [kOpenWhileOpen] });
49 child.send({ cmd: 'close' });
59 child.send({ cmd: 'close' });
67 child.send({ cmd: 'open', args: [kReOpen] });
93 process.send({ cmd: 'started' });
112 process.send({ cmd: 'url', url: inspector.url() });
H A Dtest-child-process-fork-net-server.js49 process.send({ what: 'connection' });
55 process.send({ what: 'listening' });
68 process.send({ what: 'close' });
75 process.send({ what: 'ready' });
92 child.send({ what: 'close' });
101 // Create server and send it to child.
116 child.send({ what: 'server' }, server);
157 // Create server and send it to child.
H A Dtest-inspector-esm.js39 await session.send(commands);
54 await session.send(commands);
55 const { scriptSource } = await session.send({
67 const response = await session.send({
78 let { result } = await session.send({
92 result = (await session.send({
H A Dtest-child-process-fork-dgram.js45 process.send('gotMessage');
49 process.send('handleReceived');
68 child.send('server', parentServer);
89 client.send(
H A Dtest-domain-uncaught-exception.js55 process.send('errorHandledByDomain');
82 process.send('errorHandledByDomain');
107 process.send('errorHandledByDomain');
130 process.send('errorHandledByDomain');
150 process.send('uncaughtException');
/third_party/node/test/async-hooks/
H A Dtest-udpsendwrap.js1 // Flags: --test-udp-no-try-send
13 let send;
21 sock.send(
28 // create the send wrap synchronously.
34 send = as[0];
37 assert.strictEqual(send.type, 'UDPSENDWRAP');
38 assert.strictEqual(typeof send.uid, 'number');
39 assert.strictEqual(typeof send.triggerAsyncId, 'number');
40 checkInvocations(send, { init: 1, before: 1 }, 'when message sent');
46 checkInvocations(send, { ini
[all...]
/third_party/python/Lib/multiprocessing/
H A Dresource_sharer.py31 def send(conn, pid): function
34 self._id = _resource_sharer.register(send, new_sock.close)
49 def send(conn, pid): function
53 self._id = _resource_sharer.register(send, close)
72 def register(self, send, close):
78 self._cache[self._key] = (send, close)
87 c.send((key, os.getpid()))
97 c.send(None)
107 for key, (send, close) in self._cache.items():
112 for key, (send, clos
[all...]
/third_party/node/lib/internal/cluster/
H A Dchild.js54 send({ act: 'online' });
103 send(message, (reply, handle) => {
125 send(message);
149 send({ act: 'close', key });
201 send({ act: 'close', key });
240 send({ ack: message.seq, accepted });
248 function send(message, cb) { function
262 // it's primary initiated there's no need to send the
267 send({ act: 'exitedAfterDisconnect' }, () => process.disconnect());
304 send({ ac
[all...]
/third_party/node/benchmark/child_process/
H A Dchild-process-read-ipc.js5 const send = () => {
6 while (process.send(msg));
8 setImmediate(send);
10 send();
/third_party/skia/third_party/externals/oboe/apps/OboeTester/app/src/main/java/com/mobileer/miditools/
H A DMidiFramer.java68 mReceiver.send(data, sysExStartOffset, in onSend()
82 mReceiver.send(data, sysExStartOffset, in onSend()
86 mReceiver.send(data, offset, 1, timestamp); in onSend()
95 mReceiver.send(mBuffer, 0, mCount, timestamp); in onSend()
104 // send any accumulatedSysEx data in onSend()
106 mReceiver.send(data, sysExStartOffset, in onSend()
/third_party/mesa3d/src/intel/compiler/
H A Dbrw_vec4_generator.cpp319 /* dst = send(offset, a0.0 | <descriptor>) */ in generate_tex()
767 brw_inst *send = brw_next_insn(p, BRW_OPCODE_SEND); in generate_tcs_urb_write() local
768 brw_set_dest(p, send, brw_null_reg()); in generate_tcs_urb_write()
769 brw_set_src0(p, send, urb_header); in generate_tcs_urb_write()
770 brw_set_desc(p, send, brw_message_desc(devinfo, inst->mlen, 0, true)); in generate_tcs_urb_write()
772 brw_inst_set_sfid(devinfo, send, BRW_SFID_URB); in generate_tcs_urb_write()
773 brw_inst_set_urb_opcode(devinfo, send, BRW_URB_OPCODE_WRITE_OWORD); in generate_tcs_urb_write()
774 brw_inst_set_urb_global_offset(devinfo, send, inst->offset); in generate_tcs_urb_write()
776 brw_inst_set_eot(devinfo, send, 1); in generate_tcs_urb_write()
778 brw_inst_set_urb_per_slot_offset(devinfo, send, in generate_tcs_urb_write()
954 brw_inst *send = brw_next_insn(p, BRW_OPCODE_SEND); generate_vec4_urb_read() local
991 brw_inst *send = brw_next_insn(p, BRW_OPCODE_SEND); generate_tcs_release_input() local
1169 brw_inst *send = brw_next_insn(p, BRW_OPCODE_SEND); generate_scratch_read() local
1245 brw_inst *send = brw_next_insn(p, BRW_OPCODE_SEND); generate_scratch_write() local
1307 brw_inst *send = brw_next_insn(p, BRW_OPCODE_SEND); generate_pull_constant_load() local
[all...]
/third_party/python/Lib/test/
H A Dtest__xxsubinterpreters.py163 if self.end not in ('same', 'opposite', 'send', 'recv'):
166 if self.end not in ('both', 'same', 'opposite', 'send', 'recv'):
177 return 'recv' if end == 'send' else 'send'
244 if end == 'send':
262 if end in ('recv', 'send'):
270 if end in ('recv', 'send'):
1083 cid = interpreters._channel_id(10, send=True, force=True)
1084 self.assertEqual(cid.end, 'send')
1086 cid = interpreters._channel_id(10, send
[all...]
H A Dtest_coroutines.py45 buffer.append(coro.send(None))
63 buffer.append(aw.send(None))
489 bar().send(None)
625 self.assertEqual(f.send(None), 1)
626 self.assertEqual(f.send(None), 2)
628 f.send(None)
702 self.assertEqual(aw.send(10), 100)
727 i = me.send(None)
732 me.send(None)
741 "can't send no
784 async def send(): global() function
[all...]
/third_party/ltp/testcases/kernel/syscalls/mq_timedreceive/
H A Dmq_timedreceive01.c26 .send = 1,
33 .send = 1,
40 .send = 1,
47 .send = 1,
56 .send = 1,
168 if (tc->send) { in do_test()
/third_party/libwebsockets/test-apps/android/app/src/main/java/org/libwebsockets/client/
H A DMainActivity.java84 mService.send(msg); in onCreate()
90 mService.send(msg); in onCreate()
129 mService.send(Message.obtain(null, LwsService.MSG_THREAD_SUSPEND, 0, 0)); in onStop()
189 mService.send(msg); in connectErrorListener()
226 mService.send(msg); in clickStart()
228 mService.send(msg); in clickStart()
236 mService.send(Message.obtain(null, LwsService.MSG_THREAD_STOP, 0, 0)); in clickStart()
/third_party/libwebsockets/minimal-examples/api-tests/api-test-secure-streams/
H A Dmain.c125 size_t send; member
163 return 1; /* nothing to send */ in myss_tx_get()
171 size_t budget = (next_test->send - m->sent); in myss_tx_post()
185 if (m->sent != next_test->send) in myss_tx_post()
208 if (next_test->send) in myss_state()
209 return lws_ss_request_tx_len(m->ss, (unsigned long)next_test->send); in myss_state()
228 if (!m->seen_eom || m->payload < 200 + next_test->send) { in myss_state()
296 { .ssi = &ssi_post, .send = 4096 },
/third_party/ltp/utils/sctp/func_tests/
H A Dtest_1_to_1_send.c5 * This file has test cases to test the send() call for 1-1 style sockets
12 * TEST6: send from client to server
13 * TEST7: send from server to client
33 * Please send any bug reports or fixes you make to the
118 /*send () TEST1: Bad socket descriptor, EBADF Expected error*/ in main()
119 count = send(-1, message, len_snd, flag); in main()
121 tst_brkm(TBROK, tst_exit, "send with a bad socket " in main()
124 tst_resm(TPASS, "send() with a bad socket descriptor - EBADF"); in main()
126 /*send () TEST2: Invalid socket, ENOTSOCK Expected error*/ in main()
132 count = send(f in main()
[all...]
/third_party/python/Modules/
H A D_xxsubinterpretersmodule.c550 _channelend *send; member
563 ends->send = NULL; in _channelends_new()
571 _channelend_free_all(ends->send); in _channelends_clear()
572 ends->send = NULL; in _channelends_clear()
589 int send) in _channelends_add()
597 if (send) { in _channelends_add()
598 ends->send = end; in _channelends_add()
607 if (send) { in _channelends_add()
617 _channelends_associate(_channelends *ends, int64_t interp, int send) in _channelends_associate() argument
620 _channelend *end = _channelend_find(send in _channelends_associate()
588 _channelends_add(_channelends *ends, _channelend *prev, int64_t interp, int send) _channelends_add() argument
649 _channelends_close_end(_channelends *ends, _channelend *end, int send) _channelends_close_end() argument
1367 _channel_drop(_channels *channels, int64_t id, int send, int recv) _channel_drop() argument
1395 _channel_is_associated(_channels *channels, int64_t cid, int64_t interp, int send) _channel_is_associated() argument
1485 int send = -1; channelid_new() local
2343 int send = 0; /* Send or receive end? */ channel_list_interpreters() local
2462 int send = 0; channel_close() local
2510 int send = 0; channel_release() local
[all...]
/third_party/ffmpeg/libavcodec/
H A Dutvideoenc.c391 int i, sstart, send = 0; in encode_plane() local
399 sstart = send; in encode_plane()
400 send = height * (i + 1) / c->slices & cmask; in encode_plane()
403 width, send - sstart); in encode_plane()
408 sstart = send; in encode_plane()
409 send = height * (i + 1) / c->slices & cmask; in encode_plane()
410 c->llvidencdsp.sub_left_predict(dst + sstart * width, src + sstart * stride, stride, width, send - sstart); in encode_plane()
415 sstart = send; in encode_plane()
416 send = height * (i + 1) / c->slices & cmask; in encode_plane()
418 stride, width, send in encode_plane()
[all...]

Completed in 14 milliseconds

12345678910>>...19