diff options
Diffstat (limited to 'server/rasserver_main.cc')
| -rw-r--r-- | server/rasserver_main.cc | 360 |
1 files changed, 360 insertions, 0 deletions
diff --git a/server/rasserver_main.cc b/server/rasserver_main.cc new file mode 100644 index 0000000..adaaa8c --- /dev/null +++ b/server/rasserver_main.cc @@ -0,0 +1,360 @@ +/* +* 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>. +*/ +/************************************************************* + * + * + * PURPOSE: + * + * + * COMMENTS: + * + ************************************************************/ + +using namespace std; + +#ifndef RMANVERSION +#error "Please specify RMANVERSION variable!" +#endif + +#ifndef COMPDATE +#error "Please specify the COMPDATE variable!" +/* +COMPDATE=`date +"%d.%m.%Y %H:%M:%S"` + +and -DCOMPDATE="\"$(COMPDATE)\"" when compiling +*/ +#endif + + +#ifdef EARLY_TEMPLATE +#define __EXECUTABLE__ +#ifdef __GNUG__ +#include "template_inst.hh" +#endif +#endif + +#include <iostream> +#include <netdb.h> +#include <sys/stat.h> +#include <unistd.h> +#include <string> + +#include "globals.hh" // DEFAULT_PORT +#include "raslib/rmdebug.hh" +#include "servercomm/httpserver.hh" +#include "storagemgr/sstoragelayout.hh" +#include <signal.h> + +RMINITGLOBALS('C'); + +#include "rasserver_config.hh" +#include "rnprotocol/rnpserver.hh" + +// from some unknown location the debug-srv.hh guard seems to be defined already, so get rid of it -- PB 2005-jan-10 +#undef DEBUG_HH +#define DEBUG_MAIN debug_main +#include "debug-srv.hh" + + +bool initialization(); + +extern int globalOptimizationLevel = 4; +extern unsigned long maxTransferBufferSize = 4000000; +extern char* dbSchema = 0; +extern int noTimeOut = 0; + +// here the id string for connecting to the RDBMS is stored (used by rel* modules). +// FIXME: bad hack -- PB 2003-oct-12 +char globalConnectId[256]; +int globalHTTPPort; +// do we allow for User-Defined Functions? (aka rasql routines) +bool udfEnabled = true; + +// drop client after 5 minutes of no alive signal +// can be changed via cmd line parameter +unsigned long clientTimeOut = CLIENT_TIMEOUT; + +// server management every 2 minutes +unsigned long managementInterval = 120; + +const char* rasmgrHost = 0; +int rasmgrPort = DEFAULT_PORT; +const char* serverName = 0; +int serverListenPort = 0; + +int main ( int argc, char** argv ) +{ + SET_OUTPUT( true ); // enable debug output, if compiled so + ENTER( "rasserver.main()" ); + + //print startup text (this line will still go into forking rasmgr's log!) + cout << "Spawned rasserver v" << RMANVERSION / 1000. << " on base DBMS " << BASEDBSTRING << " -- generated on " << COMPDATE << "." << endl; + + if(configuration.parseCommandLine(argc, argv) == false) + { + RMInit::logOut << "Error: cannot parse command line." << endl; + LEAVE( "rasserver.main(): Error parsing command line." ); + return -1; + } + + RMInit::logOut << "rasserver: rasdaman server v" << RMANVERSION / 1000. << " on base DBMS " << BASEDBSTRING << " -- generated on " << COMPDATE << "." << endl; + std::cout << " Copyright 2003, 2004, 2005, 2006, 2007, 2008, 2009 Peter Baumann rasdaman GmbH." << std::endl + << "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. \n" + "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. \n\n"; + + RMInit::logOut << "This program contains software which is in the public domain:" << endl; + RMInit::logOut << " zlib 1.1.4 (C) 1995-1998 Jean-loup Gailly and Mark Adler" << endl; + RMInit::logOut << " libpng 1.2.1 (C) 2002 Glenn Randers-Pehrson" << endl; + RMInit::logOut << " libtiff 3.8.0 (C) 1988-1997 Sam Leffler, (C) 1991-1997 Silicon Graphics, Inc." << endl; + RMInit::logOut << " libjpeg 6b (C) 1991-1998, Thomas G. Lane." << endl; + RMInit::logOut << " openssl 0.96c (C) 1998-2002 The OpenSSL Project, (C) 1995-1998 Eric A. Young, Tim J. Hudson" << endl; + + if(initialization() == false ) + { + RMInit::logOut << "Error during initialization. aborted." << endl; + LEAVE( "rasserver.main(): Error during initialization." ); + return -1; + } + + // + // body rasserver + // + + RMInit::logOut << "Installing signal handler for ignoring broken pipe signal..." << flush; + signal( SIGPIPE, SIG_IGN ); + RMInit::logOut << "ok" << endl; + + int returnCode = 0; + ServerComm* server = NULL; + + try + { + TALK( "selecting server type..." ); + + if(configuration.isRnpServer()) + { + TALK( "startRnpServer()..." ); + startRnpServer(); + TALK( "startRnpServer() done." ); + } + else if(configuration.isHttpServer()) + { + TALK( "initializing HttpServer()..." ); + server = new HttpServer( clientTimeOut, managementInterval, serverListenPort, (char*)rasmgrHost, rasmgrPort,(char*)serverName); + } + else + { + TALK( "initializing ServerComm() (ie: RPC)..." ); + server = new ServerComm( clientTimeOut, managementInterval, serverListenPort, (char*)rasmgrHost, rasmgrPort,(char*)serverName); + } + + // in case of HTTP or RPC server: launch previously generated object + if(server) + { + TALK( "server->startRpcServer()..." ); + server->startRpcServer(); + TALK( "server->startRpcServer() done." ); + } + } + catch ( r_Error& errorObj ) + { + TALK( "Error: encountered " << errorObj.get_errorno() << ": " << errorObj.what() ); + RMInit::logOut << "Error: encountered " << errorObj.get_errorno() << ": " << errorObj.what() << endl; +// we never write to stdout (= rasmgr log file), so we don't need this -- PB 2003-nov-24 +#if 0 + if(!configuration.isLogToStdOut()) + { + RMInit::logOut << "Error: encountered " << errorObj.get_errorno() << ": " << errorObj.what() << endl; + } +#endif // 0 + returnCode = -1; + } + catch(...) + { + TALK( "rasserver: general exception" ); + RMInit::logOut << "rasserver: general exception" << endl; +// we never write to stdout (= rasmgr log file), so we don't need this -- PB 2003-nov-24 +#if 0 + if(!configuration.isLogToStdOut()) + { + RMInit::logOut << "rasserver: general exception" << endl; + } +#endif + returnCode = -1; + } + + if(server) + delete server; + server = NULL; + + if( dbSchema ) + free( dbSchema ); + dbSchema = NULL; + + LEAVE( "rasserver.main(): -> " << returnCode ); + return returnCode; +} + +bool initialization() +{ + serverName = configuration.getServerName(); + accessControl.setServerName(serverName); + + serverListenPort = globalHTTPPort = configuration.getListenPort(); + + RMInit::logOut<<"Server "<< serverName << " of type "; + + if(configuration.isRnpServer()) + RMInit::logOut << "RNP, listening on port " << serverListenPort << flush; + else if(configuration.isHttpServer()) + RMInit::logOut << "HTTP, listening on port " << serverListenPort << flush; + else + RMInit::logOut << "RPC, registered with prognum 0x" << hex <<serverListenPort << dec << flush; + + // globalConnectId = configuration.getDbConnectionID(); + strcpy(globalConnectId,configuration.getDbConnectionID()); + RMInit::logOut << ", connecting to " << BASEDBSTRING << " as '" << globalConnectId << "'." << endl; + +// we never write to stdout (= rasmgr log file), so we don't need this -- PB 2003-nov-24 +#if 0 + if(!configuration.isLogToStdOut()) + { + RMInit::logOut<<"Server "<< serverName << " of type "; + if(configuration.isRnpServer()) + RMInit::logOut << "RNP, listening on port " << serverListenPort << endl; + else if(configuration.isHttpServer()) + RMInit::logOut << "HTTP, listening on port " << serverListenPort << endl; + else + RMInit::logOut << "RPC, registered with prognum 0x" << hex <<serverListenPort << dec << endl; + } +#endif // 0 + + rasmgrHost = configuration.getRasmgrHost(); + rasmgrPort = configuration.getRasmgrPort(); + + RMInit::logOut << "Verifying rasmgr host name: " << rasmgrHost << "..."; +// we don't write to stdout (=rasmgr log), so no need to duplicate -- PB 2003-nov-24 +#if 0 + if(!configuration.isLogToStdOut()) + RMInit::logOut << "Verifying RasMGR host name: " << rasmgrHost << "..."; +#endif // 0 + if(!gethostbyname(rasmgrHost)) + { + RMInit::logOut << "failed" << endl; + if(!configuration.isLogToStdOut()) RMInit::logOut << "failed" << endl; + return false; + } + RMInit::logOut << "ok" << endl; +// we don't write to stdout (=rasmgr log), so no need to duplicate -- PB 2003-nov-24 +#if 0 + if(!configuration.isLogToStdOut()) + RMInit::logOut << " ok" << endl; +#endif // 0 + + globalOptimizationLevel = configuration.getDefaultOptimizationLevel(); + + maxTransferBufferSize = configuration.getMaxTransferBufferSize(); + + clientTimeOut = configuration.getTimeout(); + if(clientTimeOut == 0) + noTimeOut = 1; + + managementInterval = clientTimeOut/4; + +#ifdef RMANDEBUG + //tilesize + StorageLayout::DefaultTileSize = configuration.getDefaultTileSize(); + RMInit::logOut << "Tile size set to : " << StorageLayout::DefaultTileSize << endl; + + //pctmin + StorageLayout::DefaultMinimalTileSize = configuration.getDefaultPCTMin(); + RMInit::logOut << "PCTMin set to : " << StorageLayout::DefaultMinimalTileSize << endl; + + //pctmax + StorageLayout::DefaultPCTMax = configuration.getDefaultPCTMax(); + RMInit::logOut << "PCTMax set to : " << StorageLayout::DefaultPCTMax << endl; + + //indexsize + StorageLayout::DefaultIndexSize = configuration.getDefaultIndexSize(); + RMInit::logOut << "IndexSize set to : " << StorageLayout::DefaultIndexSize << endl; + + RManDebug = configuration.getDebugLevel(); + RMInit::logOut<<"Debug level: " << RManDebug << endl; + + try + { + StorageLayout::DefaultTileConfiguration = r_Minterval(configuration.getDefaultTileConfig()); + } + catch(r_Error& err) + { + RMInit::logOut << "Error converting " << configuration.getDefaultTileConfig() << " to r_Minterval" << endl; + RMInit::logOut << "Error " << err.get_errorno() << " : " << err.what() << endl; + if(!configuration.isLogToStdOut()) + { + RMInit::logOut << "Error converting " << configuration.getDefaultTileConfig() << " to r_Minterval" << endl; + RMInit::logOut << "Error " << err.get_errorno() << " : " << err.what() << endl; + } + return false; + } + RMInit::logOut << "Default Tile Conf: " << StorageLayout::DefaultTileConfiguration << endl; + + // Tiling + r_Tiling_Scheme tmpTS=get_tiling_scheme_from_name(configuration.getTilingScheme()); + + if(tmpTS != r_Tiling_Scheme_NUMBER) + StorageLayout::DefaultTilingScheme = tmpTS; + + if((tmpTS != r_NoTiling) && (tmpTS != r_RegularTiling)) + { + RMInit::logOut << "Error: unsupported tiling strategy: " << configuration.getTilingScheme() << endl; + if(configuration.isLogToStdOut()) + { + RMInit::logOut << "Error: unsupported tiling strategy: " << configuration.getTilingScheme() << endl; + } + return false; + } + + //retiling enabled only if tiling scheme is regular tiling + RMInit::tiling = (tmpTS == r_RegularTiling); + RMInit::logOut << "Default Tiling : " << StorageLayout::DefaultTilingScheme << endl; + + // Index + r_Index_Type tmpIT = get_index_type_from_name(configuration.getIndexType()); + if ( tmpIT != r_Index_Type_NUMBER) + StorageLayout::DefaultIndexType = tmpIT; + RMInit::logOut << "Default Index : " << StorageLayout::DefaultIndexType << endl; + + //use tilecontainer + RMInit::useTileContainer = configuration.useTileContainer(); + RMInit::logOut << "Use Tile Container: " << RMInit::useTileContainer << endl; +#endif + + return true; +} + |