2 #include <msp/core/refptr.h>
3 #include <msp/core/systemerror.h>
4 #include <msp/io/handle_private.h>
5 #include <msp/strings/format.h>
6 #include "sockaddr_private.h"
7 #include "socket_private.h"
8 #include "streamlistensocket.h"
9 #include "streamsocket.h"
16 StreamListenSocket::StreamListenSocket(Family af, int proto):
17 Socket(af, SOCK_STREAM, proto),
21 int StreamListenSocket::connect(const SockAddr &)
23 // XXX This function needs to go away
24 throw logic_error("Can't connect a listen socket");
27 void StreamListenSocket::listen(const SockAddr &addr, unsigned backlog)
31 int err = ::listen(priv->handle, backlog);
33 throw system_error("listen");
36 WSAEventSelect(priv->handle, *priv->event, FD_ACCEPT);
38 set_events(IO::P_INPUT);
43 StreamSocket *StreamListenSocket::accept()
46 throw bad_socket_state("not listening");
50 new_p.handle = ::accept(priv->handle, reinterpret_cast<sockaddr *>(&sa.addr), &sa.size);
52 RefPtr<SockAddr> paddr = SockAddr::from_sys(sa);
53 return new StreamSocket(new_p, *paddr);