#include <pipe.hpp>
Definition at line 29 of file pipe.hpp.
◆ Pipe()
Pipe::Pipe |
( |
int |
port_to_use | ) |
|
Definition at line 109 of file pipe.cpp.
113 WORD wVersionRequested = MAKEWORD(2, 0);
114 if (WSAStartup( wVersionRequested, &wsaData ))
122 m_p->m_socket = socket(AF_INET, SOCK_STREAM, 0);
123 if (
m_p->m_socket < 0)
126 unsigned long one = 1;
127 if (setsockopt(
m_p->m_socket, SOL_SOCKET, SO_REUSEADDR, (
char*)
128 &one,
sizeof(one)) < 0)
132 struct sockaddr_in add;
133 add.sin_family = AF_INET;
134 add.sin_port = htons(port_to_use);
135 add.sin_addr.s_addr = INADDR_ANY;
136 struct sockaddr *addr = (
struct sockaddr *) &add;
138 if (bind(
m_p->m_socket, addr,
sizeof(
struct sockaddr_in)))
141 if (listen(
m_p->m_socket, 3) < 0)
146 tmpadd = (unsigned) inet_addr(
"127.0.0.1");
148 memcpy(&add.sin_addr.s_addr, &tmpadd,
sizeof(
struct in_addr));
152 m_p->m_fd[1] = socket(AF_INET, SOCK_STREAM, 0);
153 if (
m_p->m_fd[1] < 0)
156 m_p->nonblock(
m_p->m_fd[1]);
158 if (connect(
m_p->m_fd[1], addr,
sizeof(*addr)) < 0)
161 if (WSAGetLastError() != WSAEWOULDBLOCK)
164 if (errno != EINPROGRESS)
170 struct sockaddr caddr;
172 int caddr_len =
sizeof(caddr);
174 socklen_t caddr_len =
sizeof(caddr);
176 m_p->m_fd[0] = accept(
m_p->m_socket, &caddr, &caddr_len);
177 if (
m_p->m_fd[0] < 0)
183 FD_SET(
m_p->m_fd[1], &write_set);
184 int r = select(
m_p->m_fd[1]+1, 0, &write_set, 0, 0);
188 m_p->close(
m_p->m_socket);
197 assert(
m_p->m_fd[0] >= 0);
198 assert(
m_p->m_fd[1] >= 0);
References m_p.
◆ ~Pipe()
◆ read_fd()
int & Pipe::read_fd |
( |
| ) |
const |
◆ write_fd()
int & Pipe::write_fd |
( |
| ) |
const |
◆ m_p
boost::scoped_ptr<Rep> metaproxy_1::Pipe::m_p |
|
private |
The documentation for this class was generated from the following files: