thread.cpp.svn-base

sigmadesign smp8623 gui source code ,bingo

#include <stdio.h>       /* standard I/O routines                     */
#include <pthread.h>     /* pthread functions and data structures     */
#include <stdlib.h>      /* rand() and srand() functions              */
#include <unistd.h>
#include <string>
#include <signal.h>
#include <iostream>
#include <vector>
using std::cout;
using std::endl;
#include "log.h"
#include "common.h"
#include "tpool.h"
#include "servers.h"

context_t ctxt;

void exit_server()
{
	if(ctxt.conf->using_rc)
    	pthread_join(ctxt.rcthread, NULL);

	printf("exiting server\n");
	 int ret = pthread_join(ctxt.mngthread, NULL);

	ret = pthread_join(ctxt.phpthread, NULL);

	if(ctxt.conf->using_pms)
	{
	  	pthread_join(ctxt.pmsthread, NULL);
	  	if(ctxt.conf->second_interface)
	  		pthread_join(ctxt.pmsthread2, NULL);
	}

	ret = pthread_join(ctxt.histhread, NULL);

	ret = pthread_join(ctxt.clientthread, NULL);

	if(ctxt.pool != NULL){
		delete ctxt.pool;
		ctxt.pool = NULL;
	}

	if(ctxt.pool_tcp != NULL){
		delete ctxt.pool_tcp;
		ctxt.pool_tcp = NULL;
	}
	logger(2, "====================|| Server Close ||====================\n");

	if(ctxt.log != NULL)
	{
		delete ctxt.log;
		ctxt.log = NULL;
	}

	if(ctxt.conf != NULL)
	{
		delete ctxt.conf;
		ctxt.conf = NULL;
	}
}

static void sigtermhandler(int n)
{
	logger(FATAL, "Signal %d", n);
	logger(FATAL, "Signal %d", n);
	logger(FATAL, "Signal %d", n);
	ctxt.shutdown = 1;
	exit_server();

//	exit (0);
}

static void sigtermhandlerlog(int)
{
	std::cout<<"sig HUP handeled\n";
	ctxt.log->rotate(LOG_STDERR, ctxt.conf->log_file.c_str());
	ctxt.db_pool.shrink();
}

void poll_rcs()
{
	int rcs = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP);
	if(rcs == -1){
		logger(ERROR, "Can't create socket for broadcast\n");

		return;
	}

	int brodacast = 1;

	setsockopt(rcs, SOL_SOCKET, SO_BROADCAST, &brodacast, sizeof(int));

	struct sockaddr_in isa;

	isa.sin_family = AF_INET;
	isa.sin_port = htons(ctxt.conf->rc_port);
	inet_aton(ctxt.conf->rc_broadcast.c_str(), &isa.sin_addr);

	std::ostringstream message;

	message.fill('0');
	message << "POLL:"<<std::setw(8)<< std::hex << std::uppercase << time(NULL)<<"*";

	CRC(message);

	sendto(rcs, message.str().c_str(), message.str().length(), 0, (sockaddr *) &isa, sizeof(isa));

	shutdown(rcs, SHUT_RDWR);
	close(rcs);

	std::ostringstream event;

	event << "Стартиране на BMS сървър...";
	write_event(2, event);
}

void work(void*)
{
	sleep(1);
	logger(INFO, "%d", rand());
}

