source/net/streamserversocket.cpp

   1 #include "platform_api.h"
   2 #include "streamserversocket.h"
   3 #include <msp/core/refptr.h>
   4 #include <msp/core/systemerror.h>
   5 #include <msp/io/handle_private.h>
   6 #include <msp/strings/format.h>
   7 #include "sockaddr_private.h"
   8 #include "socket_private.h"
   9 #include "streamsocket.h"
  10
  11 using namespace std;
  12
  13 namespace Msp {
  14 namespace Net {
  15
  16 StreamServerSocket::StreamServerSocket(Family af, int proto):
  17         ServerSocket(af, SOCK_STREAM, proto)
  18 { }
  19
  20 void StreamServerSocket::listen(const SockAddr &addr, unsigned backlog)
  21 {
  22         if(listening)
  23                 throw bad_socket_state("already listening");
  24
  25         bind(addr);
  26
  27         int err = ::listen(priv->handle, backlog);
  28         if(err==-1)
  29                 throw system_error("listen");
  30
  31         set_socket_events(S_ACCEPT);
  32
  33         listening = true;
  34 }
  35
  36 StreamSocket *StreamServerSocket::accept()
  37 {
  38         if(!listening)
  39                 throw bad_socket_state("not listening");
  40
  41         SockAddr::SysAddr sa;
  42         Private new_p;
  43         new_p.handle = check_sys_error(::accept(priv->handle, reinterpret_cast<sockaddr *>(&sa.addr), &sa.size), "accept");
  44
  45         RefPtr<SockAddr> paddr = SockAddr::new_from_sys(sa);
  46         return new StreamSocket(new_p, *paddr);
  47 }
  48
  49 } // namespace Net
  50 } // namespace Msp