X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fsocket.cpp;h=7ff77417c88672b3b703430d65b2035b2d047e91;hb=65b029e8334d4dfc9a6161fc04740b03d56a8e2f;hp=150d8367948c7d0ed64a3c1547d2ae485ab089dc;hpb=1b2aabf076169e6d2049227188e464e95ac40514;p=libs%2Fnet.git

diff --git a/source/socket.cpp b/source/socket.cpp
index 150d836..7ff7741 100644
--- a/source/socket.cpp
+++ b/source/socket.cpp
@@ -1,17 +1,12 @@
-/* $Id$
-
-This file is part of libmspnet
-Copyright © 2008, 2010-2011  Mikkosoft Productions, Mikko Rasa
-Distributed under the LGPL
-*/
-
 #ifndef WIN32
 #include <errno.h>
 #include <fcntl.h>
 #include <sys/socket.h>
 #endif
 #include <iostream>
-#include <msp/strings/formatter.h>
+#include <msp/io/handle_private.h>
+#include <msp/strings/format.h>
+#include <msp/time/rawtime_private.h>
 #include <msp/time/units.h>
 #include "socket.h"
 
@@ -24,7 +19,7 @@ public:
 	WinSockHelper()
 	{
 		WSADATA wsa_data;
-		int err=WSAStartup(0x0002, &wsa_data);
+		int err = WSAStartup(0x0002, &wsa_data);
 		if(err)
 			std::cerr<<"Failed to initialize WinSock: "<<err<<'\n';
 	}
@@ -50,12 +45,14 @@ Socket::Socket(SocketHandle h, const SockAddr &paddr):
 	peer_addr(paddr.copy())
 {
 	sockaddr_storage sa;
-	socklen_t size=sizeof(sockaddr_storage);
+	socklen_t size = sizeof(sockaddr_storage);
 	getsockname(handle, reinterpret_cast<sockaddr *>(&sa), &size);
-	local_addr=SockAddr::create(sa);
+	local_addr = SockAddr::create(sa);
 
 #ifdef WIN32
-	event=CreateEvent(0, false, false, 0);
+	event = CreateEvent(0, false, false, 0);
+#else
+	*event = handle;
 #endif
 }
 
@@ -64,10 +61,12 @@ Socket::Socket(Family af, int type, int proto):
 	local_addr(0),
 	peer_addr(0)
 {
-	handle=socket(af, type, proto);
+	handle = socket(af, type, proto);
 
 #ifdef WIN32
-	event=CreateEvent(0, false, false, 0);
+	event = CreateEvent(0, false, false, 0);
+#else
+	*event = handle;
 #endif
 }
 
@@ -78,26 +77,22 @@ Socket::~Socket()
 
 void Socket::set_block(bool b)
 {
-	mode=(mode&~IO::M_NONBLOCK);
+	mode = (mode&~IO::M_NONBLOCK);
 	if(b)
-		mode=(mode|IO::M_NONBLOCK);
+		mode = (mode|IO::M_NONBLOCK);
 
 #ifdef WIN32
-	u_long flag=!b;
+	u_long flag = !b;
 	ioctlsocket(handle, FIONBIO, &flag);
 #else
-	int flags=fcntl(handle, F_GETFL);
+	int flags = fcntl(handle, F_GETFL);
 	fcntl(handle, F_SETFL, (flags&O_NONBLOCK)|(b?0:O_NONBLOCK));
 #endif
 }
 
-IO::Handle Socket::get_event_handle()
+const IO::Handle &Socket::get_event_handle()
 {
-#ifdef WIN32
 	return event;
-#else
-	return handle;
-#endif
 }
 
 
@@ -106,20 +101,16 @@ void Socket::bind(const SockAddr &addr)
 	check_state(false);
 
 	sockaddr_storage sa;
-	unsigned size=addr.fill_sockaddr(sa);
+	unsigned size = addr.fill_sockaddr(sa);
 
-	int err=::bind(handle, reinterpret_cast<sockaddr *>(&sa), size);
+	int err = ::bind(handle, reinterpret_cast<sockaddr *>(&sa), size);
 	if(err==-1)
 		throw SystemError("Unable to bind", errno);
 
 	delete local_addr;
-	local_addr=addr.copy();
+	local_addr = addr.copy();
 }
 
-/**
-Closes the socket.  Most operations on the socket will throw an exception after
-this.
-*/
 void Socket::close()
 {
 	if(handle==MSP_NET_INVALID_SOCKET_HANDLE)
@@ -134,21 +125,20 @@ void Socket::close()
 #else
 	::close(handle);
 #endif
-	handle=MSP_NET_INVALID_SOCKET_HANDLE;
-	connected=false;
+	handle = MSP_NET_INVALID_SOCKET_HANDLE;
+	connected = false;
 	signal_closed.emit();
 
 	delete local_addr;
-	local_addr=0;
+	local_addr = 0;
 	delete peer_addr;
-	peer_addr=0;
+	peer_addr = 0;
 }
 
 void Socket::set_timeout(const Time::TimeDelta &timeout)
 {
 #ifndef WIN32
-	timeval tv;
-	timeout.fill_timeval(tv);
+	timeval tv = Time::rawtime_to_timeval(timeout.raw());
 	set_option(SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(timeval));
 	set_option(SOL_SOCKET, SO_SNDTIMEO, &tv, sizeof(timeval));
 #else
@@ -205,7 +195,7 @@ unsigned Socket::do_write(const char *buf, unsigned size)
 	if(size==0)
 		return 0;
 
-	int ret=::send(handle, buf, size, 0);
+	int ret = ::send(handle, buf, size, 0);
 	if(ret<0)
 	{
 		if(errno==EAGAIN)
@@ -224,7 +214,7 @@ unsigned Socket::do_read(char *buf, unsigned size)
 	if(size==0)
 		return 0;
 
-	int ret=::recv(handle, buf, size, 0);
+	int ret = ::recv(handle, buf, size, 0);
 	if(ret<0)
 	{
 		if(errno==EAGAIN)
@@ -234,7 +224,7 @@ unsigned Socket::do_read(char *buf, unsigned size)
 	}
 	else if(ret==0 && !eof_flag)
 	{
-		eof_flag=true;
+		eof_flag = true;
 		signal_end_of_file.emit();
 		set_events(IO::P_NONE);
 	}