X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fnet%2Fstreamserversocket.cpp;h=b91491dcdd542e034ef6c35e3e00379abe019f7c;hb=6625cf0e574406425c35d33110f8d99617e902df;hp=8039ec986155155196eb4360c62197468ddc7914;hpb=dd8b0e7471bb85d26cc63da2f0819ceeff30550f;p=libs%2Fnet.git diff --git a/source/net/streamserversocket.cpp b/source/net/streamserversocket.cpp index 8039ec9..b91491d 100644 --- a/source/net/streamserversocket.cpp +++ b/source/net/streamserversocket.cpp @@ -1,7 +1,4 @@ -#ifdef WIN32 -#include -#endif -#include +#include "platform_api.h" #include #include #include @@ -17,22 +14,21 @@ namespace Msp { namespace Net { StreamServerSocket::StreamServerSocket(Family af, int proto): - ServerSocket(af, SOCK_STREAM, proto), - listening(false) + ServerSocket(af, SOCK_STREAM, proto) { } void StreamServerSocket::listen(const SockAddr &addr, unsigned backlog) { + if(listening) + throw bad_socket_state("already listening"); + bind(addr); int err = ::listen(priv->handle, backlog); if(err==-1) throw system_error("listen"); -#ifdef WIN32 - WSAEventSelect(priv->handle, *priv->event, FD_ACCEPT); -#endif - set_events(IO::P_INPUT); + set_socket_events(S_ACCEPT); listening = true; } @@ -44,7 +40,7 @@ StreamSocket *StreamServerSocket::accept() SockAddr::SysAddr sa; Private new_p; - new_p.handle = ::accept(priv->handle, reinterpret_cast(&sa.addr), &sa.size); + new_p.handle = check_sys_error(::accept(priv->handle, reinterpret_cast(&sa.addr), &sa.size), "accept"); RefPtr paddr = SockAddr::new_from_sys(sa); return new StreamSocket(new_p, *paddr);