Lines Matching refs:Pipe
122 class Pipe { class
125 Pipe(int readFd, int writeFd) : m_readFd{readFd}, m_writeFd{writeFd} {} in Pipe() function in Pipe
126 Pipe(const Pipe &) = delete;
127 Pipe& operator=(const Pipe &) = delete;
128 Pipe& operator=(const Pipe &&) = delete;
130 Pipe(Pipe&& rval) noexcept { in Pipe() function in Pipe
136 ~Pipe() { in ~Pipe()
184 static tuple<Pipe, Pipe> createPipePair() { in createPipePair()
193 return make_tuple(Pipe(a[0], b[1]), Pipe(b[0], a[1])); in createPipePair()
210 Pipe p) in worker_fx()
278 Pipe make_worker(int num, int iterations, int worker_count, int payload_size, bool cs_pair) in make_worker()
280 auto pipe_pair = Pipe::createPipePair(); in make_worker()
295 void wait_all(vector<Pipe>& v) in wait_all()
302 void signal_all(vector<Pipe>& v) in signal_all()
311 vector<Pipe> pipes; in run_main()