Lines Matching refs:m_s
32 , m_s(s)
55 m_s = s;
62 socket_t s = m_s;
63 m_s = INVALID_SOCKET;
70 assert(m_s == INVALID_SOCKET);
71 m_s = socket(AF_INET, nType, 0);
72 CheckAndHandleError("socket", m_s);
79 if (m_s != INVALID_SOCKET)
82 CancelIo((HANDLE) m_s);
83 CheckAndHandleError_int("closesocket", closesocket(m_s));
85 CheckAndHandleError_int("close", close(m_s));
87 m_s = INVALID_SOCKET;
118 assert(m_s != INVALID_SOCKET);
120 CheckAndHandleError_int("bind", bind(m_s, const_cast<sockaddr *>(psa), saLen));
125 assert(m_s != INVALID_SOCKET);
126 CheckAndHandleError_int("listen", listen(m_s, backlog));
157 assert(m_s != INVALID_SOCKET);
158 int result = connect(m_s, const_cast<sockaddr*>(psa), saLen);
167 assert(m_s != INVALID_SOCKET);
168 socket_t s = accept(m_s, psa, psaLen);
178 assert(m_s != INVALID_SOCKET);
179 CheckAndHandleError_int("getsockname", getsockname(m_s, psa, psaLen));
184 assert(m_s != INVALID_SOCKET);
185 CheckAndHandleError_int("getpeername", getpeername(m_s, psa, psaLen));
190 assert(m_s != INVALID_SOCKET);
191 int result = send(m_s, (const char *)buf, UnsignedMin(INT_MAX, bufLen), flags);
198 assert(m_s != INVALID_SOCKET);
199 int result = recv(m_s, (char *)buf, UnsignedMin(INT_MAX, bufLen), flags);
206 assert(m_s != INVALID_SOCKET);
207 int result = shutdown(m_s, how);
213 assert(m_s != INVALID_SOCKET);
215 CheckAndHandleError_int("ioctlsocket", ioctlsocket(m_s, cmd, argp));
217 CheckAndHandleError_int("ioctl", ioctl(m_s, cmd, argp));
225 FD_SET(m_s, &fds);
228 ready = select((int)m_s+1, NULL, &fds, NULL, NULL);
232 ready = select((int)m_s+1, NULL, &fds, NULL, &timeoutCopy);
242 FD_SET(m_s, &fds);
245 ready = select((int)m_s+1, &fds, NULL, NULL, NULL);
249 ready = select((int)m_s+1, &fds, NULL, NULL, &timeoutCopy);
307 throw Err(m_s, operation, err);
313 : m_s(s), m_resultPending(false), m_eofReceived(false)
316 m_s.CheckAndHandleError("CreateEvent", m_event.HandleValid());
324 CancelIo((HANDLE) m_s.GetSocket());
335 if (WSARecv(m_s, &wsabuf, 1, &m_lastResult, &flags, &m_overlapped, NULL) == 0)
345 m_s.CheckAndHandleError_int("WSARecv", SOCKET_ERROR);
370 if (WSAGetOverlappedResult(m_s, &m_overlapped, &m_lastResult, false, &flags))
380 m_s.CheckAndHandleError("WSAGetOverlappedResult", FALSE);
394 : m_s(s), m_resultPending(false), m_lastResult(0)
397 m_s.CheckAndHandleError("CreateEvent", m_event.HandleValid());
406 CancelIo((HANDLE) m_s.GetSocket());
416 if (WSASend(m_s, &wsabuf, 1, &written, 0, &m_overlapped, NULL) == 0)
424 m_s.CheckAndHandleError_int("WSASend", SOCKET_ERROR);
433 m_s.ShutDown(SD_SEND);
434 m_s.CheckAndHandleError("ResetEvent", ResetEvent(m_event));
435 m_s.CheckAndHandleError_int("WSAEventSelect", WSAEventSelect(m_s, m_event, FD_CLOSE));
444 m_s.CheckAndHandleError_int("WSAEnumNetworkEvents", WSAEnumNetworkEvents(m_s, m_event, &events));
446 throw Socket::Err(m_s, "WSAEnumNetworkEvents (FD_CLOSE not present)", E_FAIL);
448 throw Socket::Err(m_s, "FD_CLOSE (via WSAEnumNetworkEvents)", events.iErrorCode[FD_CLOSE_BIT]);
467 BOOL result = WSAGetOverlappedResult(m_s, &m_overlapped, &m_lastResult, false, &flags);
468 m_s.CheckAndHandleError("WSAGetOverlappedResult", result);
479 : m_s(s), m_lastResult(0), m_eofReceived(false)
486 container.AddReadFd(m_s, CallStack("SocketReceiver::GetWaitObjects()", &callStack));
491 m_lastResult = m_s.Receive(buf, bufLen);
503 : m_s(s), m_lastResult(0)
509 m_lastResult = m_s.Send(buf, bufLen);
514 m_s.ShutDown(SD_SEND);
524 container.AddWriteFd(m_s, CallStack("SocketSender::GetWaitObjects()", &callStack));