Initial commitv8.0

1 files changed, 173 insertions, 0 deletions

diff --git a/network/akgnet_server.cc b/network/akgnet_server.cc
new file mode 100644
index 0000000..8fcc5e0
--- /dev/null
+++ b/network/akgnet_server.cc
@@ -0,0 +1,173 @@
+/*
+* This file is part of rasdaman community.
+*
+* Rasdaman community is free software: you can redistribute it and/or modify
+* it under the terms of the GNU General Public License as published by
+* the Free Software Foundation, either version 3 of the License, or
+* (at your option) any later version.
+*
+* Rasdaman community is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+* GNU General Public License for more details.
+*
+* You should have received a copy of the GNU General Public License
+* along with rasdaman community.  If not, see <http://www.gnu.org/licenses/>.
+*
+* Copyright 2003, 2004, 2005, 2006, 2007, 2008, 2009 Peter Baumann /
+rasdaman GmbH.
+*
+* For more information please see <http://www.rasdaman.org>
+* or contact Peter Baumann via <baumann@rasdaman.com>.
+/
+/**
+ * SOURCE: akgnet_server.cc
+ *
+ * MODULE: akg network
+ * CLASS:  GenericServer, BlockingServer
+ *
+ * COMMENTS:
+ *
+ */
+
+#include "debug.hh"
+
+#include <akgnet_server.hh>
+
+//#include<iostream>
+
+
+akg::GenericServer::GenericServer() throw()
+  { 
+    listenPort = 0;
+    exitRequest = false;
+   }
+akg::GenericServer::~GenericServer() throw()
+  {
+   }
+      
+void akg::GenericServer::setListenPort(int x) throw()
+  {
+    listenPort = x;
+   }   
+int akg::GenericServer::getListenPort() throw()
+  {
+    return listenPort;
+   }   
+
+void akg::GenericServer::setTimeout(int sec,int milisec) throw()
+  { selector.setTimeout(sec,milisec);
+   }
+void akg::GenericServer::disableTimeout() throw()
+  { selector.disableTimeout();
+   }
+
+void akg::GenericServer::shouldExit() throw()
+  {
+    exitRequest = true;
+   }
+      
+    
+bool akg::GenericServer::initListenSocket(int port, bool nonblocking) throw()
+  {
+    if(listenSocket.open(port) == false) return false;
+    
+    if(nonblocking) listenSocket.setNonBlocking(true);
+    
+    selector.setRead(listenSocket());
+    
+    DBTALK("Listen socket="<<listenSocket());
+    return true;
+   }
+
+bool akg::GenericServer::connectNewClient(ServerSocket &s) throw()
+  {
+    if(s.acceptFrom(listenSocket)==false) return false;
+    
+    selector.setRead(s());
+    
+    return true;
+   }
+void akg::GenericServer::closeSocket(Socket &s) throw()
+  {
+    if(s.isOpen())
+     { selector.clearRead(s());
+       selector.clearWrite(s());
+       s.close();
+      }  
+   }
+
+
+//###########################
+
+akg::BlockingServer::BlockingServer() throw()
+  { 
+   }
+akg::BlockingServer::~BlockingServer() throw()
+  {
+   }
+   
+bool akg::BlockingServer::runServer() throw()
+{
+	ENTER( "akg::BlockingServer::runServer" );
+
+	if(listenPort == 0)
+	{
+		LEAVE( "akg::BlockingServer::runServer, listenPort=0, result=false" );
+		return false;
+	}
+
+	if(initListenSocket(listenPort,false)==false)
+	{
+		LEAVE( "akg::BlockingServer::runServer, Error: init socket failed for port " << listenPort << ", result=false" );
+		return false;
+	}
+
+	while(exitRequest == false)
+	{ 
+		int rasp = selector();
+		TALK( "rasp=" << rasp );	
+		if(rasp>0)
+		{
+			if(serverSocket.isOpen())
+	     		{
+				TALK( "socket is open." );
+				if(selector.isRead(serverSocket()))
+				{
+					TALK( "socket is readable, executing request." );
+					executeRequest(serverSocket);
+					TALK( "closing socket." );
+					closeSocket(serverSocket);
+					TALK( "socket closed." );
+				}	
+	      		}
+			else if(selector.isRead(listenSocket())) 
+			{
+				TALK( "socket not open, but readable (???). connecting new client." );
+				connectNewClient(serverSocket);
+				TALK( "after client connect." );
+				// we don't care why it could fail
+			}
+			else
+			{
+				TALK( "no read socket - should never have reached this point." );
+			}
+		}
+	   
+		if(rasp == 0)      
+		{
+			TALK( "exec timeout" );
+			executeTimeout();
+		}
+
+		if(rasp<0)
+		{
+			TALK( "Internal connect error: bad selector." );
+		}
+	}
+	
+	LEAVE( "akg::BlockingServer::runServer, result=true" );
+	return true;     
+}
+       
+