Home
last modified time | relevance | path

Searched refs:recv (Results 1 – 25 of 346) sorted by relevance

12345678910>>...14

/third_party/node/src/api/
Dcallback.cc158 Local<Object> recv, in InternalMakeCallback() argument
163 CHECK(!recv.IsEmpty()); in InternalMakeCallback()
198 ret = hook_cb->Call(env->context(), recv, args.length(), &args[0]); in InternalMakeCallback()
200 ret = callback->Call(env->context(), recv, argc, argv); in InternalMakeCallback()
219 Local<Object> recv, in MakeCallback() argument
226 return MakeCallback(isolate, recv, method_string, argc, argv, asyncContext); in MakeCallback()
230 Local<Object> recv, in MakeCallback() argument
236 Environment* env = Environment::GetCurrent(recv->CreationContext()); in MakeCallback()
241 if (!recv->Get(isolate->GetCurrentContext(), symbol).ToLocal(&callback_v)) in MakeCallback()
249 return MakeCallback(isolate, recv, callback, argc, argv, asyncContext); in MakeCallback()
[all …]
/third_party/flutter/skia/third_party/externals/wuffs/internal/cgen/
Dbuiltin.go37 recv := method.LHS().AsExpr()
38 recvTyp := recv.MType()
77 return g.writeBuiltinSlice(b, recv, method.Ident(), n.Args(), depth)
79 return g.writeBuiltinTable(b, recv, method.Ident(), n.Args(), depth)
90 return g.writeBuiltinNumType(b, recv, method.Ident(), n.Args(), depth)
94 return g.writeBuiltinIOReader(b, recv, method.Ident(), n.Args(), depth)
96 return g.writeBuiltinIOWriter(b, recv, method.Ident(), n.Args(), depth)
102 func (g *gen) writeBuiltinIO(b *buffer, recv *a.Expr, method t.ID, args []*a.Node, depth uint32) er…
107 switch recv.Str(g.tm) {
127 func (g *gen) writeBuiltinIOReader(b *buffer, recv *a.Expr, method t.ID, args []*a.Node, depth uint…
[all …]
Dexpr.go99 recv := method.LHS().AsExpr()
100 recvTyp, addr := recv.MType(), "&"
106 n.Str(g.tm), recv.MType().Str(g.tm))
116 if err := g.writeExpr(b, recv, depth); err != nil {
124 if err := g.writeExpr(b, recv, depth); err != nil {
320 recv := method.LHS().AsExpr()
321 recvTyp, addr := recv.MType(), "&"
329 n.Str(g.tm), recv.MType().Str(g.tm))
335 if err := g.writeExpr(b, recv, depth); err != nil {
/third_party/libuv/test/
Dtest-ipc-send-recv.c51 union handles recv; member
61 union handles recv; member
92 union handles* recv; in recv_cb() local
99 recv = &ctx.recv; in recv_cb()
101 recv = &ctx.recv2; in recv_cb()
120 r = uv_pipe_init(ctx.channel.loop, &recv->pipe, 0); in recv_cb()
122 r = uv_tcp_init(ctx.channel.loop, &recv->tcp); in recv_cb()
127 r = uv_accept(handle, &recv->stream); in recv_cb()
290 uv_close(&ctx2.recv.handle, NULL); in write2_cb()
304 union handles* recv; in read_cb() local
[all …]
Dtest-poll-oob.c78 n = recv(client_fd, &buffer, 5, MSG_OOB); in poll_cb()
90 n = recv(client_fd, &buffer, 5, 0); in poll_cb()
104 n = recv(server_fd, &buffer, 5, 0); in poll_cb()
118 n = recv(server_fd, &buffer, 3, 0); in poll_cb()
/third_party/node/test/pummel/
Dtest-net-pause.js28 let recv = ''; variable
50 recv += d;
54 chars_recved = recv.length;
60 assert.strictEqual(chars_recved, recv.length);
64 chars_recved = recv.length;
70 assert.strictEqual(chars_recved, recv.length);
89 assert.strictEqual(recv.length, N);
/third_party/rust/crates/signal-hook/src/low_level/
Dchannel.rs146 pub fn recv(&self) -> Option<T> { in recv() method
179 assert!(channel.recv().is_none()); in new_empty()
180 assert!(channel.recv().is_none()); in new_empty()
187 assert_eq!(42, channel.recv().unwrap()); in pass_value()
188 assert!(channel.recv().is_none()); in pass_value()
196 assert_eq!(i, channel.recv().unwrap()); in multiple()
197 assert!(channel.recv().is_none()); in multiple()
208 assert_eq!(i, channel.recv().unwrap()); in overflow()
210 assert!(channel.recv().is_none()); in overflow()
228 results.extend(channel.recv()); in multi_thread()
/third_party/pulseaudio/src/modules/gsettings/
Dpulseaudio.convert93 [org.freedesktop.pulseaudio.module-group:/org/freedesktop/pulseaudio/module-groups/rtp-recv/]
94 args0 = /system/pulseaudio/modules/rtp-recv/args0
95 args1 = /system/pulseaudio/modules/rtp-recv/args1
96 args2 = /system/pulseaudio/modules/rtp-recv/args2
97 args3 = /system/pulseaudio/modules/rtp-recv/args3
98 args4 = /system/pulseaudio/modules/rtp-recv/args4
99 args5 = /system/pulseaudio/modules/rtp-recv/args5
100 args6 = /system/pulseaudio/modules/rtp-recv/args6
101 args7 = /system/pulseaudio/modules/rtp-recv/args7
102 args8 = /system/pulseaudio/modules/rtp-recv/args8
[all …]
/third_party/nghttp2/
DREADME.rst552 [ 0.212] recv SETTINGS frame <length=12, flags=0x00, stream_id=0>
584 [ 0.221] recv SETTINGS frame <length=0, flags=0x01, stream_id=0>
587 [ 0.221] recv (stream_id=13) :method: GET
588 [ 0.221] recv (stream_id=13) :scheme: https
589 [ 0.221] recv (stream_id=13) :path: /stylesheets/screen.css
590 [ 0.221] recv (stream_id=13) :authority: nghttp2.org
591 [ 0.221] recv (stream_id=13) accept-encoding: gzip, deflate
592 [ 0.222] recv (stream_id=13) user-agent: nghttp2/1.0.1-DEV
593 [ 0.222] recv PUSH_PROMISE frame <length=50, flags=0x04, stream_id=13>
596 [ 0.222] recv (stream_id=13) :status: 200
[all …]
/third_party/protobuf/ruby/src/main/java/com/google/protobuf/jruby/
DRubyEnum.java51 public static IRubyObject lookup(ThreadContext context, IRubyObject recv, IRubyObject number) { in lookup() argument
52 …RubyEnumDescriptor rubyEnumDescriptorescriptor = (RubyEnumDescriptor) getDescriptor(context, recv); in lookup()
67 public static IRubyObject resolve(ThreadContext context, IRubyObject recv, IRubyObject name) { in resolve() argument
68 …RubyEnumDescriptor rubyEnumDescriptorescriptor = (RubyEnumDescriptor) getDescriptor(context, recv); in resolve()
83 public static IRubyObject getDescriptor(ThreadContext context, IRubyObject recv) { in getDescriptor() argument
84 return ((RubyModule) recv).getInstanceVariable(Utils.DESCRIPTOR_INSTANCE_VAR); in getDescriptor()
/third_party/lwip/test/unit/ip4/
Dtest_ip4.c87 fail_unless(lwip_stats.ip_frag.recv == 1); in START_TEST()
94 fail_unless(lwip_stats.ip_frag.recv == 2); in START_TEST()
101 fail_unless(lwip_stats.ip_frag.recv == 3); in START_TEST()
108 fail_unless(lwip_stats.ip_frag.recv == 4); in START_TEST()
115 fail_unless(lwip_stats.ip_frag.recv == 5); in START_TEST()
122 fail_unless(lwip_stats.ip_frag.recv == 6); in START_TEST()
129 fail_unless(lwip_stats.ip_frag.recv == 7); in START_TEST()
136 fail_unless(lwip_stats.ip_frag.recv == 8); in START_TEST()
143 fail_unless(lwip_stats.ip_frag.recv == 9); in START_TEST()
/third_party/node/test/addons/make-callback/
Dtest.js22 const recv = { variable
25 assert.strictEqual(recv, this);
30 assert.strictEqual(recv, this);
36 assert.strictEqual(makeCallback(recv, 'one'), 42);
37 assert.strictEqual(makeCallback(recv, 'two', 1337), 42);
Dbinding.cc13 auto recv = args[0].As<v8::Object>(); in MakeCallback() local
22 node::MakeCallback(isolate, recv, method, argv.size(), argv.data(), in MakeCallback()
27 node::MakeCallback(isolate, recv, method, argv.size(), argv.data(), in MakeCallback()
/third_party/toybox/porting/liteos_a/toys/net/
Dping.c49 unsigned long sent, recv, fugit, min, max; argument
56 lostret = TT.sent > TT.recv ? ((TT.sent-TT.recv)*100)/(TT.sent?TT.sent:1) : 0;
60 TT.sent, TT.recv, lostret);
62 TT.min, TT.max, TT.fugit/(TT.recv?TT.recv:1));
202 if (0>=(waitms = tW-tnow) || !(TT.sent-TT.recv)) break; in ping_main()
241 TT.recv++; in ping_main()
/third_party/ltp/utils/sctp/func_tests/
Dtest_1_to_1_shutdown.c150 error = recv(acpt_sk[0], msgbuf, 100, 0); in main()
161 error = recv(clnt_sk[0], msgbuf, 100, 0); in main()
173 error = recv(clnt_sk[1], msgbuf, 100, 0); in main()
191 error = recv(clnt_sk[1], msgbuf, 100, 0); in main()
202 error = recv(acpt_sk[2], msgbuf, 100, 0); in main()
207 error = recv(clnt_sk[2], msgbuf, 100, 0); in main()
Dtest_tcp_style.c239 error = recv(listen_sk, msgbuf, 100, 0); in main()
259 error = recv(accept_sk[0], msgbuf, 100, 0); in main()
290 error = recv(clt_sk[0], msgbuf, 100, 0); in main()
302 error = recv(clt_sk[1], msgbuf, 100, 0); in main()
317 error = recv(clt_sk[1], msgbuf, 100, 0); in main()
327 error = recv(accept_sk[2], msgbuf, 100, 0); in main()
332 error = recv(clt_sk[2], msgbuf, 100, 0); in main()
375 error = recv(accept2_sk, msgbuf, 100, 0); in main()
/third_party/node/test/node-api/test_worker_terminate/
Dtest_worker_terminate.c8 napi_value recv; in Test() local
12 NAPI_CALL(env, napi_get_cb_info(env, info, &argc, argv, &recv, NULL)); in Test()
20 status = napi_call_function(env, recv, argv[0], 0, NULL, NULL); in Test()
22 status = napi_call_function(env, recv, argv[0], 0, NULL, NULL); in Test()
/third_party/node/test/parallel/
Dtest-net-binary.js48 let recv = ''; variable
66 recv += chunk;
79 assert.strictEqual(recv.length, 2 * 256);
81 const a = recv.split('');
Dtest-event-emitter-get-max-listeners.js17 const recv = {}; constant
18 EventEmitter.prototype.on.call(recv, 'event', () => {}); argument
19 EventEmitter.prototype.on.call(recv, 'event', () => {}); argument
Dtest-tls-socket-default-options.js46 let recv = '';
48 conn.on('data', (data) => recv += data);
52 assert.strictEqual(recv, 'hello');
/third_party/toybox/toys/net/
Dping.c55 unsigned long sent, recv, fugit, min, max; argument
64 TT.sent, TT.recv, ((TT.sent-TT.recv)*100)/(TT.sent?TT.sent:1));
66 TT.min, TT.max, TT.fugit/(TT.recv?TT.recv:1));
199 if (0>=(waitms = tW-tnow) || !(TT.sent-TT.recv)) break; in ping_main()
239 TT.recv++; in ping_main()
/third_party/node/test/node-api/test_make_callback_recurse/
Dbinding.c10 napi_value recv = args[0]; in MakeCallback() local
14 recv, func, 0 /* argc */, NULL /* argv */, NULL /* result */); in MakeCallback()
29 return recv; in MakeCallback()
/third_party/node/test/node-api/test_async_context/
Dtest.js42 const recv = {}; constant
43 makeCallback(resourceWrap, recv, function callback() {
49 assert.strictEqual(this, recv);
/third_party/python/Modules/
D_xxsubinterpretersmodule.c547 _channelend *recv; member
560 ends->recv = NULL; in _channelends_new()
571 _channelend_free_all(ends->recv); in _channelends_clear()
572 ends->recv = NULL; in _channelends_clear()
597 ends->recv = end; in _channelends_add()
616 _channelend *end = _channelend_find(send ? ends->send : ends->recv, in _channelends_associate()
638 if (ends->send == NULL && ends->recv == NULL) { in _channelends_is_open()
673 end = _channelend_find(ends->recv, interp, &prev); in _channelends_close_interpreter()
699 for (end = ends->recv; end != NULL; end = end->next) { in _channelends_close_all()
1363 _channel_drop(_channels *channels, int64_t id, int send, int recv) in _channel_drop() argument
[all …]
/third_party/node/src/
Dnode.h179 v8::Local<v8::Object> recv,
186 v8::Local<v8::Object> recv,
193 v8::Local<v8::Object> recv,
629 inline void NODE_SET_METHOD(v8::Local<v8::Template> recv,
639 recv->Set(fn_name, t);
643 inline void NODE_SET_METHOD(v8::Local<v8::Object> recv, in NODE_SET_METHOD() argument
655 recv->Set(context, fn_name, fn).Check(); in NODE_SET_METHOD()
661 inline void NODE_SET_PROTOTYPE_METHOD(v8::Local<v8::FunctionTemplate> recv, in NODE_SET_PROTOTYPE_METHOD() argument
666 v8::Local<v8::Signature> s = v8::Signature::New(isolate, recv); in NODE_SET_PROTOTYPE_METHOD()
672 recv->PrototypeTemplate()->Set(fn_name, t); in NODE_SET_PROTOTYPE_METHOD()
[all …]

12345678910>>...14