9 reader(read_handle, 1024)
22 signal_flush_required.emit();
23 sys_close(read_handle);
24 sys_close(write_handle);
27 void Pipe::set_block(bool b)
29 mode = (mode&~M_NONBLOCK);
31 mode = (mode|M_NONBLOCK);
33 sys_set_blocking(read_handle, b);
34 sys_set_blocking(write_handle, b);
37 unsigned Pipe::do_write(const char *buf, unsigned size)
42 return sys_write(write_handle, buf, size);
45 unsigned Pipe::do_read(char *buf, unsigned size)
50 unsigned ret = reader.read(buf, size);
57 const Handle &Pipe::get_handle(Mode m)
64 throw invalid_argument("Pipe::get_handle");