208         ssize_t rc = adb_write(worker_event_fd_.get(), &notify, sizeof(notify));  in Write()  local
209         if (rc < 0) {  in Write()
224         ssize_t rc = adb_write(worker_event_fd_.get(), &notify, sizeof(notify));  in Stop()  local
225         if (rc < 0) {  in Stop()
228         CHECK_EQ(static_cast<size_t>(rc), sizeof(notify));  in Stop()
230         rc = adb_write(monitor_event_fd_.get(), &notify, sizeof(notify));  in Stop()
231         if (rc < 0) {  in Stop()
235         CHECK_EQ(static_cast<size_t>(rc), sizeof(notify));  in Stop()
273                 int rc = TEMP_FAILURE_RETRY(adb_poll(pfd, 2, timeout_ms));  in StartMonitor()  local
274                 if (rc == -1) {  in StartMonitor()
276                 } else if (rc == 0) {  in StartMonitor()
287                 rc = TEMP_FAILURE_RETRY(adb_read(control_fd_.get(), &event, sizeof(event)));  in StartMonitor()
288                 if (rc == -1) {  in StartMonitor()
290                 } else if (rc == 0) {  in StartMonitor()
293                 } else if (rc != sizeof(event)) {  in StartMonitor()
295                                << sizeof(event) << ", got " << rc;  in StartMonitor()
371                             ssize_t rc = adb_write(control_fd_.get(), "", 0);  in StartMonitor()  local
372                             if (rc != 0) {  in StartMonitor()
380                             ssize_t rc = adb_read(control_fd_.get(), buf.data(), buf.size());  in StartMonitor()  local
381                             if (rc != event.u.setup.wLength) {  in StartMonitor()
383                                         << "read " << rc  in StartMonitor()
416                 ssize_t rc = adb_read(worker_event_fd_.get(), &dummy, sizeof(dummy));  in StartWorker()  local
417                 if (rc == -1) {  in StartWorker()
419                 } else if (rc == 0) {  in StartWorker()
438             int rc = pthread_kill(worker_thread_handle, kInterruptionSignal);  in StopWorker()  local
439             if (rc != 0) {  in StopWorker()
440                 LOG(ERROR) << "failed to send interruption signal to worker: " << strerror(rc);  in StopWorker()
446             rc = pthread_kill(worker_thread_handle, 0);  in StopWorker()
447             if (rc == 0) {  in StopWorker()
449             } else if (rc == ESRCH) {  in StopWorker()
452                 LOG(ERROR) << "failed to send interruption signal to worker: " << strerror(rc);  in StopWorker()
488         int rc = io_getevents(aio_context_.get(), 0, kMaxEvents, events, &timeout);  in ReadEvents()  local
489         if (rc == -1) {  in ReadEvents()
494         for (int event_idx = 0; event_idx < rc; ++event_idx) {  in ReadEvents()
673         int rc = io_submit(aio_context_.get(), writes_to_submit, iocbs);  in SubmitWrites()  local
674         if (rc == -1) {  in SubmitWrites()
677         } else if (rc != writes_to_submit) {  in SubmitWrites()
679                        << ", actually submitted " << rc;  in SubmitWrites()