Prepare for assimilating msphttp

[libs/net.git] / source / net / streamserversocket.cpp

diff --git a/source/net/streamserversocket.cpp b/source/net/streamserversocket.cpp
new file mode 100644 (file)
index 0000000..bbf91bc
--- /dev/null
+++ b/source/net/streamserversocket.cpp
@@ -0,0 +1,51 @@
+#include <cerrno>
+#include <msp/core/refptr.h>
+#include <msp/core/systemerror.h>
+#include <msp/io/handle_private.h>
+#include <msp/strings/format.h>
+#include "sockaddr_private.h"
+#include "socket_private.h"
+#include "streamserversocket.h"
+#include "streamsocket.h"
+
+using namespace std;
+
+namespace Msp {
+namespace Net {
+
+StreamServerSocket::StreamServerSocket(Family af, int proto):
+       ServerSocket(af, SOCK_STREAM, proto),
+       listening(false)
+{ }
+
+void StreamServerSocket::listen(const SockAddr &addr, unsigned backlog)
+{
+       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);
+
+       listening = true;
+}
+
+StreamSocket *StreamServerSocket::accept()
+{
+       if(!listening)
+               throw bad_socket_state("not listening");
+
+       SockAddr::SysAddr sa;
+       Private new_p;
+       new_p.handle = ::accept(priv->handle, reinterpret_cast<sockaddr *>(&sa.addr), &sa.size);
+
+       RefPtr<SockAddr> paddr = SockAddr::new_from_sys(sa);
+       return new StreamSocket(new_p, *paddr);
+}
+
+} // namespace Net
+} // namespace Msp