| /external/chromium_org/tools/android/forwarder2/ |
| D | forwarder.cc | 105 void PrepareSelect(fd_set* read_fds, fd_set* write_fds, int* max_fd) { in PrepareSelect() argument
116 FD_SET(fd, read_fds); in PrepareSelect()
138 void ProcessSelect(const fd_set& read_fds, const fd_set& write_fds) { in ProcessSelect() argument
147 if (!FD_ISSET(fd, &read_fds)) in ProcessSelect()
232 void Forwarder::RegisterFDs(fd_set* read_fds, fd_set* write_fds, int* max_fd) { in RegisterFDs() argument
234 buffer1_->PrepareSelect(read_fds, write_fds, max_fd); in RegisterFDs()
235 buffer2_->PrepareSelect(read_fds, write_fds, max_fd); in RegisterFDs()
238 void Forwarder::ProcessEvents(const fd_set& read_fds, const fd_set& write_fds) { in ProcessEvents() argument
240 buffer1_->ProcessSelect(read_fds, write_fds); in ProcessEvents()
241 buffer2_->ProcessSelect(read_fds, write_fds); in ProcessEvents()
|
| D | forwarders_manager.cc | 65 fd_set read_fds; in WaitForEventsOnInternalThread() local
68 FD_ZERO(&read_fds); in WaitForEventsOnInternalThread()
76 forwarder->RegisterFDs(&read_fds, &write_fds, &max_fd); in WaitForEventsOnInternalThread()
87 FD_SET(notifier_fd, &read_fds); in WaitForEventsOnInternalThread()
92 select(max_fd + 1, &read_fds, &write_fds, NULL, NULL)); in WaitForEventsOnInternalThread()
99 deletion_notifier_.receiver_fd(), &read_fds); in WaitForEventsOnInternalThread()
107 if (FD_ISSET(wakeup_notifier_.receiver_fd(), &read_fds)) { in WaitForEventsOnInternalThread()
117 forwarder->ProcessEvents(read_fds, write_fds); in WaitForEventsOnInternalThread()
|
| D | forwarder.h | 25 void RegisterFDs(fd_set* read_fds, fd_set* write_fds, int* max_fd);
27 void ProcessEvents(const fd_set& read_fds, const fd_set& write_fds);
|
| D | socket.cc | 398 fd_set read_fds; in WaitForEvent() local
400 FD_ZERO(&read_fds); in WaitForEvent()
403 FD_SET(socket_, &read_fds); in WaitForEvent()
407 FD_SET(events_[i].fd, &read_fds); in WaitForEvent()
420 select(max_fd + 1, &read_fds, &write_fds, NULL, tv_ptr)) <= 0) { in WaitForEvent()
426 if (FD_ISSET(events_[i].fd, &read_fds)) { in WaitForEvent()
|
| /external/qemu/util/ |
| D | yield-android.c | 12 fd_set read_fds; in yield_until_fd_readable() local
13 FD_ZERO(&read_fds); in yield_until_fd_readable()
14 FD_SET(fd, &read_fds); in yield_until_fd_readable()
15 int ret = select(fd + 1, &read_fds, NULL, NULL, NULL); in yield_until_fd_readable()
|
| /external/chromium_org/third_party/boringssl/src/tool/ |
| D | client.cc | 162 fd_set read_fds; in TransferData() local
163 FD_ZERO(&read_fds); in TransferData()
171 FD_SET(0, &read_fds); in TransferData()
173 FD_SET(sock, &read_fds); in TransferData()
175 int ret = select(sock + 1, &read_fds, NULL, NULL, NULL); in TransferData()
181 if (FD_ISSET(0, &read_fds)) { in TransferData()
190 FD_CLR(0, &read_fds); in TransferData()
218 if (FD_ISSET(sock, &read_fds)) { in TransferData()
|
| /external/chromium_org/base/ |
| D | sync_socket_posix.cc | 158 fd_set read_fds; in ReceiveWithTimeout() local
163 FD_ZERO(&read_fds); in ReceiveWithTimeout()
164 FD_SET(handle_, &read_fds); in ReceiveWithTimeout()
170 select(handle_ + 1, &read_fds, NULL, NULL, &timeout_struct); in ReceiveWithTimeout()
179 DCHECK(FD_ISSET(handle_, &read_fds)); in ReceiveWithTimeout()
|
| /external/chromium_org/tools/android/forwarder/ |
| D | forwarder.cc | 200 fd_set read_fds; in ForwarderThread() local
206 FD_ZERO(&read_fds); in ForwarderThread()
208 FD_SET(socket1, &read_fds); in ForwarderThread()
210 FD_SET(socket2, &read_fds); in ForwarderThread()
218 if (HANDLE_EINTR(select(nfds, &read_fds, &write_fds, NULL, NULL)) <= 0) { in ForwarderThread()
224 if (FD_ISSET(socket1, &read_fds)) { in ForwarderThread()
231 if (FD_ISSET(socket2, &read_fds)) { in ForwarderThread()
|
| /external/lldb/source/Core/ |
| D | ConnectionFileDescriptor.cpp | 676 llvm::SmallVector<fd_set, 1> read_fds; in BytesAvailable() local
677 read_fds.resize((nfds/FD_SETSIZE) + 1); in BytesAvailable()
678 for (size_t i=0; i<read_fds.size(); ++i) in BytesAvailable()
679 FD_ZERO (&read_fds[i]); in BytesAvailable()
683 FD_SET (data_fd, read_fds.data()); in BytesAvailable()
685 FD_SET (pipe_fd, read_fds.data()); in BytesAvailable()
699 const int num_set_fds = ::select (nfds, read_fds.data(), NULL, NULL, tv_ptr); in BytesAvailable()
746 if (FD_ISSET(data_fd, read_fds.data())) in BytesAvailable()
748 if (have_pipe_fd && FD_ISSET(pipe_fd, read_fds.data())) in BytesAvailable()
835 fd_set read_fds; in BytesAvailable() local
[all …]
|
| /external/qemu/proxy/ |
| D | proxy_common.h | 79 fd_set* read_fds,
84 extern void proxy_manager_poll( fd_set* read_fds,
|
| D | proxy_common.c | 420 proxy_manager_select_fill( int *pcount, fd_set* read_fds, fd_set* write_fds, fd_set* err_fds) in proxy_manager_select_fill() argument
429 sel->reads = read_fds; in proxy_manager_select_fill()
443 proxy_manager_poll( fd_set* read_fds, fd_set* write_fds, fd_set* err_fds ) in proxy_manager_poll() argument
449 sel->reads = read_fds; in proxy_manager_poll()
|
| /external/protobuf/src/google/protobuf/compiler/ |
| D | subprocess.cc | 360 fd_set read_fds;
362 FD_ZERO(&read_fds);
365 FD_SET(child_stdout_, &read_fds);
371 if (select(max_fd + 1, &read_fds, &write_fds, NULL, NULL) < 0) {
398 if (child_stdout_ != -1 && FD_ISSET(child_stdout_, &read_fds)) {
|
| /external/iptables/libipq/ |
| D | libipq.c | 140 fd_set read_fds; in ipq_netlink_recvfrom() local
151 FD_ZERO(&read_fds); in ipq_netlink_recvfrom()
152 FD_SET(h->fd, &read_fds); in ipq_netlink_recvfrom()
153 ret = select(h->fd+1, &read_fds, NULL, NULL, &tv); in ipq_netlink_recvfrom()
162 if (!FD_ISSET(h->fd, &read_fds)) { in ipq_netlink_recvfrom()
|
| /external/chromium_org/third_party/protobuf/src/google/protobuf/compiler/ |
| D | subprocess.cc | 365 fd_set read_fds;
367 FD_ZERO(&read_fds);
370 FD_SET(child_stdout_, &read_fds);
376 if (select(max_fd + 1, &read_fds, &write_fds, NULL, NULL) < 0) {
403 if (child_stdout_ != -1 && FD_ISSET(child_stdout_, &read_fds)) {
|
| /external/chromium_org/build/android/pylib/ |
| D | cmd_helper.py | 149 read_fds, _, _ = select.select([child_fd], [], [], poll_interval)
150 if child_fd in read_fds:
|
| /external/chromium_org/sync/tools/testserver/ |
| D | sync_testserver.py | 96 read_fds = [ self.fileno() ]
104 read_fds.append(fd)
111 read_fds, write_fds, exceptional_fds = (
112 select.select(read_fds, write_fds, exceptional_fds))
119 for fd in read_fds:
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/port/ |
| D | server_process.py | 270 … read_fds, _, _ = select.select(select_fds, [], select_fds, max(deadline - time.time(), 0))
284 if out_fd in read_fds:
291 if err_fd in read_fds:
|
| /external/chromium_org/chrome/browser/ |
| D | process_singleton_posix.cc | 176 fd_set read_fds; in WaitSocketForRead() local
179 FD_ZERO(&read_fds); in WaitSocketForRead()
180 FD_SET(fd, &read_fds); in WaitSocketForRead()
182 return HANDLE_EINTR(select(fd + 1, &read_fds, NULL, NULL, &tv)); in WaitSocketForRead()
|
| /external/lldb/tools/debugserver/source/MacOSX/ |
| D | MachProcess.cpp | 1292 fd_set read_fds; in STDIOThread() local
1293 FD_ZERO (&read_fds); in STDIOThread()
1295 FD_SET (stdout_fd, &read_fds); in STDIOThread()
1297 FD_SET (stderr_fd, &read_fds); in STDIOThread()
1300 int num_set_fds = select (nfds, &read_fds, NULL, NULL, NULL); in STDIOThread()
1333 if (stdout_fd >= 0 && FD_ISSET (stdout_fd, &read_fds)) in STDIOThread()
1357 if (stderr_fd >= 0 && FD_ISSET (stderr_fd, &read_fds)) in STDIOThread()
|