X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fsocket.cpp;h=f24bcbe7533d7c95a961e5c35bf10f996c16e7c8;hb=3103b110c863c19a56cc176a173cc30ddf13afec;hp=decdbeb9e2fd663c05a7e07819a30bdd0ca6e4bb;hpb=f59eded7c3e162bbdfc6db424c9badc730017698;p=libs%2Fnet.git diff --git a/source/socket.cpp b/source/socket.cpp index decdbeb..f24bcbe 100644 --- a/source/socket.cpp +++ b/source/socket.cpp @@ -43,6 +43,39 @@ WinSockHelper wsh; namespace Msp { namespace Net { +Socket::Socket(SocketHandle h, const SockAddr &paddr): + handle(h), + connected(true), + local_addr(0), + peer_addr(paddr.copy()) +{ + sockaddr sa; + socklen_t size=sizeof(sockaddr); + getsockname(handle, &sa, &size); + local_addr=SockAddr::create(sa); + +#ifdef WIN32 + event=CreateEvent(0, false, false, 0); +#endif +} + +Socket::Socket(Family af, int type, int proto): + connected(false), + local_addr(0), + peer_addr(0) +{ + handle=socket(af, type, proto); + +#ifdef WIN32 + event=CreateEvent(0, false, false, 0); +#endif +} + +Socket::~Socket() +{ + close(); +} + void Socket::set_block(bool b) { mode=(mode&~IO::M_NONBLOCK); @@ -77,14 +110,14 @@ void Socket::bind(const SockAddr &addr) int err=::bind(handle, &sa, size); if(err==-1) - throw Exception(format("Unable to bind: %s", strerror(errno))); + throw SystemError("Unable to bind", errno); delete local_addr; local_addr=addr.copy(); } /** -Closes the socket. Most operations on the socket will return an error after +Closes the socket. Most operations on the socket will throw an exception after this. */ void Socket::close() @@ -124,39 +157,6 @@ const SockAddr &Socket::get_peer_address() const return *peer_addr; } -Socket::~Socket() -{ - close(); -} - -Socket::Socket(SocketHandle h, const SockAddr &paddr): - handle(h), - connected(true), - local_addr(0), - peer_addr(paddr.copy()) -{ - sockaddr sa; - socklen_t size=sizeof(sockaddr); - getsockname(handle, &sa, &size); - local_addr=SockAddr::create(sa); - -#ifdef WIN32 - event=CreateEvent(0, false, false, 0); -#endif -} - -Socket::Socket(Family af, int type, int proto): - connected(false), - local_addr(0), - peer_addr(0) -{ - handle=socket(af, type, proto); - -#ifdef WIN32 - event=CreateEvent(0, false, false, 0); -#endif -} - void Socket::check_state(bool conn) const { if(handle==MSP_NET_INVALID_SOCKET_HANDLE) @@ -187,7 +187,7 @@ unsigned Socket::do_write(const char *buf, unsigned size) if(errno==EAGAIN) return 0; else - throw Exception(format("Writing to socket failed: %s", strerror(errno))); + throw SystemError("Writing to socket failed", errno); } return ret; @@ -206,7 +206,7 @@ unsigned Socket::do_read(char *buf, unsigned size) if(errno==EAGAIN) return 0; else - throw Exception(format("Reading from socket failed: %s", strerror(errno))); + throw SystemError("Reading from socket failed", errno); } else if(ret==0 && !eof_flag) {