Searched refs:commandpipe (Results 1 – 2 of 2) sorted by relevance
156 ssize_t r = write(dtio->commandpipe[1], &cmd, sizeof(cmd)); in dtio_wakeup()1606 fd_set_nonblock(dtio->commandpipe[0]); in dtio_setup_cmd()1607 cmdev = ub_event_new(dtio->event_base, dtio->commandpipe[0], in dtio_setup_cmd()1864 close(dtio->commandpipe[0]); in dtio_desetup()1866 _close(dtio->commandpipe[0]); in dtio_desetup()1868 dtio->commandpipe[0] = -1; in dtio_desetup()2121 if(pipe(dtio->commandpipe) == -1) { in dt_io_thread_start()2126 if(_pipe(dtio->commandpipe, 4096, _O_BINARY) == -1) { in dt_io_thread_start()2157 ssize_t r = write(dtio->commandpipe[1], &cmd, sizeof(cmd)); in dt_io_thread_stop()2178 close(dtio->commandpipe[1]); in dt_io_thread_stop()[all …]
180 int commandpipe[2]; member