| /dports/devel/grpc/grpc-1.42.0/test/core/util/ |
| H A D | mock_endpoint.cc | 38 grpc_closure* on_read; member
50 m->on_read = cb; in me_read()
77 if (m->on_read) { in me_shutdown()
78 grpc_core::ExecCtx::Run(DEBUG_LOCATION, m->on_read, in me_shutdown()
81 m->on_read = nullptr; in me_shutdown()
127 m->on_read = nullptr; in grpc_mock_endpoint_create()
134 if (m->on_read != nullptr) { in grpc_mock_endpoint_put_read()
136 grpc_core::ExecCtx::Run(DEBUG_LOCATION, m->on_read, GRPC_ERROR_NONE); in grpc_mock_endpoint_put_read()
137 m->on_read = nullptr; in grpc_mock_endpoint_put_read()
|
| H A D | passthru_endpoint.cc | 42 grpc_closure* on_read; member
67 m->on_read = cb; in me_read()
86 } else if (m->on_read != nullptr) { in me_write()
91 m->on_read = nullptr; in me_write()
115 if (m->on_read) { in me_shutdown()
117 DEBUG_LOCATION, m->on_read, in me_shutdown()
119 m->on_read = nullptr; in me_shutdown()
122 if (m->on_read) { in me_shutdown()
124 DEBUG_LOCATION, m->on_read, in me_shutdown()
126 m->on_read = nullptr; in me_shutdown()
[all …]
|
| /dports/devel/grpc130/grpc-1.30.2/test/core/util/ |
| H A D | passthru_endpoint.cc | 43 grpc_closure* on_read; member
68 m->on_read = cb; in me_read()
87 } else if (m->on_read != nullptr) { in me_write()
92 m->on_read = nullptr; in me_write()
116 if (m->on_read) { in me_shutdown()
118 DEBUG_LOCATION, m->on_read, in me_shutdown()
120 m->on_read = nullptr; in me_shutdown()
123 if (m->on_read) { in me_shutdown()
125 DEBUG_LOCATION, m->on_read, in me_shutdown()
127 m->on_read = nullptr; in me_shutdown()
[all …]
|
| H A D | mock_endpoint.cc | 39 grpc_closure* on_read; member
51 m->on_read = cb; in me_read()
78 if (m->on_read) { in me_shutdown()
79 grpc_core::ExecCtx::Run(DEBUG_LOCATION, m->on_read, in me_shutdown()
82 m->on_read = nullptr; in me_shutdown()
133 m->on_read = nullptr; in grpc_mock_endpoint_create()
140 if (m->on_read != nullptr) { in grpc_mock_endpoint_put_read()
142 grpc_core::ExecCtx::Run(DEBUG_LOCATION, m->on_read, GRPC_ERROR_NONE); in grpc_mock_endpoint_put_read()
143 m->on_read = nullptr; in grpc_mock_endpoint_put_read()
|
| /dports/devel/grpc134/grpc-1.34.1/test/core/util/ |
| H A D | passthru_endpoint.cc | 47 grpc_closure* on_read; member
72 m->on_read = cb; in me_read()
91 } else if (m->on_read != nullptr) { in me_write()
96 m->on_read = nullptr; in me_write()
120 if (m->on_read) { in me_shutdown()
122 DEBUG_LOCATION, m->on_read, in me_shutdown()
124 m->on_read = nullptr; in me_shutdown()
127 if (m->on_read) { in me_shutdown()
129 DEBUG_LOCATION, m->on_read, in me_shutdown()
131 m->on_read = nullptr; in me_shutdown()
[all …]
|
| H A D | mock_endpoint.cc | 43 grpc_closure* on_read; member
55 m->on_read = cb; in me_read()
82 if (m->on_read) { in me_shutdown()
83 grpc_core::ExecCtx::Run(DEBUG_LOCATION, m->on_read, in me_shutdown()
86 m->on_read = nullptr; in me_shutdown()
140 m->on_read = nullptr; in grpc_mock_endpoint_create()
147 if (m->on_read != nullptr) { in grpc_mock_endpoint_put_read()
149 grpc_core::ExecCtx::Run(DEBUG_LOCATION, m->on_read, GRPC_ERROR_NONE); in grpc_mock_endpoint_put_read()
150 m->on_read = nullptr; in grpc_mock_endpoint_put_read()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/core/util/ |
| H A D | passthru_endpoint.cc | 43 grpc_closure* on_read; member
67 m->on_read = cb; in me_read()
86 } else if (m->on_read != nullptr) { in me_write()
91 m->on_read = nullptr; in me_write()
114 if (m->on_read) { in me_shutdown()
116 m->on_read, in me_shutdown()
118 m->on_read = nullptr; in me_shutdown()
121 if (m->on_read) { in me_shutdown()
123 m->on_read, in me_shutdown()
125 m->on_read = nullptr; in me_shutdown()
[all …]
|
| H A D | mock_endpoint.cc | 39 grpc_closure* on_read; member
51 m->on_read = cb; in me_read()
77 if (m->on_read) { in me_shutdown()
78 GRPC_CLOSURE_SCHED(m->on_read, in me_shutdown()
81 m->on_read = nullptr; in me_shutdown()
132 m->on_read = nullptr; in grpc_mock_endpoint_create()
139 if (m->on_read != nullptr) { in grpc_mock_endpoint_put_read()
141 GRPC_CLOSURE_SCHED(m->on_read, GRPC_ERROR_NONE); in grpc_mock_endpoint_put_read()
142 m->on_read = nullptr; in grpc_mock_endpoint_put_read()
|
| /dports/devel/p5-IO-Async/IO-Async-0.800/t/ |
| H A D | 21stream-1read.t | 43 on_read => sub {
93 on_read => sub {
130 on_read => sub {
197 on_read => sub {
279 on_read => sub {
336 on_read => sub {
384 on_read => sub {
419 on_read => sub {
484 on_read => sub {
629 on_read => sub {
[all …]
|
| H A D | 28filestream.t | 46 on_read => sub {
90 on_read => sub {
124 on_read => sub {
162 on_read => sub {
195 on_read => sub {
238 on_read => sub {
314 sub on_read
|
| /dports/devel/p5-Data-MessagePack-Stream/Data-MessagePack-Stream-0.07/msgpack-0.5.7/test/ |
| H A D | streaming.cc | 57 void on_read() in on_read() function in event_handler
102 handler.on_read(); in TEST()
106 handler.on_read(); in TEST()
110 handler.on_read(); in TEST()
163 void on_read() in on_read() function in event_handler_compat
210 handler.on_read(); in TEST()
214 handler.on_read(); in TEST()
218 handler.on_read(); in TEST()
|
| /dports/net/p5-Net-SSH-Mechanize/Net-SSH-Mechanize-0.1.3/lib/Net/SSH/Mechanize/ |
| H A D | Session.pm | 171 $stderr->on_read(_croak_with "error" => $done);
211 $stderr->on_read(undef);
277 $stderr->on_read(_warn_with "unexpected stderr from command");
292 $stderr->on_read(undef);
345 $stderr->on_read(_croak_with "error" => $done);
383 $stderr->on_read(undef);
400 $stderr->on_read(_warn_with "unexpected stderr from sudo command");
416 $stderr->on_read(undef);
|
| /dports/devel/p5-IO-Async/IO-Async-0.800/lib/IO/Async/ |
| H A D | Test.pm | 167 my $on_read;
169 $on_read = $_[2];
173 $on_read = sub { $$varref .= $_[0] };
186 $on_read->( $buffer );
|
| /dports/archivers/maxcso/maxcso-1.10.0/libuv/docs/code/uvcat/ |
| H A D | main.c | 7 void on_read(uv_fs_t *req);
22 uv_fs_read(uv_default_loop(), &read_req, open_req.result, &iov, 1, -1, on_read); in on_write()
26 void on_read(uv_fs_t *req) { in on_read() function
48 &iov, 1, -1, on_read); in on_open()
|
| /dports/devel/libuv/libuv-v1.42.0/docs/code/uvcat/ |
| H A D | main.c | 7 void on_read(uv_fs_t *req);
22 uv_fs_read(uv_default_loop(), &read_req, open_req.result, &iov, 1, -1, on_read); in on_write()
26 void on_read(uv_fs_t *req) { in on_read() function
48 &iov, 1, -1, on_read); in on_open()
|
| /dports/www/R-cran-httpuv/httpuv/src/libuv/docs/code/uvcat/ |
| H A D | main.c | 7 void on_read(uv_fs_t *req);
22 uv_fs_read(uv_default_loop(), &read_req, open_req.result, &iov, 1, -1, on_read); in on_write()
26 void on_read(uv_fs_t *req) { in on_read() function
48 &iov, 1, -1, on_read); in on_open()
|
| /dports/devel/cquery/cquery-20180718/third_party/msgpack-c/test/ |
| H A D | streaming.cpp | 166 void on_read() in on_read() function in event_handler
211 handler.on_read(); in TEST()
215 handler.on_read(); in TEST()
219 handler.on_read(); in TEST()
274 void on_read() in on_read() function in event_handler_compat
321 handler.on_read(); in TEST()
325 handler.on_read(); in TEST()
329 handler.on_read(); in TEST()
|
| /dports/devel/msgpack/msgpack-c-cpp-3.3.0/test/ |
| H A D | streaming.cpp | 177 void on_read() in on_read() function in event_handler
222 handler.on_read(); in TEST()
226 handler.on_read(); in TEST()
230 handler.on_read(); in TEST()
285 void on_read() in on_read() function in event_handler_compat
332 handler.on_read(); in TEST()
336 handler.on_read(); in TEST()
340 handler.on_read(); in TEST()
|
| /dports/devel/luv/luv-1.41.0-0/examples/uvbook/ |
| H A D | uvcat.lua | 14 local function on_read(err,chunk) function
25 uv.fs_read(fd, block, off, on_read)
30 uv.fs_read(fd, block, off, on_read)
|
| /dports/textproc/libxml++26/libxml++-2.40.1/libxml++/io/ |
| H A D | parserinputbuffer.cc | 21 static int on_read(void * context, char * buffer, int len) in on_read() function
38 &ParserInputBufferCallback::on_read, in ParserInputBuffer()
62 int ParserInputBuffer::on_read( in on_read() function in xmlpp::ParserInputBuffer
|
| /dports/devel/p5-IO-Async/IO-Async-0.800/lib/IO/Async/Protocol/ |
| H A D | Stream.pm | 159 on_read => $self->_replace_weakself( sub {
161 $self->invoke_event( on_read => @_ );
180 on_read => undef,
|
| /dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/internal/ |
| H A D | async_read_stream_impl.h | 119 OnReadHandler&& on_read, OnFinishHandler&& on_finish) {
121 new AsyncReadStreamImpl(std::forward<OnReadHandler>(on_read),
306 explicit AsyncReadStreamImpl(OnReadHandler&& on_read,
308 : on_read_(std::move(on_read)), on_finish_(std::move(on_finish)) {}
342 MakeAsyncReadStreamImpl(OnReadHandler&& on_read, OnFinishHandler&& on_finish) {
344 std::forward<OnReadHandler>(on_read),
|
| /dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/internal/ |
| H A D | async_read_stream_impl.h | 117 OnReadHandler&& on_read, OnFinishHandler&& on_finish) {
119 new AsyncReadStreamImpl(std::forward<OnReadHandler>(on_read),
304 explicit AsyncReadStreamImpl(OnReadHandler&& on_read,
306 : on_read_(std::move(on_read)), on_finish_(std::move(on_finish)) {}
340 MakeAsyncReadStreamImpl(OnReadHandler&& on_read, OnFinishHandler&& on_finish) {
342 std::forward<OnReadHandler>(on_read),
|
| /dports/www/p5-Plack-Middleware-SocketIO/Plack-Middleware-SocketIO-0.00904/lib/Plack/Middleware/SocketIO/ |
| H A D | Handle.pm | 22 $self->{handle}->on_read(sub { });
46 sub on_read { subroutine
50 $self->{handle}->on_read(
|
| /dports/games/retroarch/RetroArch-1.9.7/deps/switchres/ |
| H A D | custom_video_adl.h | 199 int invert_pol(bool on_read) { return ((cat_version <= 12) || (cat_version >= 15 && on_read)); } in invert_pol() argument
200 …rlace_factor(bool interlace, bool on_read) { return interlace && ((cat_version <= 12) || (cat_vers… in interlace_factor() argument
|