service.cpp

语音接口～语音识别 & 从声音识别到对各种情报的查找/提供 资料请求～住所.姓名.电话号码等的识别接待 受订货业务～被定型化的受订货业务 预约业务～预约情况的向导和预约接

// Copyright (C) 2005 Open Source Telecom Corporation.
//  
// This program 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 2 of the License, or
// (at your option) any later version.
// 
// This program 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 this program; if not, write to the Free Software 
// Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.

#include "module.h"
#include <cc++/process.h>

namespace module {
using namespace ost;
using namespace std;

#ifdef  WIN32
#define KEYS    "/bayonne/tcpmon"
#else
#define KEYS    "/bayonne/module/tcpmon"
#endif

Service Service::tcp;
bool Service::active = false;

Service::Service() :
BayonneService(0, 0), Keydata(Bayonne::getKeypath(KEYS))
{
	static Keydata::Define defkeys[] = {
	{"interface", "127.0.0.1"},
	{"port", "5555"},
	{"secret", "pass"},
	{NULL, NULL}};

	load(defkeys);

#ifdef  WIN32
        const char *env = Process::getEnv("MODULECONFIG");

        if(env)
                loadFile(env, "tcpmon");
#else
	if(Bayonne::provision_system)
		load("/bayonne/provision/tcpmon");
	else if(Bayonne::provision_user)
	        load("~bayonne/tcpmon");
#endif

}

void Service::stopService(void)
{
	active = false;
	terminate();
}

void Service::run(void)
{
	InetAddress addr(getLast("interface"));
	tpport_t port = atoi(getLast("port"));
	TCPSocket tcp(addr, port);
	Session *session;

	active = true;
	slog.debug("tcpmon service started");

	for(;;)
	{
                if(tcp.isPendingConnection(30))
                {
                        session = new Session(tcp);
                        session->detach();
                }
		Thread::yield();
	}

	Thread::sync();
}

} // namespace