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()1643 fd_set_nonblock(dtio->commandpipe[0]); in dtio_setup_cmd()1644 cmdev = ub_event_new(dtio->event_base, dtio->commandpipe[0], in dtio_setup_cmd()1901 close(dtio->commandpipe[0]); in dtio_desetup()1903 _close(dtio->commandpipe[0]); in dtio_desetup()1905 dtio->commandpipe[0] = -1; in dtio_desetup()2158 if(pipe(dtio->commandpipe) == -1) { in dt_io_thread_start()2163 if(_pipe(dtio->commandpipe, 4096, _O_BINARY) == -1) { in dt_io_thread_start()2194 ssize_t r = write(dtio->commandpipe[1], &cmd, sizeof(cmd)); in dt_io_thread_stop()2215 close(dtio->commandpipe[1]); in dt_io_thread_stop()[all …]
180 int commandpipe[2]; member