Home
last modified time | relevance | path

Searched refs:read_cb (Results 1 – 25 of 29) sorted by relevance

12

/external/libcups/scheduler/
Dselect.c181 cupsd_selfunc_t read_cb, /* Read callback */ member
236 cupsd_selfunc_t read_cb, /* I - Read callback */ in cupsdAddSelect() argument
252 fd, read_cb, write_cb, data); in cupsdAddSelect()
298 if (fdptr->read_cb != read_cb)
300 if (read_cb)
338 if (read_cb)
365 if (read_cb)
386 fdptr->read_cb = read_cb;
433 if (fdptr->read_cb && event->filter == EVFILT_READ) in cupsdDoSelect()
434 (*(fdptr->read_cb))(fdptr->data); in cupsdDoSelect()
[all …]
Dcupsd.h210 extern int cupsdAddSelect(int fd, cupsd_selfunc_t read_cb,
/external/flac/src/libFLAC/
Dmetadata_iterators.c74 …d_metadata_block_header_cb_(FLAC__IOHandle handle, FLAC__IOCallback_Read read_cb, FLAC__bool *is_l…
75 …ead_metadata_block_data_cb_(FLAC__IOHandle handle, FLAC__IOCallback_Read read_cb, FLAC__IOCallback…
76 …a_block_data_streaminfo_cb_(FLAC__IOHandle handle, FLAC__IOCallback_Read read_cb, FLAC__StreamMeta…
78 …_block_data_application_cb_(FLAC__IOHandle handle, FLAC__IOCallback_Read read_cb, FLAC__StreamMeta…
79 …ta_block_data_seektable_cb_(FLAC__IOHandle handle, FLAC__IOCallback_Read read_cb, FLAC__StreamMeta…
80 …ta_vorbis_comment_entry_cb_(FLAC__IOHandle handle, FLAC__IOCallback_Read read_cb, FLAC__StreamMeta…
81 …ock_data_vorbis_comment_cb_(FLAC__IOHandle handle, FLAC__IOCallback_Read read_cb, FLAC__IOCallback…
82 …ock_data_cuesheet_track_cb_(FLAC__IOHandle handle, FLAC__IOCallback_Read read_cb, FLAC__StreamMeta…
83 …ata_block_data_cuesheet_cb_(FLAC__IOHandle handle, FLAC__IOCallback_Read read_cb, FLAC__StreamMeta…
84 …data_block_data_picture_cb_(FLAC__IOHandle handle, FLAC__IOCallback_Read read_cb, FLAC__StreamMeta…
[all …]
/external/grpc-grpc/src/core/lib/iomgr/
Dendpoint_cfstream.cc50 grpc_closure* read_cb; member
120 ep->read_cb, ep->read_cb->cb, ep->read_cb->cb_arg); in CallReadCb()
132 grpc_closure* cb = ep->read_cb; in CallReadCb()
133 ep->read_cb = nullptr; in CallReadCb()
153 GPR_ASSERT(ep->read_cb != nullptr); in ReadAction()
260 GPR_ASSERT(ep_impl->read_cb == nullptr); in CFStreamRead()
261 ep_impl->read_cb = cb; in CFStreamRead()
355 ep_impl->read_cb = nil; in grpc_cfstream_endpoint_create()
Dtcp_custom.cc61 grpc_closure* read_cb; member
126 grpc_closure* cb = tcp->read_cb; in call_read_cb()
143 tcp->read_cb = nullptr; in call_read_cb()
199 GPR_ASSERT(tcp->read_cb == nullptr); in endpoint_read()
200 tcp->read_cb = cb; in endpoint_read()
Dtcp_uv.cc63 grpc_custom_read_callback read_cb; member
113 uv_socket->read_cb(socket, (size_t)nread, error); in uv_read_callback()
127 size_t length, grpc_custom_read_callback read_cb) { in uv_socket_read() argument
131 uv_socket->read_cb = read_cb; in uv_socket_read()
140 uv_socket->read_cb(socket, 0, error); in uv_socket_read()
Dtcp_windows.cc113 grpc_closure* read_cb; member
180 grpc_closure* cb = tcp->read_cb; in on_read()
207 tcp->read_cb = NULL; in on_read()
229 tcp->read_cb = cb; in win_read()
Dtcp_posix.cc96 grpc_closure* read_cb; member
387 grpc_closure* cb = tcp->read_cb; in call_read_cb()
403 tcp->read_cb = nullptr; in call_read_cb()
528 GPR_ASSERT(tcp->read_cb == nullptr); in tcp_read()
529 tcp->read_cb = cb; in tcp_read()
1050 tcp->read_cb = nullptr; in grpc_tcp_create()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dendpoint_cfstream.cc52 grpc_closure* read_cb; member
121 ep->read_cb, ep->read_cb->cb, ep->read_cb->cb_arg); in CallReadCb()
134 grpc_closure* cb = ep->read_cb; in CallReadCb()
135 ep->read_cb = nullptr; in CallReadCb()
155 GPR_ASSERT(ep->read_cb != nullptr); in ReadAction()
263 GPR_ASSERT(ep_impl->read_cb == nullptr); in CFStreamRead()
264 ep_impl->read_cb = cb; in CFStreamRead()
384 ep_impl->read_cb = nil; in grpc_cfstream_endpoint_create()
Dtcp_custom.cc61 grpc_closure* read_cb = nullptr; member
126 grpc_closure* cb = tcp->read_cb; in call_read_cb()
144 tcp->read_cb = nullptr; in call_read_cb()
203 GPR_ASSERT(tcp->read_cb == nullptr); in endpoint_read()
204 tcp->read_cb = cb; in endpoint_read()
Dtcp_uv.cc62 grpc_custom_read_callback read_cb; member
112 uv_socket->read_cb(socket, (size_t)nread, error); in uv_read_callback()
126 size_t length, grpc_custom_read_callback read_cb) { in uv_socket_read() argument
130 uv_socket->read_cb = read_cb; in uv_socket_read()
139 uv_socket->read_cb(socket, 0, error); in uv_socket_read()
Dtcp_windows.cc111 grpc_closure* read_cb; member
182 grpc_closure* cb = tcp->read_cb; in on_read()
234 tcp->read_cb = NULL; in on_read()
264 tcp->read_cb = cb; in win_read()
/external/grpc-grpc/test/core/iomgr/
Dtcp_posix_test.cc155 grpc_closure read_cb; member
174 static void read_cb(void* user_data, grpc_error* error) { in read_cb() function
194 grpc_endpoint_read(state->ep, &state->incoming, &state->read_cb); in read_cb()
230 GRPC_CLOSURE_INIT(&state.read_cb, read_cb, &state, grpc_schedule_on_exec_ctx); in read_test()
232 grpc_endpoint_read(ep, &state.incoming, &state.read_cb); in read_test()
281 GRPC_CLOSURE_INIT(&state.read_cb, read_cb, &state, grpc_schedule_on_exec_ctx); in large_read_test()
283 grpc_endpoint_read(ep, &state.incoming, &state.read_cb); in large_read_test()
520 GRPC_CLOSURE_INIT(&state.read_cb, read_cb, &state, grpc_schedule_on_exec_ctx); in release_fd_test()
522 grpc_endpoint_read(ep, &state.incoming, &state.read_cb); in release_fd_test()
/external/libevent/test/
Dregress_et.c63 read_cb(evutil_socket_t fd, short event, void *arg) in read_cb() function
106 ev = event_new(base, pair[1], EV_READ|EV_ET|EV_PERSIST, read_cb, &ev); in test_edgetriggered()
153 ev_et = event_new(base, data->pair[0], EV_READ|EV_ET, read_cb, ev_et); in test_edgetriggered_mix_error()
155 ev_lt = event_new(base, data->pair[0], EV_READ, read_cb, ev_lt); in test_edgetriggered_mix_error()
Dtest-eof.c57 read_cb(evutil_socket_t fd, short event, void *arg) in read_cb() function
109 event_set(&ev, pair[1], EV_READ | EV_TIMEOUT, read_cb, &ev); in main()
Dbench_cascade.c67 read_cb(evutil_socket_t fd, short which, void *arg) in read_cb() function
111 event_set(&events[i], cp[0], EV_READ, read_cb, in run_once()
Dbench.c77 read_cb(evutil_socket_t fd, short which, void *arg) in read_cb() function
109 event_assign(&events[i], base, cp[0], EV_READ | EV_PERSIST, read_cb, (void *)(ev_intptr_t) i); in run_once()
/external/libcups/cups/
Dtestipp.c291 ssize_t read_cb(_ippdata_t *data, ipp_uchar_t *buffer, size_t bytes);
436 while ((state = ippReadIO(&data, (ipp_iocb_t)read_cb, 1, NULL, in main()
666 while ((state = ippReadIO(&data, (ipp_iocb_t)read_cb, 1, NULL, request)) != IPP_STATE_DATA) in main()
688 while ((state = ippReadIO(&data, (ipp_iocb_t)read_cb, 1, NULL, in main()
979 read_cb(_ippdata_t *data, /* I - Data */ in read_cb() function
/external/adhd/cras/src/server/
Dcras_hfp_info.c112 int (*read_cb)(struct hfp_info *info); member
674 err = info->read_cb(info); in hfp_info_callback()
785 info->read_cb = hfp_read_msbc; in hfp_info_start()
793 info->read_cb = hfp_read; in hfp_info_start()
830 info->read_cb = NULL; in hfp_info_stop()
/external/webrtc/common_audio/resampler/
Dsinc_resampler.cc150 SincResamplerCallback* read_cb) in SincResampler() argument
152 read_cb_(read_cb), in SincResampler()
Dsinc_resampler.h64 SincResamplerCallback* read_cb);
/external/libese/esed/
DWeaver.h42 Return<void> read(uint32_t slotId, const hidl_vec<uint8_t>& key, read_cb _hidl_cb) override;
DWeaver.cpp114 Return<void> Weaver::read(uint32_t slotId, const hidl_vec<uint8_t>& key, read_cb _hidl_cb) { in read()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/
Dsecure_endpoint.cc89 grpc_closure* read_cb = nullptr; member
168 grpc_core::ExecCtx::Run(DEBUG_LOCATION, ep->read_cb, error); in call_read_cb()
260 ep->read_cb = cb; in endpoint_read()
/external/grpc-grpc/src/core/lib/security/transport/
Dsecure_endpoint.cc50 grpc_closure* read_cb; member
141 GRPC_CLOSURE_SCHED(ep->read_cb, error); in call_read_cb()
233 ep->read_cb = cb; in endpoint_read()

12