128             fdevent_add(s->fde, FDE_WRITE);  in local_socket_flush_incoming()
131             fdevent_add(s->fde, FDE_WRITE);  in local_socket_flush_incoming()
146     fdevent_del(s->fde, FDE_WRITE);  in local_socket_flush_incoming()
179       s->fde->force_eof);  in local_socket_flush_outgoing()
206             fdevent_del(s->fde, FDE_READ);  in local_socket_flush_outgoing()
211     if ((s->fde->force_eof && !r) || is_eof) {  in local_socket_flush_outgoing()
212         D(" closing because is_eof=%d r=%d s->fde.force_eof=%d", is_eof, r, s->fde->force_eof);  in local_socket_flush_outgoing()
241     fdevent_add(s->fde, FDE_READ);  in local_socket_ready()
259     auto callback = [](fdevent* fde, unsigned event, void* arg) {  in deferred_close()  argument
264             while ((rc = adb_read(fde->fd.get(), buf, sizeof(buf))) > 0) {  in deferred_close()
282         fdevent_destroy(fde);  in deferred_close()
290     fdevent* fde = fdevent_create(fd.release(), callback, socket_info);  in deferred_close()  local
291     fdevent_add(fde, FDE_READ);  in deferred_close()
292     fdevent_set_timeout(fde, 1s);  in deferred_close()
301     deferred_close(fdevent_release(s->fde));  in local_socket_destroy()
343     fdevent_del(s->fde, FDE_READ);  in local_socket_close()
347     CHECK_EQ(FDE_WRITE, s->fde->state & FDE_WRITE);  in local_socket_close()
397     s->fde = fdevent_create(fd, local_socket_event_func, s);  in create_local_socket()