Home
last modified time | relevance | path

Searched refs:pipe_fds_ (Results 1 – 2 of 2) sorted by relevance

/test/dittosuite/src/
Dmultiprocessing.cpp64 pipe_fds_.resize(instructions_.size()); in SetUpSingle()
66 if (pipe(pipe_fds_[i].data()) == -1) { in SetUpSingle()
93 close(pipe_fds_[p][1]); in SetUpSingle()
161 ssize_t chars_read = read(pipe_fds_[i][0], buffer.data(), buffer.size()); in CollectResults()
195 ssize_t chars_written = write(pipe_fds_[instruction_id_][1], &serialized.data()[chars_sent], in CollectResults()
203 close(pipe_fds_[instruction_id_][1]); in CollectResults()
/test/dittosuite/include/ditto/
Dmultiprocessing.h42 std::vector<std::array<int, 2>> pipe_fds_; variable