5 #include <msp/core/systemerror.h>
6 #include <msp/strings/formatter.h>
17 string name = format("\\\\.\\pipe\\%u.%p", GetCurrentProcessId(), this);
18 handle[0] = CreateNamedPipe(name.c_str(), PIPE_ACCESS_INBOUND|FILE_FLAG_OVERLAPPED, PIPE_TYPE_BYTE, 1, 1024, 1024, 0, 0);
19 if(handle[0]==INVALID_HANDLE_VALUE)
20 throw system_error("CreateNamedPipe");
22 handle[1] = CreateFile(name.c_str(), GENERIC_WRITE, 0, 0, OPEN_EXISTING, 0, 0);
23 if(handle[1]==INVALID_HANDLE_VALUE)
25 unsigned err = GetLastError();
26 CloseHandle(handle[0]);
27 throw system_error(format("CreateFile(%s)", name), err);
31 event = CreateEvent(0, true, false, 0);
33 buffer = new char[buf_size];
38 throw system_error("pipe");
53 signal_flush_required.emit();
55 CloseHandle(handle[0]);
56 CloseHandle(handle[1]);
64 void Pipe::set_block(bool b)
66 mode = (mode&~M_NONBLOCK);
68 mode = (mode|M_NONBLOCK);
71 int flags = fcntl(handle[0], F_GETFD);
72 fcntl(handle[0], F_SETFL, (flags&O_NONBLOCK)|(b?0:O_NONBLOCK));
73 flags = fcntl(handle[1], F_GETFD);
74 fcntl(handle[1], F_SETFL, (flags&O_NONBLOCK)|(b?0:O_NONBLOCK));
78 unsigned Pipe::do_write(const char *buf, unsigned size)
85 if(!WriteFile(handle[1], buf, size, &ret, 0))
86 throw system_error("WriteFile");
88 int ret = ::write(handle[1], buf, size);
94 throw system_error("write");
101 unsigned Pipe::do_read(char *buf, unsigned size)
107 // Initiate overlapped read if needed
113 if(!GetOverlappedResult(handle[0], overlapped, &ret, !buf_avail))
114 throw system_error("GetOverlappedResult");
123 unsigned ret = min(buf_avail, size);
124 memcpy(buf, buf_next, ret);
128 // Initiate another overlapped read in case someone is polling us
131 int ret = ::read(handle[0], buf, size);
137 throw system_error("read");
144 signal_end_of_file.emit();
150 Handle Pipe::get_event_handle()
153 if(!overlapped && !buf_avail)
155 overlapped = new OVERLAPPED;
156 memset(overlapped, 0, sizeof(OVERLAPPED));
157 overlapped->hEvent = event;
161 if(!ReadFile(handle[0], buffer, buf_size, &ret, overlapped))
163 unsigned err = GetLastError();
164 if(err!=ERROR_IO_PENDING)
165 throw system_error("ReadFile");