| /third_party/node/deps/cares/src/lib/ |
| D | ares_nowarn.c | 212 int aresx_FD_ISSET(int fd, fd_set *fdset) in aresx_FD_ISSET() argument
216 return FD_ISSET(fd, fdset); in aresx_FD_ISSET()
220 void aresx_FD_SET(int fd, fd_set *fdset) in aresx_FD_SET() argument
224 FD_SET(fd, fdset); in aresx_FD_SET()
228 void aresx_FD_ZERO(fd_set *fdset) in aresx_FD_ZERO() argument
232 FD_ZERO(fdset); in aresx_FD_ZERO()
|
| D | ares_nowarn.h | 36 int aresx_FD_ISSET(int fd, fd_set *fdset);
38 void aresx_FD_SET(int fd, fd_set *fdset);
40 void aresx_FD_ZERO(fd_set *fdset);
|
| /third_party/gstreamer/gstreamer/plugins/elements/ |
| D | gstfdsink.c | 265 ret = gst_writev_buffer_list (GST_OBJECT_CAST (sink), sink->fd, sink->fdset, in gst_fd_sink_render_list()
300 ret = gst_writev_buffer (GST_OBJECT_CAST (sink), sink->fd, sink->fdset, in gst_fd_sink_render()
371 if ((fdsink->fdset = gst_poll_new (TRUE)) == NULL) in gst_fd_sink_start()
375 gst_poll_add_fd (fdsink->fdset, &fd); in gst_fd_sink_start()
376 gst_poll_fd_ctl_write (fdsink->fdset, &fd, TRUE); in gst_fd_sink_start()
399 if (fdsink->fdset) { in gst_fd_sink_stop()
400 gst_poll_free (fdsink->fdset); in gst_fd_sink_stop()
401 fdsink->fdset = NULL; in gst_fd_sink_stop()
415 gst_poll_set_flushing (fdsink->fdset, TRUE); in gst_fd_sink_unlock()
429 gst_poll_set_flushing (fdsink->fdset, FALSE); in gst_fd_sink_unlock_stop()
[all …]
|
| D | gstelements_private.h | 37 GstFlowReturn gst_writev_buffer (GstObject * sink, gint fd, GstPoll * fdset,
44 GstFlowReturn gst_writev_buffer_list (GstObject * sink, gint fd, GstPoll * fdset,
51 GstFlowReturn gst_writev_mem (GstObject * sink, gint fd, GstPoll * fdset,
|
| D | gstelements_private.c | 210 gst_writev_iovecs (GstObject * sink, gint fd, GstPoll * fdset, in gst_writev_iovecs() argument
238 if (fdset != NULL) { in gst_writev_iovecs()
242 ret = gst_poll_wait (fdset, GST_CLOCK_TIME_NONE); in gst_writev_iovecs()
304 if (fdset != NULL) in gst_writev_iovecs()
352 gst_writev_buffer (GstObject * sink, gint fd, GstPoll * fdset, in gst_writev_buffer() argument
399 gst_writev_iovecs (sink, fd, fdset, vecs, num_vecs, left, in gst_writev_buffer()
441 gst_writev_mem (GstObject * sink, gint fd, GstPoll * fdset, in gst_writev_mem() argument
461 gst_writev_iovecs (sink, fd, fdset, &vec, 1, left, in gst_writev_mem()
492 gst_writev_buffer_list (GstObject * sink, gint fd, GstPoll * fdset, in gst_writev_buffer_list() argument
550 gst_writev_iovecs (sink, fd, fdset, vecs, num_vecs, left, in gst_writev_buffer_list()
|
| D | gstfdsrc.c | 234 GST_DEBUG_OBJECT (src, "fdset %p, old_fd %d, new_fd %d", src->fdset, src->fd, in gst_fd_src_update_fd()
239 if (src->fdset != NULL) { in gst_fd_src_update_fd()
245 gst_poll_remove_fd (src->fdset, &fd); in gst_fd_src_update_fd()
249 gst_poll_add_fd (src->fdset, &fd); in gst_fd_src_update_fd()
250 gst_poll_fd_ctl_read (src->fdset, &fd, TRUE); in gst_fd_src_update_fd()
310 if ((src->fdset = gst_poll_new (TRUE)) == NULL) in gst_fd_src_start()
331 if (src->fdset) { in gst_fd_src_stop()
332 gst_poll_free (src->fdset); in gst_fd_src_stop()
333 src->fdset = NULL; in gst_fd_src_stop()
346 gst_poll_set_flushing (src->fdset, TRUE); in gst_fd_src_unlock()
[all …]
|
| D | gstfdsink.h | 58 GstPoll *fdset; member
|
| D | gstfdsrc.h | 71 GstPoll *fdset; member
|
| /third_party/gstreamer/gstplugins_base/gst/tcp/ |
| D | gstmultifdsink.c | 527 gst_poll_add_fd (sink->fdset, &client->gfd); in gst_multi_fd_sink_new_client()
535 gst_poll_fd_ctl_read (sink->fdset, &client->gfd, TRUE); in gst_multi_fd_sink_new_client()
572 gst_poll_restart (sink->fdset); in gst_multi_fd_sink_hash_changed()
700 gst_poll_fd_ctl_write (sink->fdset, &client->gfd, FALSE); in gst_multi_fd_sink_handle_client_write()
725 gst_poll_fd_ctl_write (sink->fdset, &client->gfd, FALSE); in gst_multi_fd_sink_handle_client_write()
858 gst_poll_fd_ctl_write (sink->fdset, &client->gfd, TRUE); in gst_multi_fd_sink_hash_adding()
868 gst_poll_remove_fd (sink->fdset, &client->gfd); in gst_multi_fd_sink_hash_removing()
904 gst_poll_wait (sink->fdset, in gst_multi_fd_sink_handle_clients()
990 fclass->wait (sink, sink->fdset); in gst_multi_fd_sink_handle_clients()
1016 if (gst_poll_fd_has_closed (sink->fdset, &client->gfd)) { in gst_multi_fd_sink_handle_clients()
[all …]
|
| D | gstmultifdsink.h | 69 GstPoll *fdset; member
|
| /third_party/gstreamer/gstreamer/gst/ |
| D | gstpluginloader.c | 90 GstPoll *fdset; member
154 l->fdset = gst_poll_new (FALSE); in plugin_loader_new()
199 gst_poll_free (loader->fdset); in plugin_loader_free()
447 gst_poll_add_fd (loader->fdset, &loader->fd_w); in gst_plugin_loader_try_helper()
448 gst_poll_add_fd (loader->fdset, &loader->fd_r); in gst_plugin_loader_try_helper()
450 gst_poll_fd_ctl_read (loader->fdset, &loader->fd_r, TRUE); in gst_plugin_loader_try_helper()
629 gst_poll_remove_fd (l->fdset, &l->fd_w); in plugin_loader_cleanup_child()
630 gst_poll_remove_fd (l->fdset, &l->fd_r); in plugin_loader_cleanup_child()
691 gst_poll_add_fd (l->fdset, &l->fd_w); in _gst_plugin_loader_client_run()
692 gst_poll_add_fd (l->fdset, &l->fd_r); in _gst_plugin_loader_client_run()
[all …]
|
| /third_party/curl/lib/ |
| D | warnless.c | 379 int curlx_FD_ISSET(int fd, fd_set *fdset) in curlx_FD_ISSET() argument
383 return FD_ISSET(fd, fdset); in curlx_FD_ISSET()
387 void curlx_FD_SET(int fd, fd_set *fdset) in curlx_FD_SET() argument
391 FD_SET(fd, fdset); in curlx_FD_SET()
395 void curlx_FD_ZERO(fd_set *fdset) in curlx_FD_ZERO() argument
399 FD_ZERO(fdset); in curlx_FD_ZERO()
|
| D | warnless.h | 85 int curlx_FD_ISSET(int fd, fd_set *fdset);
87 void curlx_FD_SET(int fd, fd_set *fdset);
89 void curlx_FD_ZERO(fd_set *fdset);
|
| /third_party/openssl/util/perl/TLSProxy/ |
| D | Proxy.pm | 358 my $fdset = IO::Select->new($self->{proxy_sock});
359 if (!$fdset->can_read(60)) {
376 $fdset = IO::Select->new($server_sock, $client_sock);
381 while($fdset->count && $ctr < 10) {
388 if (!(@ready = $fdset->can_read(1))) {
400 $fdset->remove($server_sock);
410 $fdset->remove($client_sock);
|
| /third_party/glib/glib/ |
| D | gbacktrace.c | 321 fd_set fdset; in stack_trace() local
366 FD_ZERO (&fdset); in stack_trace()
367 FD_SET (out_fd[0], &fdset); in stack_trace()
386 readset = fdset; in stack_trace()
|
| /third_party/gstreamer/gstplugins_bad/ext/curl/ |
| D | gstcurlbasesink.c | 280 if (this->fdset != NULL) { in gst_curl_base_sink_finalize()
281 gst_poll_free (this->fdset); in gst_curl_base_sink_finalize()
282 this->fdset = NULL; in gst_curl_base_sink_finalize()
451 if ((sink->fdset = gst_poll_new (TRUE)) == NULL) { in gst_curl_base_sink_start()
468 if (sink->fdset != NULL) { in gst_curl_base_sink_stop()
469 gst_poll_free (sink->fdset); in gst_curl_base_sink_stop()
470 sink->fdset = NULL; in gst_curl_base_sink_stop()
484 gst_poll_set_flushing (sink->fdset, TRUE); in gst_curl_base_sink_unlock()
497 gst_poll_set_flushing (sink->fdset, FALSE); in gst_curl_base_sink_unlock_stop()
999 activated_fds = gst_poll_wait (sink->fdset, timeout * GST_SECOND); in handle_transfer()
[all …]
|
| D | gstcurlbasesink.h | 69 GstPoll *fdset; member
|
| /third_party/skia/third_party/externals/tint/tools/src/cmd/remote-compile/ |
| D | socket.cc | 291 fd_set fdset; in Connect() local
292 FD_ZERO(&fdset); in Connect()
293 FD_SET(socket, &fdset); in Connect()
298 res = select(static_cast<int>(socket + 1), nullptr, &fdset, nullptr, &tv); in Connect()
|
| /third_party/curl/tests/libtest/ |
| D | lib582.c | 188 static void updateFdSet(struct Sockets *sockets, fd_set* fdset, in updateFdSet() argument
193 FD_SET(sockets->sockets[i], fdset); in updateFdSet()
214 static void checkFdSet(CURLM *curl, struct Sockets *sockets, fd_set *fdset, in checkFdSet() argument
219 if(FD_ISSET(sockets->sockets[i], fdset)) { in checkFdSet()
|
| /third_party/flutter/skia/third_party/externals/sdl/src/audio/bsd/ |
| D | SDL_bsdaudio.c | 138 fd_set fdset; in BSDAUDIO_WaitDevice() local
141 FD_ZERO(&fdset); in BSDAUDIO_WaitDevice()
142 FD_SET(this->hidden->audio_fd, &fdset); in BSDAUDIO_WaitDevice()
148 if (select(this->hidden->audio_fd + 1, NULL, &fdset, NULL, &timeout) in BSDAUDIO_WaitDevice()
|
| /third_party/flutter/skia/third_party/externals/sdl/src/audio/sun/ |
| D | SDL_sunaudio.c | 100 fd_set fdset; in SUNAUDIO_WaitDevice()
102 FD_ZERO(&fdset); in SUNAUDIO_WaitDevice()
103 FD_SET(this->hidden->audio_fd, &fdset); in SUNAUDIO_WaitDevice()
104 select(this->hidden->audio_fd + 1, NULL, &fdset, NULL, NULL); in SUNAUDIO_WaitDevice()
|
| /third_party/flutter/skia/third_party/externals/sdl/src/audio/paudio/ |
| D | SDL_paudio.c | 128 fd_set fdset; in PAUDIO_WaitDevice() local
144 FD_ZERO(&fdset); in PAUDIO_WaitDevice()
145 FD_SET(this->hidden->audio_fd, &fdset); in PAUDIO_WaitDevice()
168 if (select(this->hidden->audio_fd + 1, NULL, &fdset, NULL, &timeout) in PAUDIO_WaitDevice()
|
| /third_party/flutter/skia/third_party/externals/sdl/src/video/x11/ |
| D | SDL_x11events.c | 1365 fd_set fdset; in X11_Pending() local
1368 FD_ZERO(&fdset); in X11_Pending()
1369 FD_SET(x11_fd, &fdset); in X11_Pending()
1370 if (select(x11_fd + 1, &fdset, NULL, NULL, &zero_time) == 1) { in X11_Pending()
|
| /third_party/mksh/ |
| D | funcs.c | 1736 fd_set fdset; in c_read() local
1738 FD_ZERO(&fdset); in c_read()
1739 FD_SET((unsigned int)fd, &fdset); in c_read()
1748 switch (select(fd + 1, &fdset, NULL, NULL, &tv)) { in c_read()
|
| /third_party/lwip/src/api/ |
| D | sockets.c | 1973 lwip_select_inc_sockets_used_set(int maxfdp, fd_set *fdset, fd_set *used_sockets) in lwip_select_inc_sockets_used_set() argument
1976 if (fdset) { in lwip_select_inc_sockets_used_set()
1980 if (FD_ISSET(i, fdset) && !FD_ISSET(i, used_sockets)) { in lwip_select_inc_sockets_used_set()
|