/* like any C program, program's execution begins in main */
extern void check_in(std::string& req);
extern void new_card(std::string&, int);
int
main()
{
    ctxt.conf = new conf_t();
    if(ctxt.conf == NULL)
    	return EXIT_FAILURE;

    ctxt.conf->read_conf();

    ctxt.log = new log_t(LOG_STDERR, ctxt.conf->log_file.c_str());
    if(ctxt.log == NULL)
    	return EXIT_FAILURE;

    ctxt.pool = new tpool_t(300, 3000);
    if(ctxt.pool == NULL)
    	return EXIT_FAILURE;

    ctxt.pool_tcp = new tpool_t(10,20);
    if(ctxt.pool_tcp == NULL)
    	return EXIT_FAILURE;

    logger(INFO, "====================|| Server Start ||====================\n");

 //   {
    	logger(INFO, "Starting DB repair\n");
    	BEGIN_DB()
 //   		mysqlpp::StoreQueryResult res = qr.store("REPAIR TABLE AccessControlLog , CurrencyRate , DoorLockEvent , DoorLockLog , Emp , Genre , GenreLang , InfoText , Internet , InternetOnLine , InternetPay , Lang , LangSub , Message , Movie , MovieLang , MovieLog , MovieOfficalRentLog , MoviePay , MovieSubLang , Music , MusicGenre , MusicGenreLang , OfficialOperationLog , Page , PageMenu , PlayLists , PlayListsDet , RadioChannel , RoomService , RoomServiceCell , RoomServiceMenu , RoomServiceRow , RoomStatus , RoomTZoneLog , RoomVolumeScheme , RoomWS , ServerEventLog , ServerEventType , SystemInfo , Weather , WeatherLang , WeatherPointData , WeatherPointLang , WeatherType , WeatherTypeLang");

  //  		for (size_t i = 0; i < res.num_rows(); ++i) {
    //			if(strcmp(res[i][3], "OK"))
    	//			logger(ERROR, "Error in table %s: %s\n", res[i][0].c_str(), res[i][3].c_str());

    		//}

    		mysqlpp::StoreQueryResult resrooms = qr.store("SELECT RoomID, IP_RC FROM Room ORDER BY RoomID asc");

    		for (size_t i = 0; i < resrooms.num_rows(); ++i) {
    			ctxt.rooms.insert(make_pair(string(resrooms[i][1].c_str()), new room_status_t(atoi(resrooms[i][0]))));
    		}

    		mysqlpp::StoreQueryResult rks = qr.store("SELECT BMS_WSID, BMS_WSIP FROM BMS_WS ORDER BY BMS_WSID asc");

    		for (size_t i = 0; i < rks.num_rows(); ++i) {
    		    ctxt.ks.insert(make_pair(string(rks[i][1].c_str()), (int)rks[i][0]));
    		}

    	END_DB()
    	logger(INFO, "Finished DB repair\n");
 //   }

    if(ctxt.conf->using_rc){
    	if(pthread_create(&ctxt.rcthread, NULL, rc_server, NULL) != 0){
    		logger(ERROR, "Can not create rc server thread\n");

    		return EXIT_FAILURE;
    	}
    }

    if(pthread_create(&ctxt.mngthread, NULL, mng_server, NULL) != 0){
        logger(ERROR, "Can not create mng server thread\n");

        return EXIT_FAILURE;
     }

    if(pthread_create(&ctxt.phpthread, NULL, php_server, NULL) != 0){
        logger(ERROR, "Can not create php server thread\n");

        return EXIT_FAILURE;
     }

    if(ctxt.conf->using_pms){
    	if(pthread_create(&ctxt.pmsthread, NULL, pms_server, NULL) != 0){
    		logger(ERROR, "Can not create pms server thread\n");

    		return EXIT_FAILURE;
    	}

    	if(ctxt.conf->second_interface)
    	{
    		if(pthread_create(&ctxt.pmsthread2, NULL, pms_server_2, NULL) != 0){
				logger(ERROR, "Can not create pms server thread\n");

				return EXIT_FAILURE;
			}
    	}
    }

    if(pthread_create(&ctxt.histhread, NULL, his_server, NULL) != 0){
        logger(ERROR, "Can not create his server thread\n");

        return EXIT_FAILURE;
     }

    if(pthread_create(&ctxt.clientthread, NULL, client_server, NULL) != 0){
        logger(ERROR, "Can not create his server thread\n");

        return EXIT_FAILURE;
    }

    //========= Catch terminate signals: ================
	// terminate requests:
	signal(SIGTERM, sigtermhandler); // kill
	signal(SIGHUP, sigtermhandlerlog);  // kill -HUP
	//signal(SIGTERM, sigtermhandler); //term closed

	signal(SIGINT, sigtermhandler);  // Interrupt from keyboard

	signal(SIGQUIT, sigtermhandler); // Quit from keyboard
	// fatal errors:
	signal(SIGBUS, sigtermhandler);  // bus error
	signal(SIGSEGV, sigtermhandler); // segfault
	signal(SIGILL, sigtermhandler);  // illegal instruction
	signal(SIGFPE, sigtermhandler);  // floating point exc.
	signal(SIGABRT, sigtermhandler); // abort()

 //   exit_server();
	poll_rcs();
	while(!ctxt.shutdown)
	{
		pause();
	}

    return 0;
}