X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fstreamlistensocket.cpp;h=3b375bcafcadb54d0581b1cf6500b82a87ca1448;hb=bdd968802348fae7a7a407616cb3744e4877601a;hp=68580d7627672e7041e79f1a415d5c63d8c156eb;hpb=a81c41acd873cda7f40bca634782230d9e57dc4f;p=libs%2Fnet.git diff --git a/source/streamlistensocket.cpp b/source/streamlistensocket.cpp index 68580d7..3b375bc 100644 --- a/source/streamlistensocket.cpp +++ b/source/streamlistensocket.cpp @@ -1,9 +1,14 @@ #include #include -#include +#include +#include +#include +#include "socket_private.h" #include "streamlistensocket.h" #include "streamsocket.h" +using namespace std; + namespace Msp { namespace Net { @@ -14,19 +19,20 @@ StreamListenSocket::StreamListenSocket(Family af, int proto): int StreamListenSocket::connect(const SockAddr &) { - throw Exception("Can't connect a listen socket"); + // XXX This function needs to go away + throw logic_error("Can't connect a listen socket"); } void StreamListenSocket::listen(const SockAddr &addr, unsigned backlog) { bind(addr); - int err = ::listen(handle, backlog); + int err = ::listen(priv->handle, backlog); if(err==-1) - throw SystemError("Unable to listen", errno); + throw system_error("listen"); #ifdef WIN32 - WSAEventSelect(handle, event, FD_ACCEPT); + WSAEventSelect(priv->handle, *priv->event, FD_ACCEPT); #endif set_events(IO::P_INPUT); @@ -36,14 +42,15 @@ void StreamListenSocket::listen(const SockAddr &addr, unsigned backlog) StreamSocket *StreamListenSocket::accept() { if(!listening) - throw InvalidState("Socket is not listening"); + throw bad_socket_state("not listening"); sockaddr_storage sa; socklen_t size = sizeof(sockaddr_storage); - SocketHandle new_h = ::accept(handle, reinterpret_cast(&sa), &size); + Private new_p; + new_p.handle = ::accept(priv->handle, reinterpret_cast(&sa), &size); RefPtr paddr = SockAddr::create(sa); - return new StreamSocket(new_h, *paddr); + return new StreamSocket(new_p, *paddr); } } // namespace Net