demo.cpp

#include "demo.h"
#include <stdio.h>
#include "base/wshandller.h"


using namespace base;
using namespace std;

DemoSvr::DemoSvr()
{

}
DemoSvr::~DemoSvr()
{
}

void  DemoSvr::admin_test(void* para,int argc, char **argv, std::ostream& os)
{
	   DemoSvr* pSelf = (DemoSvr*)para;
	   if (argc < 2)
	   {
	     os<<"found invalid param"<<endl;
	     return;
	   }

	   os<<"test succefully:para count:"<<argc<<",para:";
	   for (int i = 0 ; i < argc;++i)
	   {
	     os<<argv[i]<<",";
	   }
       os<<endl;
}


void  DemoSvr::init_admin()
{
    ServerAdmin& as = getServerAdmin();
	AdminCmdInfo aa;
	aa.func_para = this;
	aa.desc = "usage:test_admin para1 para2";
	aa.func = DemoSvr::admin_test;
	as.addCommand("test_admin", aa);
}






void DemoSvr::init(const char *conf_file)throw(runtime_error)
{
		try
		{
				m_strConfigFile = conf_file;	
				Server::init(conf_file);
				m_confMgr.Init(conf_file);
				string logpath = m_confMgr["zeus\\Log\\Name"];
				unsigned int logsize = s2u(m_confMgr["zeus\\Log\\Size"]);
				unsigned int lognum = s2u(m_confMgr["zeus\\Log\\Num"]);
				unsigned int log_level = s2u(m_confMgr["zeus\\Log\\Level"]);
				m_pRollLog = new base::Logger(logpath.c_str(), logsize, lognum,Logger::DEBUG_LOG, true, false);
               	m_pRollLog->normal("system start success!");
                init_admin();          
							
		}
		catch (conf_load_error &ex) 
		{
				//m_pRollLog->error("DemoSvr::init: init fail : %s", (char*)(ex.what()));
				throw ex;
		}
		catch (conf_not_find& ex) 
		{
				//m_pRollLog->error("DemoSvr::init: conf_not_find: %s" ,(char*)(ex.what()));
				throw ex;
		}

}


void DemoSvr::connectionMade(Connection* pConn)
{
		m_pRollLog->debug("sproxy:connection made:%d,%s", pConn->fd(),(char*)(pConn->getIPStr().c_str()));

}
void DemoSvr::connectionLost(Connection* pConn)
{
		m_pRollLog->debug("sproxy:connection lost:%d,%s", pConn->fd(),(char*)(pConn->getIPStr().c_str()));
}


void DemoSvr::timeoutHandller(time_t now)
{
}



void DemoSvr::dataReceived(Connection* pConn,const char* data,unsigned int nLength)
{
		m_pRollLog->debug("DemoSvr::dataReceived:ip:%s,recv data len:%d",pConn->getIPStr().c_str(),nLength);
		if (pConn->isWebSocket())
		{
           //pConn->
		   cout<<"DemoSvr::dataReceived:websocket receive :"<<pConn->getPayLoadLen()<<"bytes,data:"<<pConn->getPayLoad()<<endl;
		   char bufOut[8*1024]={'\0'};
		   int nLenOut = 8*1024;
		   
		   WSHandller::packData(pConn->getPayLoad(), pConn->getPayLoadLen(), bufOut, nLenOut);
		   cout <<"rsponse:len:"<<nLenOut<<endl;
		   pConn->sendMessage(bufOut,nLenOut);
		}
}