Lines Matching refs:egc
64 void xswait_xswatch_callback(libxl__egc *egc, libxl__ev_xswatch *xsw, in xswait_xswatch_callback() argument
76 if (rc) { xswait_report_error(egc, xswa, rc); return; } in xswait_xswatch_callback()
79 xswa->callback(egc, xswa, 0, data); in xswait_xswatch_callback()
82 void xswait_timeout_callback(libxl__egc *egc, libxl__ev_time *ev, in xswait_timeout_callback() argument
89 xswait_report_error(egc, xswa, rc); in xswait_timeout_callback()
92 static void xswait_report_error(libxl__egc *egc, libxl__xswait_state *xswa, in xswait_report_error() argument
97 xswa->callback(egc, xswa, rc, 0); in xswait_report_error()
125 static void datacopier_callback(libxl__egc *egc, libxl__datacopier_state *dc, in datacopier_callback() argument
129 dc->callback(egc, dc, rc, onwrite, errnoval); in datacopier_callback()
132 static void datacopier_writable(libxl__egc *egc, libxl__ev_fd *ev,
135 static void datacopier_check_state(libxl__egc *egc, libxl__datacopier_state *dc) in datacopier_check_state() argument
147 datacopier_callback(egc, dc, ERROR_FAIL, -1, EIO); in datacopier_check_state()
154 datacopier_callback(egc, dc, 0, 0, 0); in datacopier_check_state()
162 void libxl__datacopier_prefixdata(libxl__egc *egc, libxl__datacopier_state *dc, in libxl__datacopier_prefixdata() argument
189 static int datacopier_pollhup_handled(libxl__egc *egc, in datacopier_pollhup_handled() argument
199 dc->callback_pollhup(egc, dc, ERROR_FAIL, onwrite, -1); in datacopier_pollhup_handled()
205 static void datacopier_abort(libxl__egc *egc, libxl__ao_abortable *abrt, in datacopier_abort() argument
211 datacopier_callback(egc, dc, rc, -1, 0); in datacopier_abort()
214 static void datacopier_readable(libxl__egc *egc, libxl__ev_fd *ev, in datacopier_readable() argument
219 if (datacopier_pollhup_handled(egc, dc, fd, revents, 0)) in datacopier_readable()
226 datacopier_callback(egc, dc, ERROR_FAIL, -1, EIO); in datacopier_readable()
264 datacopier_callback(egc, dc, ERROR_FAIL, -1, 0); in datacopier_readable()
271 datacopier_callback(egc, dc, ERROR_FAIL, 0, errno); in datacopier_readable()
285 LIBXL__EVENT_DISASTER(egc, in datacopier_readable()
288 if (datacopier_pollhup_handled(egc, dc, fd, hupchk.revents, 0)) in datacopier_readable()
300 datacopier_callback(egc, dc, ERROR_FAIL, 0, errno); in datacopier_readable()
314 datacopier_check_state(egc, dc); in datacopier_readable()
317 static void datacopier_writable(libxl__egc *egc, libxl__ev_fd *ev, in datacopier_writable() argument
322 if (datacopier_pollhup_handled(egc, dc, fd, revents, 1)) in datacopier_writable()
329 datacopier_callback(egc, dc, ERROR_FAIL, -1, EIO); in datacopier_writable()
349 datacopier_callback(egc, dc, ERROR_FAIL, 1, errno); in datacopier_writable()
359 datacopier_check_state(egc, dc); in datacopier_writable()
411 static void openpty_exited(libxl__egc *egc, libxl__ev_child *child, in openpty_exited() argument
425 op->callback(egc, op); in openpty_exited()
525 static void async_exec_timeout(libxl__egc *egc, in async_exec_timeout() argument
549 static void async_exec_done(libxl__egc *egc, in async_exec_done() argument
564 aes->callback(egc, aes, aes->rc, status); in async_exec_done()