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()1646 fd_set_nonblock(dtio->commandpipe[0]); in dtio_setup_cmd()1647 cmdev = ub_event_new(dtio->event_base, dtio->commandpipe[0], in dtio_setup_cmd()1904 close(dtio->commandpipe[0]); in dtio_desetup()1906 _close(dtio->commandpipe[0]); in dtio_desetup()1908 dtio->commandpipe[0] = -1; in dtio_desetup()2172 if(pipe(dtio->commandpipe) == -1) { in dt_io_thread_start()2177 if(_pipe(dtio->commandpipe, 4096, _O_BINARY) == -1) { in dt_io_thread_start()2208 ssize_t r = write(dtio->commandpipe[1], &cmd, sizeof(cmd)); in dt_io_thread_stop()2229 close(dtio->commandpipe[1]); in dt_io_thread_stop()[all …]
186 int commandpipe[2]; member