/*****************************************************************************
Copyright © 2006, 2007, The Board of Trustees of the University of Illinois.
All Rights Reserved.
National Center for Data Mining (NCDM)
University of Illinois at Chicago
http://www.ncdm.uic.edu/
This library is free software; you can redistribute it and/or modify it
under the terms of the GNU Lesser General Public License as published by
the Free Software Foundation; either version 2.1 of the License, or (at
your option) any later version.
This library 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 Lesser
General Public License for more details.
You should have received a copy of the GNU Lesser General Public License
along with this library; if not, write to the Free Software Foundation, Inc.,
59 Temple Place, Suite 330, Boston, MA 02111-1307, USA.
*****************************************************************************/
/*****************************************************************************
written by
Yunhong Gu [gu@lac.uic.edu], last updated 02/23/2007
*****************************************************************************/
#ifndef __STORE_H__
#define __STORE_H__
#include <routing.h>
#include <gmp.h>
#include <udt.h>
#include <log.h>
#include <conf.h>
#include <index.h>
#include <kb.h>
#include <spe.h>
namespace cb
{
class Server
{
public:
Server(const string& ip);
~Server();
public:
int init(char* ip = NULL, int port = 0);
int run();
private:
struct Param1
{
Server* s;
char ip[64];
int port;
int32_t id;
CCBMsg* msg;
};
struct Param2
{
Server* s;
string fn; // filename
UDTSOCKET u;
int m; // file access mode
string ip; // client IP
int p; // client UDT port
};
struct Param3
{
Server* s;
string fn; // filename
string q; // query
UDTSOCKET u;
string ip; // client IP
int p; // client UDT port
};
struct Param4
{
Server* s;
UDTSOCKET u;
string ip;
int port;
SPE spe;
int p;
};
static void* process(void* s);
static void* processEx(void* p);
static void* fileHandler(void* p);
static void* SQLHandler(void* p);
static void* SPEHandler(void* p);
private:
void updateOutLink();
void updateInLink();
int initLocalFile();
private:
CRouting m_Router;
CGMP m_GMP;
CIndex m_LocalFile;
CIndex m_RemoteFile;
string m_strLocalHost;
int m_iLocalPort;
static const int m_iKeySpace = 16;
string m_strHomeDir;
CAccessLog m_AccessLog;
CPerfLog m_PerfLog;
SECTORParam m_SysConfig;
KnowledgeBase m_KBase;
};
}; //namespace
#endif