Skip to content

U
uniset2
Commit 57922c6b authored by Pavel Vainerman's avatar Pavel Vainerman
Browse files
Options

(2.0): Удалил AlarmMessage,InfoMessage,InfoServer,TimerServer(подумать),…

(2.0): Удалил AlarmMessage,InfoMessage,InfoServer,TimerServer(подумать), ISRestorer,MessageInteface_xxx,SystemGuard т.к. активного распространения не получили (пока-что).
parent 6bb862b7
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 18 additions and 2424 deletions
IDL/Makefile.am
View file @ 57922c6b
......@@ -2,5 +2,5 @@
# This file is part of the UniSet library #
############################################################################
SUBDIRS = UniSetTypes Processes Services
SUBDIRS = UniSetTypes Processes
include $(top_builddir)/conf/common.mk
IDL/Services/DBServer_i.idl deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \author Pavel Vainerman
* \date $Date: 2005/11/01 21:44:53 $
* \version $Id: DBServer_i.idl,v 1.5 2005/11/01 21:44:53 vpashka Exp $
*/
// --------------------------------------------------------------------------
#ifndef DBServer_i_IDL_
#define DBServer_i_IDL_
// --------------------------------------------------------------------------
#include "../UniSetTypes/UniSetTypes_i.idl"
#include "../UniSetTypes/UniSetObject_i.idl"
// --------------------------------------------------------------------------
/*!
* \interface DBServer_i
* \brief Интерфейс сервера базы данных системы
*/
interface DBServer_i: UniSetObject_i
{
// исключения
exception DBError
{
string errmsg;
};
void query(in string query) raises(DBError);
string hostname();
string dbname();
};
#endif
\ No newline at end of file
IDL/Services/InfoServer_i.idl deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \author Pavel Vainerman
* \date $Date: 2005/01/28 20:27:06 $
* \version $Id: InfoServer_i.idl,v 1.4 2005/01/28 20:27:06 vitlav Exp $
*/
// --------------------------------------------------------------------------
#ifndef InfoServer_i_IDL_
#define InfoServer_i_IDL_
// --------------------------------------------------------------------------
#include "../UniSetTypes/UniSetTypes_i.idl"
#include "../UniSetTypes/UniSetObject_i.idl"
// --------------------------------------------------------------------------
/*!
* \interface InfoServer_i
* \brief Интерфейс к серверу сообщений
*/
interface InfoServer_i: UniSetObject_i
{
// исключения
exception MsgNotFound
{
UniSetTypes::MessageCode bad_code;
};
// исключения
exception MsgBadRange
{
};
/*! Заказ информации о приходе сообщения */
void ackMessage(in UniSetTypes::MessageCode mid, in UniSetTypes::ConsumerInfo ci,
in UniversalIO::UIOCommand cmd, in boolean acknotify ) raises(MsgNotFound);
/*! Заказ информации о приходе сообщений из диапазона */
void ackMessageRange(in UniSetTypes::MessageCode from, in UniSetTypes::MessageCode to,
in UniSetTypes::ConsumerInfo ci,
in UniversalIO::UIOCommand cmd, in boolean acknotify ) raises(MsgNotFound,MsgBadRange);
};
// --------------------------------------------------------------------------
#endif
IDL/Services/Makefile.am deleted 100644 → 0
View file @ 6bb862b7
############################################################################
# This file is part of the UniSet library #
############################################################################
# Каталоги для размещения генерируемых CC- и HH-файлов соответственно
CCDIR=$(top_builddir)/src/Services
HHDIR=$(top_builddir)/include
# Исходные файлы IDL
IDLFILES=TimerService_i.idl InfoServer_i.idl
include $(top_builddir)/conf/idl.mk
idl_include_HEADERS = *.idl
idl_includedir = $(datadir)/idl/@PACKAGE@/Services
IDL/Services/NetService_i.idl deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \author Pavel Vainerman
* \date $Date: 2005/01/28 20:27:06 $
* \version $Id: NetService_i.idl,v 1.4 2005/01/28 20:27:06 vitlav Exp $
*/
// --------------------------------------------------------------------------
#ifndef NetService_i_IDL_
#define BaseProcess_i_IDL_
// --------------------------------------------------------------------------
#include "../UniSetTypes/UniSetTypes_i.idl"
// --------------------------------------------------------------------------
/*!
* \interface NetService_i
*/
interface NetService_i
{
void registration( in BaseObjectName name, in Object ref );
void unregistration( in BaseObjectName name, in Object ref );
Object resolve(in BaseObjectName name);
Object resolveid( in BaseObjectId name);
};
#endif
\ No newline at end of file
IDL/Services/RepositoryAgent_i.idl deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \author Pavel Vainerman
* \date $Date: 2005/11/01 21:44:53 $
* \version $Id: RepositoryAgent_i.idl,v 1.5 2005/11/01 21:44:53 vpashka Exp $
*/
// --------------------------------------------------------------------------
#ifndef RepositoryAgent_i_IDL_
#define RepositoryAgent_i_IDL_
// --------------------------------------------------------------------------
#include "../UniSetTypes/UniSetObject_i.idl"
// --------------------------------------------------------------------------------------------------------------
/*!
* \interface RepositoryAgent_i
* \brief Интерфейс агента репозитория
* Агент репозитрория предназначен для получения доступа к объектам с удаленных узлов.
* Он запускается на каждом узле, и с других узлов через него можно получить доступ
* к процессам, датчикам и т.п на данном узле.
*/
interface RepositoryAgent_i: UniSetObject_i
{
// исключения
exception NameNotFound
{
string errmsg;
};
exception ResolveError
{
string errmsg;
};
// void registration( in BaseObjectName name, in Object ref );
// void unregistration( in BaseObjectName name, in Object ref );
// Object resolve(in BaseObjectName name) raises(NameNotFound, ResolveError);
Object resolveid( in UniSetTypes::ObjectId name) raises(NameNotFound, ResolveError);
};
#endif
\ No newline at end of file
IDL/Services/TimerService_i.idl deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \author Pavel Vainerman
* \date $Date: 2005/01/28 21:24:12 $
* \version $Id: TimerService_i.idl,v 1.1 2005/01/28 21:24:12 vitlav Exp $
*/
// --------------------------------------------------------------------------
#ifndef TimerService_i_IDL_
#define TimerService_i_IDL_
// --------------------------------------------------------------------------
#include "../UniSetTypes/UniSetTypes_i.idl"
#include "../UniSetTypes/UniSetObject_i.idl"
// --------------------------------------------------------------------------
/*!
* \interface TimerService_i
*/
interface TimerService_i: UniSetObject_i
{
/*! Превышения максимально возможного
* количества таймеров
*/
exception LimitTimers
{
long maxTimers;
};
/*! Таймер с таким id уже заказан
* (от данного заказчика)
*/
exception TimerAlreadyExist
{
};
/*! Задан интервал меньше
* минимально разрешённого
*/
exception TimeMSLowLimit
{
unsigned long lowLimitMS; // instead timeout_t
};
/*! Информация о таймере */
struct Timer
{
UniSetTypes::TimerId timerid;
unsigned long timeMS;
long ticks; // instead clock_t
short msgPriority;
};
/*! заказ таймера */
void askTimer( in Timer ti, in UniSetTypes::ConsumerInfo ci )
raises(LimitTimers, TimerAlreadyExist, TimeMSLowLimit);
// void setSysTime(...);
// void getSysTime(...);
};
#endif
\ No newline at end of file
TODO
View file @ 57922c6b
......@@ -34,6 +34,4 @@ Version 2.0
============
- отказаться от функций getState,setState,saveState,saveValue и оставить только getValue/setValue.
- (DBServer): сделать возможность задать для датчика в configure.xml dbignore="1". Видимо надо встроить это поле в SensorMessgage
- удалить AlarmMessage,InfoMessage,InfoServer,TimerServer(подумать),ISRestorer,MessageInteface_xxx,SystemGuard
т.к. активного распространения не получили (пока-что).
- написать документацию по ModbusSlave
Utilities/InfoServer/Makefile.am deleted 100644 → 0
View file @ 6bb862b7
############################################################################
# This file is part of the UniSet library #
############################################################################
bin_PROGRAMS = uniset-infoserver
uniset_infoserver_SOURCES = main.cc
uniset_infoserver_LDADD = $(top_builddir)/lib/libUniSet.la
uniset_infoserver_CPPFLAGS = -I$(top_builddir)/lib $(SIGC_CFLAGS)
include $(top_builddir)/conf/setting.mk
Utilities/InfoServer/main.cc deleted 100644 → 0
View file @ 6bb862b7
#include "Configuration.h"
#include "InfoServer.h"
#include "ISRestorer.h"
#include "ObjectsActivator.h"
#include "Debug.h"
// --------------------------------------------------------------------------
using namespace UniSetTypes;
using namespace std;
// --------------------------------------------------------------------------
static void short_usage()
{
cout << "Usage: uniset-infoserver --name ObjectId [--askfile filename]"
<< " [--confile configure.xml]\n";
}
// --------------------------------------------------------------------------
int main(int argc, char** argv)
{
try
{
if( argc>1 && !strcmp(argv[1],"--help") )
{
short_usage();
return 0;
}
uniset_init(argc,argv,"configure.xml");
ObjectId ID = conf->getInfoServer();
// определяем ID объекта
string name = conf->getArgParam("--name");
if( !name.empty() )
{
if( ID != UniSetTypes::DefaultObjectId )
{
unideb[Debug::WARN] << "(InfoServer::main): переопределяем ID заданнй в "
<< conf->getConfFileName() << endl;
}
ID = conf->oind->getIdByName(conf->getServicesSection()+"/"+name);
if( ID == UniSetTypes::DefaultObjectId )
{
cerr << "(InfoServer): идентификатор '" << name
<< "' не найден в конф. файле!"
<< " в секции " << conf->getServicesSection() << endl;
return 1;
}
}
else if( ID == UniSetTypes::DefaultObjectId )
{
cerr << "(DBServer::main): Не удалось определить ИДЕНТИФИКАТОР сервера" << endl;
short_usage();
return 1;
}
// определяем ask-файл
string askfile = conf->getArgParam("--askfile",conf->getConfFileName());
if( askfile.empty() )
{
InfoServer is(ID,new ISRestorer_XML(askfile));
ObjectsActivator act;
act.addObject(static_cast<class UniSetObject*>(&is));
act.run(false);
}
else
{
InfoServer is(ID);
ObjectsActivator act;
act.addObject(static_cast<class UniSetObject*>(&is));
act.run(false);
}
return 0;
}
catch(Exception& ex)
{
cerr << "(InfoServer::main): " << ex << endl;
}
catch(...)
{
cerr << "(InfoServer::main): catch ..." << endl;
}
return 1;
}
Utilities/Makefile.am
View file @ 57922c6b
......@@ -3,8 +3,7 @@
############################################################################
SUBDIRS = scripts Admin NullController SViewer-text \
InfoServer SMonit MBTester codegen SImitator
#MapSourceParser ClassGen
SMonit MBTester codegen SImitator
include $(top_builddir)/conf/common.mk
......
configure.ac
View file @ 57922c6b
......@@ -204,10 +204,8 @@ AC_CONFIG_FILES([Makefile
IDL/Makefile
IDL/UniSetTypes/Makefile
IDL/Processes/Makefile
IDL/Services/Makefile
src/Communications/Makefile
src/Communications/Modbus/Makefile
src/IOs/Makefile
src/Interfaces/Makefile
src/ObjectRepository/Makefile
src/Processes/Makefile
......
docs/DocPages/Concept.dox
View file @ 57922c6b
......@@ -76,8 +76,8 @@ UniSetTypes::Message::TheLastFieldOfTypeOfMessage.
...
<ObjectsMap idfromfile="0">
<nodes port="2809">
<item name="LocalhostNode" alias="" textname="Локальный узел" ip="127.0.0.1" infserver="InfoServer" dbserver=""/>
<item name="Node2" alias="" textname="Локальный узел" ip="127.0.0.1" infserver="InfoServer" dbserver=""/>
<item name="LocalhostNode" alias="" textname="Локальный узел" ip="127.0.0.1" dbserver=""/>
<item name="Node2" alias="" textname="Локальный узел" ip="127.0.0.1" dbserver=""/>
</nodes>
<sensors>
<item name="Input1_S" textname="Команда 1" node="" iotype="DI" priority="Medium" default="1" />
......@@ -91,10 +91,8 @@ UniSetTypes::Message::TheLastFieldOfTypeOfMessage.
<!-- ******************* Идентификаторы сервисов ***************** -->
<services name="Services">
<item name="InfoServer"/>
<item name="DBServer"/>
<item name="PrintServer"/>
<item name="TimeService"/>
</services>
<!-- ******************* Идентификаторы объектов ***************** -->
......@@ -134,8 +132,8 @@ UniSetTypes::Message::TheLastFieldOfTypeOfMessage.
...
<ObjectsMap idfromfile="1">
<nodes port="2809">
<item id="1000" name="LocalhostNode" alias="" textname="Локальный узел" ip="127.0.0.1" infserver="InfoServer" dbserver=""/>
<item id="1001" name="Node2" alias="" textname="Локальный узел" ip="127.0.0.1" infserver="InfoServer" dbserver=""/>
<item id="1000" name="LocalhostNode" alias="" textname="Локальный узел" ip="127.0.0.1" dbserver=""/>
<item id="1001" name="Node2" alias="" textname="Локальный узел" ip="127.0.0.1" dbserver=""/>
</nodes>
<sensors>
<item id="1" name="Input1_S" textname="Команда 1" node="" iotype="DI" priority="Medium" default="1" />
......@@ -149,10 +147,8 @@ UniSetTypes::Message::TheLastFieldOfTypeOfMessage.
<!-- ******************* Идентификаторы сервисов ***************** -->
<services name="Services">
<item id="500" name="InfoServer"/>
<item id="501" name="DBServer"/>
<item id="502" name="PrintServer"/>
<item id="503" name="TimeService"/>
</services>
<!-- ******************* Идентификаторы объектов ***************** -->
......
docs/DocPages/Configuration.dox
View file @ 57922c6b
......@@ -77,28 +77,19 @@ int main(int argc, char **argv)
</UniSet>
<Services section="Services">
<LocalTimerService name="TimerService1" MaxCountTimers="100" AskLifeTimeSEC="60"/>
<LocalInfoServer name="InfoServer1" dbrepeat="1">
<RouteList>
<!-- <consumer name="" node=""/> -->
</RouteList>
</LocalInfoServer>
<LocalDBServer name="DBServer1" dbnode="" dbname="Theatre" dbuser="dbadmin" dbpass="dbadmin">
<Tables></Tables>
</LocalDBServer>
</Services>
<!-- список узлов в сиситеме -->
<ListOfNodes>
<!--
Параметры:
infserver - id инфо-сервера на данном узле(если указать "", значит нет)
dbnode - id db-сервера на данном узле DB(если указать "", значит нет)
-->
<Node name="LocalhostNode" infserver="InfoServer1" dbserver="DBServer1"/>
<Node name="LocalhostNode" dbserver="DBServer1"/>
</ListOfNodes>
</UniSetTestConfiguration>
......
docs/DocPages/Services.dox
View file @ 57922c6b
......@@ -3,8 +3,6 @@
\page ServicesPage Сервисы
- \ref secDBServer
- \ref secInfoService
- \ref secTimerService
\section secDBServer Сервер БД
......
docs/DocPages/commonpage.dox
View file @ 57922c6b
......@@ -6,9 +6,7 @@
- \ref subIO
- Алгоритмы управления
- \ref UniSetGraphics
- \ref subInfoServer
- \ref UniDiag
- \ref subTimer
- \ref secSection2
- \ref subTransfer
......@@ -57,15 +55,6 @@
буферизацию данных на время недоступности других узлов.
\sa \ref secDBServer
\subsection subInfoServer Система оповещения
Некоторым алгоритмам требуются сообщать о том или ином событии оператору. Для этой цели служит InfoServer.
Идея заключается в следующем: Все объекты, которым необходимо послать информацию, работают с локальным зараннее известным
объектом InfoServer. Все сообщения посылаются ему. В его задачи входит переслать это сообщение объекту отображающему
информацию на экране, а также переслать сообщение на другие узлы(в случае необходимости). Помимо этого InfoServer пересылает
сообщения DBServer-у для сохранения их в БД. То что этот объект является локальным, гарантирует, что он будет
доступен...
\sa \ref secInfoServer
\subsection subIO Ввод/вывод
Процессы ввода/вывода строятся на основе классов IOController и IONotifyController.
\par IOController
......@@ -74,12 +63,6 @@
\par IONotifyController
Раширение IOController-а. Предоставляющее интерфейс для заказа уведомлений об изменении состояния датчиков.
\subsection subTimer Таймеры
В библиотеку включен компонент TimerService. Данный сервис реализует функции генератора переодический событий (таймеров).
TimeService предоставляет интерфейс для заказа уведомлений с заданной переодичностью.
\warning TimerService - НЕ является реализацией спецификации CORBA::TimerService.
\sa \ref secTimerService
\subsection UniSetGraphics Графический интерфейс пользователя
...
......
extensions/DBServer-MySQL/DBServer_MySQL.cc
View file @ 57922c6b
......@@ -134,40 +134,6 @@ void DBServer_MySQL::sysCommand( UniSetTypes::SystemMessage *sm )
}
//--------------------------------------------------------------------------------------------
void DBServer_MySQL::parse( UniSetTypes::DBMessage* dbm )
{
if( dbm->tblid == UniSetTypes::Message::Unused )
{
unideb[Debug::CRIT] << myname << "(dbmessage): не задан tblId...\n";
return;
}
ostringstream query;
switch( dbm->qtype )
{
case DBMessage::Query:
query << dbm->data;
break;
case DBMessage::Update:
query << "UPDATE " << tblName(dbm->tblid) << " SET " << dbm->data;
break;
case DBMessage::Insert:
query << "INSERT INTO " << tblName(dbm->tblid) << " VALUES (" << dbm->data << ")";
break;
}
if( !writeToBase(query.str()) )
{
unideb[Debug::CRIT] << myname << "(update): error: "<< db->error() << endl;
// if( dbm->qtype == DBMessage::Query )
// db->freeResult();
}
}
//--------------------------------------------------------------------------------------------
void DBServer_MySQL::parse( UniSetTypes::ConfirmMessage* cem )
{
try
......
extensions/DBServer-MySQL/DBServer_MySQL.h
View file @ 57922c6b
......@@ -153,7 +153,6 @@ class DBServer_MySQL:
// Функции обработки пришедших сообщений
virtual void parse( UniSetTypes::SensorMessage* sm );
virtual void parse( UniSetTypes::DBMessage* dbmsg );
virtual void parse( UniSetTypes::ConfirmMessage* cmsg );
bool writeToBase( const string& query );
......
extensions/DBServer-SQLite/DBServer_SQLite.h
View file @ 57922c6b
......@@ -153,7 +153,6 @@ class DBServer_SQLite:
// Функции обработки пришедших сообщений
virtual void parse( UniSetTypes::SensorMessage* sm );
virtual void parse( UniSetTypes::DBMessage* dbmsg );
virtual void parse( UniSetTypes::ConfirmMessage* cmsg );
bool writeToBase( const string& query );
......
extensions/include/SMInterface.h
View file @ 57922c6b
......@@ -30,11 +30,6 @@ class SMInterface
void askSensor( UniSetTypes::ObjectId id, UniversalIO::UIOCommand cmd,
UniSetTypes::ObjectId backid = UniSetTypes::DefaultObjectId );
inline bool alarm( UniSetTypes::AlarmMessage& msg, UniSetTypes::ObjectId messenger )
{
return ui->alarm(msg,messenger);
}
IOController_i::DSensorInfoSeq* getDigitalSensorsMap();
IOController_i::ASensorInfoSeq* getAnalogSensorsMap();
IONotifyController_i::ThresholdsListSeq* getThresholdsList();
......
include/Configuration.h
View file @ 57922c6b
......@@ -32,7 +32,6 @@
#include "UniSetTypes.h"
#include "ObjectIndex.h"
#include "IORFile.h"
#include "MessageInterface.h"
#include "Debug.h"
class SystemGuard;
......@@ -88,9 +87,7 @@ namespace UniSetTypes
std::string getRootDir(); /*!< Получение каталога, в котором находится выполняющаяся программа */
inline int getArgc(){ return _argc; }
inline const char* const* getArgv() const { return _argv; }
inline ObjectId getTimerService() const { return localTimerService; } /*!< получение идентификатора TimerServic-а */
inline ObjectId getDBServer() const { return localDBServer; } /*!< получение идентификатора DBServer-а */
inline ObjectId getInfoServer() const { return localInfoServer; } /*!< получение идентификатора InfoServer-а */
inline ObjectId getLocalNode() const { return localNode; } /*!< получение идентификатора локального узла */
inline std::string getLocalNodeName() const { return localNodeName; } /*!< получение название локального узла */
inline const std::string getNSName() const { return NSName; }
......@@ -159,9 +156,6 @@ namespace UniSetTypes
return lnodes.end();
}
/*! интерфейс к карте сообщений */
MessageInterface* mi;
/*! интерфейс к карте объектов */
ObjectIndex* oind;
......@@ -223,9 +217,7 @@ namespace UniSetTypes
static xmlNode* xmlServicesSec;
static xmlNode* xmlNodesSec;
ObjectId localTimerService;
ObjectId localDBServer;
ObjectId localInfoServer;
ObjectId localNode;
std::string localNodeName;
......
include/DBServer.h
View file @ 57922c6b
......@@ -42,7 +42,7 @@
Сервис является системным, поэтому его идентификатор можно получить при помощи
UniSetTypes::Configuration::getDBServer() объекта UniSetTypes::conf.
Реализацию см. \ref page_DBServer_MySQL
Реализацию см. \ref page_DBServer_MySQL и \ref page_DBServer_SQLite
*/
/*! Прототип реализации сервиса ведения БД */
......@@ -61,9 +61,6 @@ class DBServer:
// Функции обработки пришедших сообщений
virtual void parse( UniSetTypes::SensorMessage* sm ){};
virtual void parse( UniSetTypes::DBMessage* dbmsg ){};
virtual void parse( UniSetTypes::InfoMessage* imsg ){};
virtual void parse( UniSetTypes::AlarmMessage* amsg ){};
virtual void parse( UniSetTypes::ConfirmMessage* cmsg ){};
virtual bool activateObject();
......
include/ISRestorer.h deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \brief Интерфейс к объекту сохраняющему список заказчиков и сообщений для InfoServer-а
* \author Pavel Vainerman
*/
// --------------------------------------------------------------------------
#ifndef ISRestorer_H_
#define ISRestorer_H_
// ------------------------------------------------------------------------------------------
#include <string>
#include "UniXML.h"
#include "InfoServer.h"
#include "Restorer.h"
// ------------------------------------------------------------------------------------------
/*!
Это абстрактный интерфейс. В чистом виде не используется.
*/
class ISRestorer
{
public:
ISRestorer();
virtual ~ISRestorer();
virtual void read(InfoServer* is, const std::string fname="")=0;
virtual void dump(InfoServer* is, const UniSetTypes::MessageCode code,
const InfoServer::ConsumerList& lst)=0;
protected:
// добавление списка заказчиков
void addlist( InfoServer* is, const UniSetTypes::MessageCode code,
InfoServer::ConsumerList& lst );
};
// ------------------------------------------------------------------------------------------
#if 0
/*!
* \brief Реализация сохранения списка заказчиков в xml.
* \author Pavel Vainerman
*
Реализует сохранение списка заказчиков в xml-файле.
\sa ISRestorer
*/
class ISRestorer_XML:
public ISRestorer,
public Restorer_XML
{
public:
ISRestorer_XML(const std::string fname, bool createIfNotFound=false );
// ISRestorer_XML( UniXML& xml );
virtual ~ISRestorer_XML();
virtual void dump(InfoServer* is, const UniSetTypes::MessageCode code,
const InfoServer::ConsumerList& lst);
virtual void read(InfoServer* is, const std::string fname="");
virtual void read(InfoServer* is, UniXML& xml );
void setFileName(const std::string& file);
inline std::string getFileName(){ return fname; }
ISRestorer_XML();
protected:
virtual void read_list(UniXML& xml, xmlNode* node, InfoServer* is);
};
// ------------------------------------------------------------------------------------------
#endif
/*!
* \brief Реализация сохранения списка заказчиков в xml(работа с файлом проекта)
* \author Pavel Vainerman
*
Реализует сохранение списка заказчиков в xml-файле (версия для работы с файлом проекта).
\sa ISRestorer
*/
class ISRestorer_XML:
public ISRestorer,
public Restorer_XML
{
public:
ISRestorer_XML( const std::string fname );
// ISRestorer_XML( UniXML& xml );
virtual ~ISRestorer_XML();
virtual void dump(InfoServer* is, const UniSetTypes::MessageCode code,
const InfoServer::ConsumerList& lst);
virtual void read(InfoServer* is, const std::string fname="");
virtual void read(InfoServer* is, UniXML& xml );
void setFileName(const std::string& file);
inline std::string getFileName(){ return fname; }
protected:
void read_list(UniXML& xml, xmlNode* node, InfoServer* is);
void create_new_file(const std::string& fname);
xmlNode* bind_node(UniXML& xml, xmlNode* root, const std::string& nodename, const std::string nm="");
xmlNode* rebind_node(UniXML& xml, xmlNode* root, const std::string& nodename, const std::string nm="");
void init( std::string fname );
std::string fname;
UniXML uxml;
};
// ------------------------------------------------------------------------------------------
#endif
include/InfoServer.h deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \author Pavel Vainerman
*/
// --------------------------------------------------------------------------
#ifndef InfoServer_H_
#define InfoServer_H_
//---------------------------------------------------------------------------
#include <map>
#include <list>
#include "MessageType.h"
#include "UniSetObject.h"
#include "InfoServer_i.hh"
//---------------------------------------------------------------------------
class ISRestorer;
//---------------------------------------------------------------------------
/*!
\page ServicesPage
\section secInfoServer Сервис сообщений
\subsection subIS_common Общие сведения
В его задачи входит обработка всех сообщений для оператора.
При приходе сообщения он производит следующие действия:
- переправляет сообщение в БД (\ref secDBServer)
- рассылает сообщение на все узлы, если оно помечено как broadcast.
- рассылает сообщение всем занесённым в RouteList(см. конф.файл).
- обрабатывает сообщение специфичным для каждого проекта образом (т.е. вызывает виртуальную
функцию InfoServer::processing() )
\subsection subIS_idea Сценарий работы
На узле, где ведётся БД запускается один экземпляр сервиса. Клиенты могут получить доступ, несколькими способами:
- через NameService
- при помощи UniversalInterface::send()
\par
Сервис является системным, поэтому его идентификатор можно получить при помощи
UniSetTypes::Configuration::getInfoServer() объекта UniSetTypes::conf.
\subsection subIS_interface Интерфейс
InfoServer позволяет заказывать уведомелние о приходе тех или иных сообщений,
а также подтверждения(квитирования). Можно производить заказ сообщения по коду
\code
InfoServer::ackMessage(UniSetTypes::MessageCode msgid, const UniSetTypes::ConsumerInfo& ci,
UniversalIO::UIOCommand cmd, CORBA::Boolean acknotify);
\endcode
или сразу из диапазона кодов
\code
InfoServer::ackMessageRange(UniSetTypes::MessageCode from, UniSetTypes::MessageCode to,
const UniSetTypes::ConsumerInfo& ci,
UniversalIO::UIOCommand cmd, CORBA::Boolean acknotify);
\endcode
Реализацию см. \ref InfoServer
*/
/*!
* \class InfoServer
* \brief Интерфейс для вывода информации
*/
class InfoServer:
public UniSetObject,
public POA_InfoServer_i
{
public:
InfoServer( UniSetTypes::ObjectId id=UniSetTypes::DefaultObjectId, ISRestorer* d=0 );
virtual ~InfoServer();
virtual UniSetTypes::ObjectType getType(){ return UniSetTypes::getObjectType("InfoServer"); }
// реализация IDL интерфейса
/*! заказ уведомления о приходе сообщения */
virtual void ackMessage(UniSetTypes::MessageCode msgid, const UniSetTypes::ConsumerInfo& ci,
UniversalIO::UIOCommand cmd, CORBA::Boolean acknotify);
/*! заказ уведомления о приходе сообщения из диапазона */
virtual void ackMessageRange(UniSetTypes::MessageCode from, UniSetTypes::MessageCode to,
const UniSetTypes::ConsumerInfo& ci,
UniversalIO::UIOCommand cmd, CORBA::Boolean acknotify);
/*! информация о потребителе (заказчике) */
struct ConsumerInfoExt:
public UniSetTypes::ConsumerInfo
{
ConsumerInfoExt( UniSetTypes::ConsumerInfo ci,
UniSetObject_i_ptr ref=0):
ConsumerInfo(ci),ref(ref){}
UniSetObject_i_ptr ref;
CORBA::Boolean ask;
};
/*! Список потребителей */
typedef std::list<ConsumerInfoExt> ConsumerList;
/*! массив пар идентификатор->список потребителей */
typedef std::map<UniSetTypes::MessageCode,ConsumerList> AskMap;
protected:
// Функции обработки пришедших сообщений
virtual void processingMessage( UniSetTypes::VoidMessage *msg );
/*! Функция обработки UniSetTypes::AlarmMessage.
Переопределяется в кокретном проекте, если требуется специфичная обработка. */
virtual void processing(UniSetTypes::AlarmMessage &amsg){};
/*! Функция обработки UniSetTypes::InfoMessage.
Переопределяется в кокретном проекте, если требуется специфичная обработка. */
virtual void processing(UniSetTypes::InfoMessage &imsg){};
/*! Функция обработки UniSetTypes::AckMessage.
Переопределяется в кокретном проекте, если требуется специфичная обработка. */
virtual void processing(UniSetTypes::ConfirmMessage &cmsg){};
/*! Предварительная обработка сообщения. Пересылка на другие узлы и
сохранение в базе.
*/
void preprocessing( UniSetTypes::TransportMessage& tmsg, bool broadcast );
void preprocessingConfirm( UniSetTypes::ConfirmMessage& am, bool broadcast );
virtual bool activateObject();
/*! сохранение списка заказчиков
По умолчанию делает dump, если объявлен dumper.
*/
virtual void dumpOrdersList(UniSetTypes::MessageCode mid, const ConsumerList& lst);
/*! чтение dump-файла */
virtual void readDump();
//! посылка информации об приходе сообщения
template<class TMessage>
void event(UniSetTypes::MessageCode key, TMessage& msg, CORBA::Boolean askn);
//----------------------
//! посылка информации об изменении состояния датчика
template <class TMessage>
void send(ConsumerList& lst, TMessage& msg, CORBA::Boolean acknotify);
bool addConsumer(ConsumerList& lst, const UniSetTypes::ConsumerInfo& cons, CORBA::Boolean acknotify); //!< добавить потребителя сообщения
bool removeConsumer(ConsumerList& lst, const UniSetTypes::ConsumerInfo& cons, CORBA::Boolean acknotify); //!< удалить потребителя сообщения
//! обработка заказа
void ask(AskMap& askLst, UniSetTypes::MessageCode key,
const UniSetTypes::ConsumerInfo& cons, UniversalIO::UIOCommand cmd,
CORBA::Boolean acknotify);
/*! указатель на объект реализующий дамп списка заказчиков */
ISRestorer* restorer;
private:
friend class ISRestorer;
bool dbrepeat; /*!< флаг пересылки сообщений DBServer-у */
AskMap askList; /*!< список потребителей */
/*! замок для блокирования совместного доступа к cписку потребителей */
UniSetTypes::uniset_mutex askMutex;
std::list<UniSetTypes::ConsumerInfo> routeList;
};
//---------------------------------------------------------------------------
#endif
//---------------------------------------------------------------------------
include/MessageInterface.h deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \brief Класс работы с сообщениями
* \author Pavel Vainerman
*
* Получение сообщения по id
*/
// --------------------------------------------------------------------------
#ifndef __MESSAGEINTERFACE_H__
#define __MESSAGEINTERFACE_H__
// --------------------------------------------------------------------------
#include <string>
#include "UniSetTypes.h"
// --------------------------------------------------------------------------
class MessageInterface
{
public:
virtual ~MessageInterface(){}
virtual std::string getMessage( UniSetTypes::MessageCode code )=0;
virtual bool isExist(UniSetTypes::MessageCode code)=0;
virtual UniSetTypes::MessageCode getCode( const std::string& msg ){ return UniSetTypes::DefaultMessageCode; }
virtual UniSetTypes::MessageCode getCodeByIdName( const std::string& name ){ return UniSetTypes::DefaultMessageCode; }
virtual std::ostream& printMessagesMap(std::ostream& os)=0;
};
// --------------------------------------------------------------------------
#endif
include/MessageInterface_XML.h deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \brief Реализация интерфейса работы с сообщениями на основе XML
* \author Pavel Vainerman
*/
// --------------------------------------------------------------------------
#ifndef __MESSAGEINTERFACE_XML_H__
#define __MESSAGEINTERFACE_XML_H__
// --------------------------------------------------------------------------
#include <vector>
#include "UniXML.h"
#include "MessageInterface.h"
// --------------------------------------------------------------------------
class MessageInterface_XML:
public MessageInterface
{
public:
MessageInterface_XML(const std::string confile="", int msize=200);
MessageInterface_XML(UniXML& xml, int msize=200);
virtual ~MessageInterface_XML();
virtual std::string getMessage( UniSetTypes::MessageCode code );
virtual bool isExist(UniSetTypes::MessageCode code);
virtual UniSetTypes::MessageCode getCode( const std::string& msg );
virtual UniSetTypes::MessageCode getCodeByIdName( const std::string& name );
virtual std::ostream& printMessagesMap(std::ostream& os);
friend std::ostream& operator<<(std::ostream& os, MessageInterface_XML& mi );
protected:
void read( UniXML& xml );
std::vector<UniSetTypes::MessageInfo> msgmap;
};
// --------------------------------------------------------------------------
#endif
include/MessageInterface_idXML.h deleted 100644 → 0
View file @ 6bb862b7
/*! \file
* \brief Класс работы с сообщениями
* \author Pavel Vainerman
*/
/**************************************************************************/
#ifndef MessageInterface_idXML_H_
#define MessageInterface_idXML_H_
// -----------------------------------------------------------------------------------------
#include <map>
#include <string>
#include "UniSetTypes.h"
#include "MessageInterface.h"
#include "UniXML.h"
// -----------------------------------------------------------------------------------------
class MessageInterface_idXML:
public MessageInterface
{
public:
MessageInterface_idXML( const std::string xmlfile );
MessageInterface_idXML( UniXML& xml );
virtual ~MessageInterface_idXML();
virtual std::string getMessage( UniSetTypes::MessageCode code );
virtual bool isExist( UniSetTypes::MessageCode code );
virtual UniSetTypes::MessageCode getCode( const std::string& msg );
virtual UniSetTypes::MessageCode getCodeByIdName( const std::string& name );
virtual std::ostream& printMessagesMap(std::ostream& os);
friend std::ostream& operator<<(std::ostream& os, MessageInterface_idXML& mi );
protected:
void build( UniXML& xml );
private:
typedef std::map<UniSetTypes::MessageCode, UniSetTypes::MessageInfo> MapMessageKey;
MapMessageKey mmk;
};
// -----------------------------------------------------------------------------------------
#endif
include/MessageType.h
View file @ 57922c6b
......@@ -37,14 +37,11 @@ namespace UniSetTypes
public:
enum TypeOfMessage
{
Unused, // Сообщение не содержит информации
Unused, // Сообщение не содержит информации
SensorInfo,
SysCommand, // Сообщение содержит системную команду
Confirm, // Сообщение содержит подтверждение
Info, // Сообщения содержит информацию для оператора (DEPRECATED)
Timer, // Сообщения о срабатывании таймера
Alarm, // Аварийное сообщение (DEPRECATED)
DataBase, // (DEPRECATED)
Timer, // Сообщения о срабатывании таймера
TheLastFieldOfTypeOfMessage // Обязательно оставьте последним
};
......@@ -172,150 +169,6 @@ namespace UniSetTypes
long data[2];
};
/*! Информационное собщение оператору (DEPRECATED) */
class InfoMessage : public Message
{
public:
enum Character{
Normal,
Warning
};
InfoMessage();
InfoMessage(ObjectId id, const std::string str, ObjectId node = conf->getLocalNode(),
Character ch = InfoMessage::Normal,
Priority priority = Message::Medium, ObjectId consumer=UniSetTypes::DefaultObjectId);
InfoMessage(ObjectId id, MessageCode icode, ObjectId node = conf->getLocalNode(),
Character ch = InfoMessage::Normal,
Priority priority = Message::Medium, ObjectId consumer=UniSetTypes::DefaultObjectId);
InfoMessage(const VoidMessage *msg);
inline TransportMessage transport_msg() const
{
return transport(*this);
}
ObjectId id; /*!< от кого */
MessageCode infocode; /*!< код сообщения */
Character character; /*!< характер */
bool broadcast; /*!< флаг рассылки на другие узлы */
/*!
признак, что сообщение является пересланным.
(т.е. в БД второй раз сохранять не надо, пересылать
второй раз тоже не надо).
*/
bool route;
// т.к. размер транспортных сообщений ограничен, то
// мы можем высчитать максимальную длину текстового сообщения
// считаем размер текстового сообщения по формуле
// размерТраснпортного - РазмерБазового-суммаВсехВспомПолейДляДанногоСообщения-1
// всё это конечно не очень хорошо, но пока так.
// static const int size_of_info_message = sizeof(UniSetTypes::RawDataOfTransportMessage)-sizeof(Message)-sizeof(ObjectId)-sizeof(MessageCode)-sizeof(Character)-2*sizeof(bool)-1;
// пока делаем размер постоянным
static const unsigned int size_of_info_message = 55;
char message[size_of_info_message]; /*!< сообщение */
};
/*! Собщение об аварии (DEPRECATED) */
class AlarmMessage : public Message
{
public:
enum Character{
Normal,
Attention,
Warning,
Alarm
};
AlarmMessage();
AlarmMessage(ObjectId id, const std::string str, ObjectId node = conf->getLocalNode(),
Character ch = AlarmMessage::Alarm,
Priority prior = Message::Medium, ObjectId cons=UniSetTypes::DefaultObjectId);
AlarmMessage(ObjectId id, const std::string str, MessageCode ccode,
ObjectId node = conf->getLocalNode(),
Character ch = AlarmMessage::Alarm,
Priority prior = Message::Medium, ObjectId cons=UniSetTypes::DefaultObjectId);
AlarmMessage(ObjectId id, MessageCode acode, MessageCode ccode,
ObjectId node=conf->getLocalNode(),
Character ch=AlarmMessage::Alarm,
Priority prior=Message::Medium,
ObjectId cons=UniSetTypes::DefaultObjectId);
AlarmMessage(const VoidMessage *msg);
inline TransportMessage transport_msg() const
{
return transport(*this);
}
ObjectId id; /*!< от кого */
MessageCode alarmcode; /*!< код сообщения */
MessageCode causecode; /*!< код причины */
Character character; /*!< характер */
bool broadcast; /*!< флаг рассылки на другие узлы */
/*!
признак, что сообщение является пересланным.
(т.е. в БД второй раз сохранять не надо, пересылать
второй раз тоже не надо).
*/
bool route;
// т.к. размер транспортных сообщений ограничен, то
// мы можем высчитать максимальную длину текстового сообщения
// считаем размер текстового сообщения по формуле
// размерТраснпортного - РазмерБазового-суммаВсехВспомПолейДляДанногоСообщения-1
// всё это конечно не очень хорошо, но пока так.
// sizeof(UniSetTypes::RawDataOfTransportMessage)-sizeof(Message)-sizeof(ObjectId)-2*sizeof(MessageCode)-sizeof(Character)-2*sizeof(bool)-1
// пока делаем размер постоянным
static const unsigned int size_of_alarm_message = 55;
char message[size_of_alarm_message]; /*!< сообщение */
};
/*! Собщение DBServer-у */
class DBMessage : public Message
{
public:
enum TypeOfQuery
{
Query,
Update,
Insert
};
DBMessage();
DBMessage(TypeOfQuery qtype, const std::string query, TypeOfMessage tblid,
Priority prior=Message::Low,
ObjectId cons=UniSetTypes::DefaultObjectId);
DBMessage(const VoidMessage *msg);
inline TransportMessage transport_msg() const
{
return transport(*this);
}
DBMessage::TypeOfQuery qtype; // тип данных в запросе
TypeOfMessage tblid; // идентификатор таблицы
// т.к. размер трансопртынх сообщений ограничен, то
// мы можем высчитать максимальнйю длину текстового запроса
// считаем размер текстового сообщения по формуле
// размерТраснпортного - РазмерБазового-суммаВсехВспомПолейДляДанногоСообщения-1
// всё это конечно не очень хорошо, но пока так.
// sizeof(UniSetTypes::RawDataOfTransportMessage)-sizeof(Message)-sizeof(DBMessage::TypeOfQuery)-sizeof(TypeOfMessage)-1
static const unsigned int size_of_query = 55;
char data[size_of_query];
};
/*! Собщение о срабатывании таймера */
class TimerMessage : public Message
{
......@@ -343,14 +196,14 @@ namespace UniSetTypes
}
ConfirmMessage( const VoidMessage *msg );
ConfirmMessage(long in_sensor_id,
double in_value,
time_t in_time,
time_t in_time_usec,
time_t in_confirm,
Priority in_priority = Message::Medium);
long sensor_id; /* ID датчика */
double value; /* значение датчика */
......
include/SystemGuard.h deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
//--------------------------------------------------------------------------------
/*! \file
* \brief Реализация SystemGuard
* \author Pavel Vainerman
*/
//--------------------------------------------------------------------------------
#ifndef SystemGuard_H_
#define SystemGuard_H_
//--------------------------------------------------------------------------------
#include <omniORB4/CORBA.h>
#include <omnithread.h>
#include "UniSetTypes.h"
#include "PassiveTimer.h"
#include "ThreadCreator.h"
#include "ObjectsActivator.h"
//--------------------------------------------------------------------------------
/*! \class SystemGuard
* Предназначен для слежения за исправностью работы процессов. А так же отслеживает наличие
* связи c узлами и обновляет эту информацию в ListOfNodes.
*/
class SystemGuard:
public ObjectsActivator
{
public:
SystemGuard(UniSetTypes::ObjectId id);
SystemGuard();
~SystemGuard();
virtual void run( bool thread=false );
virtual void stop();
virtual void oaDestroy(int signo=0);
virtual UniSetTypes::SimpleInfo* getInfo();
virtual UniSetTypes::ObjectType getType(){ return UniSetTypes::getObjectType("SystemGuard"); }
protected:
void execute();
virtual void sigterm( int signo );
virtual bool pingNode();
virtual void updateNodeInfo(const UniSetTypes::NodeInfo& newinf){};
virtual void watchDogTime();
virtual void dumpStateInfo();
virtual void autostart();
private:
void init();
// ObjectsActivator* act;
// CORBA::ORB_var orb;
PassiveTimer wdogt;
PassiveTimer rit;
PassiveTimer dumpt;
// PassiveTimer strt;
friend class ThreadCreator<SystemGuard>;
ThreadCreator<SystemGuard> *thr;
bool active;
int expid;
// omni_mutex omutex;
// omni_condition ocond;
UniSetTypes::uniset_mutex actMutex;
};
//--------------------------------------------------------------------------------
#endif
include/TimerService.h deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \brief Реализация TimerService
* \author Pavel Vainerman
*/
//---------------------------------------------------------------------------
#ifndef TimerService_H_
#define TimerService_H_
//---------------------------------------------------------------------------
#include <list>
#include <functional>
#include <omnithread.h>
#include <string>
#include "UniSetTypes.h"
#include "UniSetObject.h"
#include "TimerService_i.hh"
#include "PassiveTimer.h"
//#include "OmniThreadCreator.h"
#include "ThreadCreator.h"
//-----------------------------------------------------------------------------------
/*!
\page ServicesPage
\section secTimerService Сервис таймеров
\subsection subTS_common Общие сведения
Данный сервис предоставляет возможность заказа переодических сообщений
UniSetTypes::TimerMessage т.е. таймеров.
Каждый заказчик может заказывать несколько таймеров, различающихся идентификаторами. При этом
идентификаторы определяет сам заказчик. Они должны быть уникальны только для одного заказчика.
\note
Сервис не гарантирует реальное время и точное соблюдение интервала. Т.к. к указанному в заказе времени
добавляется время на обработку и посылку сообщения, но при достаточных системных ресурсах точность увеличивается.
\subsection subTS_idea Сценарий работы
На узле запускается один экземпляр сервиса. Клиенты могут получить доступ, несколькими способами:
- через NameService
- при помощи UniversalInterface::askTimer()
\par
Сервис является системным, поэтому его идентификатор можно получить при помощи
UniSetTypes::Configuration::getTimerService() объекта UniSetTypes::conf.
\subsection subTS_interface Интерфейс
Сервис предоставляет одну функцию
\code
void TimerService::askTimer( CORBA::Short timerid, CORBA::Long timeMS, const UniSetTypes::ConsumerInfo& ci,
CORBA::Short ticks)
\endcode
при помощи которой осуществялется заказ таймера.
\param timerid - уникальный идентификатор таймера
\par
В случае попытки заказать таймер с уже существующим (для данного заказчика) идентификатором вырабатывается
исключение TimerService_i::TimerAlreadyExist.
\param timeMS - период между уведомлениями. Для отказа от таймера необходимо указать timeMS=0.
\param ticks позволяет ограничить количество уведомлений.
\par
Если ticks<0 уведомления будут посылатся, пока заказчик сам не откажется от них.
Общее количество таймеров (\b на \b всех \b заказчиков) ограничено ( TimerService::MaxCountTimers ).
В случае превышения данного предела на все заказы будет вырабатываться исключение TimerService_i::LimitTimers.
Для преодоления этого ограничения, а так же для обеспечения оптимальной работы сервиса, можно запускать на одном
узле несколько TimerService-ов для распределения нагрузки(заказов) между ними. При этом за распределение заказов
отвечает, разработчик.
\subsection subTS_lifetime Время жизни заказа
Для того, чтобы оптимизировать работу сервиса и уменьшить на него нагрузку вводится понятие
"время жизни заказа". В случае, если в течение TimerService::AskLifeTimeSEC не удаётся послать заказчику
уведомление, в следствие его недоступности - заказ анулируется.
\note Параметры можно задавать в конфигурационном файле
Реализацию см. \ref TimerService
*/
/*! \class TimerService
* Построен на основе PassiveTimer.
*/
class TimerService:
public POA_TimerService_i,
public UniSetObject
{
public:
TimerService( UniSetTypes::ObjectId id, const std::string confNodeName="LocalTimerService");
~TimerService();
//! заказ таймера
virtual void askTimer( const TimerService_i::Timer& ti, const UniSetTypes::ConsumerInfo& ci);
void printList();
protected:
TimerService(const std::string confNodeName="LocalTimerService");
/*! Информация о таймере */
struct TimerInfo
{
TimerInfo():id(0), curTimeMS(0){};
TimerInfo(CORBA::Short id, CORBA::Long timeMS, const UniSetTypes::ConsumerInfo& cinf,
CORBA::Short cnt, unsigned int askLifeTime, UniSetTypes::Message::Priority p):
cinf(cinf),
ref(0),
id(id),
curTimeMS(timeMS),
priority(p),
curTick(cnt-1),
not_ping(false)
{
tmr.setTiming(timeMS);
lifetmr.setTiming(askLifeTime*1000); // [сек]
};
inline void reset()
{
curTimeMS = tmr.getInterval();
tmr.reset();
}
UniSetTypes::ConsumerInfo cinf; /*!< инфою о заказчике */
UniSetObject_i_var ref; /*!< ссылка заказчика */
UniSetTypes::TimerId id; /*!< идентификатор таймера */
timeout_t curTimeMS; /*!< остаток времени */
UniSetTypes::Message::Priority priority; /*!< приоритет посылаемого сообщения */
/*!
* текущий такт
* \note Если задано количество -1 то сообщения будут поылатся постоянно
*/
CORBA::Short curTick;
// заказчик с меньшим временем ожидания имеет больший приоритет
bool operator < ( const TimerInfo& ti ) const
{
return curTimeMS > ti.curTimeMS;
}
PassiveTimer tmr;
PassiveTimer lifetmr; /*! таймер жизни заказа в случае если объект не доступен */
bool not_ping; /* признак недоступности заказчика */
};
typedef std::list<TimerInfo> TimersList;
//! посылка сообщения о наступлении времени
virtual bool send(TimerInfo& ti);
//! Дизактивизация объекта (переопределяется для необходимых действий перед деактивацией)
virtual bool disactivateObject();
virtual bool activateObject();
virtual void sigterm( int signo );
unsigned int MaxCountTimers; /*!< максимально возможное количество таймеров */
unsigned int AskLifeTimeSEC; /*!< [сек] время жизни заказа, если объект недоступен */
void init(const std::string& confnode);
void work();
private:
bool terminate;
bool isSleep;
UniSetTimer* sleepTimer; /*!< таймер для реализации засыпания в отсутствие заказов */
class Timer_eq: public std::unary_function<TimerInfo, bool>
{
public:
Timer_eq(const UniSetTypes::ConsumerInfo& coi, CORBA::Short t):tid(t),ci(coi){}
inline bool operator()(const TimerInfo& ti) const
{
return ( ti.cinf.id == ci.id && ti.cinf.node == ci.node && ti.id == tid );
}
protected:
UniSetTypes::TimerId tid;
UniSetTypes::ConsumerInfo ci;
};
TimersList tlst;
/*! замок для блокирования совместного доступа к cписку таймеров */
UniSetTypes::uniset_mutex lstMutex;
int execute_pid;
ThreadCreator<TimerService>* exthread;
};
#endif
include/UniversalInterface.h
View file @ 57922c6b
......@@ -272,19 +272,6 @@ class UniversalInterface
void send( UniSetTypes::ObjectId name, UniSetTypes::TransportMessage& msg, UniSetTypes::ObjectId node) throw(IO_THROW_EXCEPTIONS);
void send( UniSetTypes::ObjectId name, UniSetTypes::TransportMessage& msg);
bool info( std::string msg, UniSetTypes::ObjectId messenger,
UniSetTypes::ObjectId fromNode = UniSetTypes::conf->getLocalNode(),
UniSetTypes::InfoMessage::Character ch=UniSetTypes::InfoMessage::Normal,
UniSetTypes::ObjectId from=UniSetTypes::DefaultObjectId );
bool alarm( std::string msg, UniSetTypes::ObjectId messenger,
UniSetTypes::ObjectId fromNode = UniSetTypes::conf->getLocalNode(),
UniSetTypes::AlarmMessage::Character ch=UniSetTypes::AlarmMessage::Alarm,
UniSetTypes::ObjectId from=UniSetTypes::DefaultObjectId );
bool info( UniSetTypes::InfoMessage& msg, UniSetTypes::ObjectId messenger);
bool alarm( UniSetTypes::AlarmMessage& msg, UniSetTypes::ObjectId messenger);
bool waitReady( UniSetTypes::ObjectId id, int msec, int pause=5000,
UniSetTypes::ObjectId node = UniSetTypes::conf->getLocalNode() ); // used exist
......
src/Processes/UniSetObserver.cc deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \author Pavel Vainerman
*/
// --------------------------------------------------------------------------
#include "UniSetObserver.h"
#include "Exceptions.h"
#include "UniversalInterface.h"
// ---------------------------------------------------------------------------
using namespace UniSetTypes;
// ---------------------------------------------------------------------------
UniSetSubject::UniSetSubject()
{
}
UniSetSubject::UniSetSubject(ObjectId id):
id(id)
{
}
UniSetSubject::~UniSetSubject()
{
}
// ---------------------------------------------------------------------------
void UniSetSubject::attach( UniSetObject* o )
{
ObserverList::iterator li = find(lst.begin(),lst.end(),o);
if( li==lst.end() )
lst.push_front(o);
}
// ---------------------------------------------------------------------------
void UniSetSubject::detach( UniSetObject* o )
{
lst.remove(o);
}
// ---------------------------------------------------------------------------
void UniSetSubject::notify(int notify, int data, Message::Priority priority)
{
for( ObserverList::iterator li=lst.begin();li!=lst.end();++li )
{
try
{
UpdateMessage msg(id, notify, data, priority, (*li)->getId());
(*li)->push( msg.transport_msg() );
}
catch(Exception& ex)
{
unideb[Debug::WARN] << ex << endl;
}
}
}
// ------------------------------------------------------------------------------------------
void UniSetSubject::notify( UniSetTypes::TransportMessage& msg )
{
for (ObserverList::iterator li=lst.begin();li!=lst.end();++li)
{
try
{
(*li)->push( msg );
}
catch(Exception& ex)
{
unideb[Debug::WARN] << ex << endl;
}
}
}
// ------------------------------------------------------------------------------------------
void UniSetSubject::attach( UniSetObject* o, int MessageType )
{
}
// ------------------------------------------------------------------------------------------
void UniSetSubject::detach( UniSetObject* o, int MessageType )
{
}
// ------------------------------------------------------------------------------------------
src/Services/DBServer.cc
View file @ 57922c6b
......@@ -83,27 +83,6 @@ void DBServer::processingMessage( UniSetTypes::VoidMessage *msg )
break;
}
case Message::DataBase:
{
DBMessage dbm(msg);
parse(&dbm);
break;
}
case Message::Info:
{
InfoMessage im(msg);
parse(&im);
break;
}
case Message::Alarm:
{
AlarmMessage am(msg);
parse(&am);
break;
}
case Message::Confirm:
{
ConfirmMessage cm(msg);
......
src/Services/Makefile.am
View file @ 57922c6b
......@@ -4,7 +4,7 @@
noinst_LTLIBRARIES = libServices.la
libServices_la_CPPFLAGS = $(SIGC_CFLAGS)
libServices_la_LIBADD = $(SIGC_LIBS)
libServices_la_SOURCES = TimerService_iSK.cc InfoServer_iSK.cc TimerService.cc DBServer.cc InfoServer.cc
libServices_la_SOURCES = DBServer.cc
include $(top_builddir)/conf/setting.mk
......
src/Services/RepositoryAgent.cc deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \author Pavel Vainerman
*/
// --------------------------------------------------------------------------
#include "Exceptions.h"
#include "RepositoryAgent.h"
// ------------------------------------------------------------------------------------------
using namespace UniSetTypes;
extern const ObjectInfo *pObjectsMap;
// ------------------------------------------------------------------------------------------
RepositoryAgent::RepositoryAgent():
oind(pObjectsMap)
{
}
RepositoryAgent::~RepositoryAgent()
{
}
/*
RepositoryAgent::RepositoryAgent(const string name, const string section, int* argc, char* **argv):
BaseProcess_i(name, section, argc, argv)
{
}
RepositoryAgent::RepositoryAgent( ObjectId id, int* argc, char* **argv):
BaseProcess_i( id, argc, argv)
{
}
*/
RepositoryAgent::RepositoryAgent( ObjectId id, const ObjectInfo *pObjMap):
BaseProcess(id),
oind(pObjMap)
{
// cout << ui.getNameById(id) << endl;
}
// ------------------------------------------------------------------------------------------
/*
void RepositoryAgent::registration(const char* name, ::CORBA::Object_ptr ref)
{
}
// ------------------------------------------------------------------------------------------
void RepositoryAgent::unregistration(const char* name, ::CORBA::Object_ptr ref)
{
}
*/
// ------------------------------------------------------------------------------------------
CORBA::Object_ptr RepositoryAgent::resolve(const char* name)
{
cout << "resolve: " << name << endl;
CORBA::Object_ptr ref;
try
{
ref= ui.resolve(name);
}
catch(NameNotFound)
{
throw RepositoryAgent_i::NameNotFound();
}
catch(ORepFailed)
{
throw RepositoryAgent_i::ResolveError();
}
return CORBA::Object::_duplicate(ref);
}
// ------------------------------------------------------------------------------------------
CORBA::Object_ptr RepositoryAgent::resolveid(BaseObjectId id)
{
cout << "resolveid: " << ui.getNameById(id) << endl;
CORBA::Object_ptr ref;
try
{
ref= ui.resolve(id);
}
catch(NameNotFound)
{
throw RepositoryAgent_i::NameNotFound();
}
catch(ORepFailed)
{
throw RepositoryAgent_i::ResolveError();
}
return CORBA::Object::_duplicate(ref);
}
// ------------------------------------------------------------------------------------------
void RepositoryAgent::execute()
{
while(active)// for(;;)
{
if ( waitMessage(&msg) )
{
/*
switch(msg.type)
{
case MessageType::Command:
{
cout << BaseProcess_i::myname << ": msg id ="<< msg.id << endl;
break;
}
default:
break;
}
*/
}
}
}
src/Various/Configuration.cc
View file @ 57922c6b
......@@ -37,11 +37,6 @@
#include "ObjectIndex_Array.h"
#include "ObjectIndex_XML.h"
#include "ObjectIndex_idXML.h"
#include "DefaultMessageInterface.h"
#include "MessageInterface_XML.h"
#include "MessageInterface_idXML.h"
#include "SystemGuard.h"
// -------------------------------------------------------------------------
using namespace std;
// -------------------------------------------------------------------------
......@@ -83,13 +78,10 @@ namespace UniSetTypes
Configuration *conf = 0;
Configuration::Configuration():
mi(NULL),
oind(NULL),
NSName("NameService"),
repeatCount(2),repeatTimeout(100),
localTimerService(UniSetTypes::DefaultObjectId),
localDBServer(UniSetTypes::DefaultObjectId),
localInfoServer(UniSetTypes::DefaultObjectId),
localNode(UniSetTypes::DefaultObjectId),
localNodeName(""),
fileConfName(""),
......@@ -106,35 +98,16 @@ Configuration::~Configuration()
delete oind;
oind=0;
}
if( mi != NULL )
{
delete mi;
mi=0;
}
/*
// ??. ObjectsActivator.cc
unideb[Debug::SYSTEM] << "(Configuration): orb destroy..." << endl;
try
{
orb->destroy();
}
catch(...){}
unideb[Debug::SYSTEM] << "(Configuration): orb destroy ok."<< endl;
*/
}
// ---------------------------------------------------------------------------------
Configuration::Configuration( int argc, const char* const* argv, const string xmlfile ):
mi(NULL),
oind(NULL),
_argc(argc),
_argv(argv),
NSName("NameService"),
repeatCount(2),repeatTimeout(100),
localTimerService(UniSetTypes::DefaultObjectId),
localDBServer(UniSetTypes::DefaultObjectId),
localInfoServer(UniSetTypes::DefaultObjectId),
localNode(UniSetTypes::DefaultObjectId),
localNodeName(""),
fileConfName(xmlfile)
......@@ -147,15 +120,12 @@ Configuration::Configuration( int argc, const char* const* argv, const string xm
// ---------------------------------------------------------------------------------
Configuration::Configuration( int argc, const char* const* argv, ObjectIndex* _oind,
const string fileConf ):
mi(NULL),
oind(NULL),
_argc(argc),
_argv(argv),
NSName("NameService"),
repeatCount(2),repeatTimeout(100),
localTimerService(UniSetTypes::DefaultObjectId),
localDBServer(UniSetTypes::DefaultObjectId),
localInfoServer(UniSetTypes::DefaultObjectId),
localNode(UniSetTypes::DefaultObjectId),
localNodeName(""),
fileConfName(fileConf)
......@@ -169,15 +139,12 @@ Configuration::Configuration( int argc, const char* const* argv, ObjectIndex* _o
// ---------------------------------------------------------------------------------
Configuration::Configuration( int argc, const char* const* argv, const string fileConf,
UniSetTypes::ObjectInfo* omap ):
mi(NULL),
oind(NULL),
_argc(argc),
_argv(argv),
NSName("NameService"),
repeatCount(2),repeatTimeout(100),
localTimerService(UniSetTypes::DefaultObjectId),
localDBServer(UniSetTypes::DefaultObjectId),
localInfoServer(UniSetTypes::DefaultObjectId),
localNode(UniSetTypes::DefaultObjectId),
localNodeName(""),
fileConfName(fileConf)
......@@ -261,20 +228,6 @@ void Configuration::initConfiguration( int argc, const char* const* argv )
}
}
// Init MessageInterface
{
UniXML_iterator it = unixml.findNode(unixml.getFirstNode(),"messages");
if( it == NULL )
mi = new DefaultMessageInterface();
else
{
if( it.getIntProp("idfromfile") == 0 )
mi = new MessageInterface_XML(unixml); // (fileConfName);
else
mi = new MessageInterface_idXML(unixml); // (fileConfName);
}
}
// Настраиваем отладочные логи
initDebug(unideb, "UniSetDebug");
......@@ -499,35 +452,6 @@ void Configuration::initParameters()
setLocalNode(nodename);
}
}
else if( name == "LocalTimerService" )
{
name = it.getProp("name");
// TimerService
string secTime( getServicesSection()+"/"+name);
localTimerService = oind->getIdByName(secTime);
if( localTimerService == DefaultObjectId )
{
ostringstream msg;
msg << "Configuration: TimerService '" << secTime << "' ?? ?????? ????????????? ÷ ObjectsMap!!!";
unideb[Debug::CRIT] << msg.str() << endl;
throw Exception(msg.str());
}
}
else if( name == "LocalInfoServer" )
{
name = it.getProp("name");
// InfoServer
string secInfo( getServicesSection()+"/"+name);
localInfoServer = oind->getIdByName(secInfo);
if( localInfoServer == DefaultObjectId )
{
ostringstream msg;
msg << "Configuration: InfoServer '" << secInfo << "' ?? ?????? ????????????? ÷ ObjectsMap!!!";
unideb[Debug::CRIT] << msg.str() << endl;
throw Exception(msg.str());
}
}
else if( name == "LocalDBServer" )
{
name = it.getProp("name");
......@@ -732,21 +656,7 @@ void Configuration::createNodesList()
else
ninf.port = tp.c_str();
string tmp(getProp(it,"infserver"));
if( tmp.empty() )
ninf.infserver = UniSetTypes::DefaultObjectId;
else
{
string iname(getServicesSection()+"/"+tmp);
ninf.infserver = oind->getIdByName(iname);
if( ninf.infserver == DefaultObjectId )
{
unideb[Debug::CRIT] << "Configuration(createNodesList): Not found ID for infoserver name='" << iname << "'" << endl;
throw Exception("Configuration(createNodesList: Not found ID for infoserver name='"+iname+"'");
}
}
tmp = it.getProp("dbserver");
string tmp(it.getProp("dbserver"));
if( tmp.empty() )
ninf.dbserver = UniSetTypes::DefaultObjectId;
......@@ -762,10 +672,7 @@ void Configuration::createNodesList()
}
if( ninf.id == getLocalNode() )
{
localDBServer = ninf.dbserver;
localInfoServer = ninf.infserver;
}
ninf.connected = false;
......
src/Various/ISRestorer.cc deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \author Pavel Vainerman
*/
// --------------------------------------------------------------------------
#include <sstream>
#include <fstream>
#include "Debug.h"
#include "Configuration.h"
#include "ISRestorer.h"
#include "Exceptions.h"
// ------------------------------------------------------------------------------------------
using namespace std;
using namespace UniversalIO;
using namespace UniSetTypes;
// ------------------------------------------------------------------------------------------
ISRestorer::ISRestorer()
{
}
ISRestorer::~ISRestorer()
{
}
// ------------------------------------------------------------------------------------------
void ISRestorer::addlist( InfoServer* is, const UniSetTypes::MessageCode code,
InfoServer::ConsumerList& lst )
{
is->askList[code]=lst;
}
// ------------------------------------------------------------------------------------------
src/Various/ISRestorer_XML.cc deleted 100644 → 0
View file @ 6bb862b7
/* This file is part of the UniSet project
* Copyright (c) 2002 Free Software Foundation, Inc.
* Copyright (c) 2002 Pavel Vainerman
*
* 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.
*/
// --------------------------------------------------------------------------
/*! \file
* \author Pavel Vainerman
*/
// --------------------------------------------------------------------------
#include <sstream>
#include <fstream>
#include "Debug.h"
#include "Configuration.h"
#include "ISRestorer.h"
#include "Exceptions.h"
#include "ORepHelpers.h"
// ------------------------------------------------------------------------------------------
using namespace std;
using namespace UniversalIO;
using namespace UniSetTypes;
// ------------------------------------------------------------------------------------------
ISRestorer_XML::ISRestorer_XML(string fname):
fname(fname)
{
init(fname);
}
// ------------------------------------------------------------------------------------------
ISRestorer_XML::~ISRestorer_XML()
{
}
// ------------------------------------------------------------------------------------------
void ISRestorer_XML::init( std::string fname )
{
/*!
\warning Файл открывается только при создании...
Т.е. не будут учтены изменения в промежутке между записью(dump-а) файла
*/
try
{
uxml.open(fname);
}
catch (...){}
}
// ------------------------------------------------------------------------------------------
void ISRestorer_XML::dump( InfoServer* is, const UniSetTypes::MessageCode code,
const InfoServer::ConsumerList& lst )
{
if( unideb.debugging(Debug::WARN) )
unideb[Debug::WARN] << "ISRestorer_XML::dump NOT SUPPORT!!!!" << endl;
}
// ------------------------------------------------------------------------------------------
void ISRestorer_XML::read( InfoServer* is, const string fn )
{
UniXML* confxml = conf->getConfXML();
if( !fn.empty() )
{
// оптимизация (не загружаем второй раз xml-файл)
if( fn == conf->getConfFileName() && confxml )
read( is, *confxml );
else
{
UniXML xml(fn);
read(is,xml);
xml.close();
}
}
else
{
// оптимизация (не загружаем второй раз xml-файл)
if( fname == conf->getConfFileName() && confxml )
read( is, *confxml );
else
{
uxml.close();
uxml.open(fname);
read(is,uxml);
}
}
}
// ------------------------------------------------------------------------------------------
void ISRestorer_XML::read( InfoServer* is, UniXML& xml )
{
xmlNode* node = find_node(xml, xml.getFirstNode(),"messages");
if( node )
read_list(xml, node, is);
}
// ------------------------------------------------------------------------------------------
void ISRestorer_XML::read_list(UniXML& xml, xmlNode* node, InfoServer* is )
{
UniXML_iterator it(node);
bool autoID=it.getIntProp("autoID");
if( !it.goChildren() )
return;
for( ;it.getCurrent(); it.goNext() )
{
if( !check_list_item(it) )
continue;
MessageCode code;
if( !autoID )
code = conf->mi->getCodeByIdName(it.getProp("name"));
else
{
code = xml.getIntProp(it,"id");
}
if( code == UniSetTypes::DefaultMessageCode )
{
unideb[Debug::WARN] << "(read_list): не смог получить message code для "
<< it.getProp("name") << endl;
continue;
}
UniXML_iterator itc(it.getCurrent());
if( !itc.goChildren() )
continue;
InfoServer::ConsumerList lst;
for(;itc.getCurrent();itc.goNext())
{
if( !check_consumer_item(itc) )
continue;
ConsumerInfo ci;
if( !getConsumerInfo(it,ci.id,ci.node) )
continue;
InfoServer::ConsumerInfoExt cinf(ci);
cinf.ask = xml.getIntProp(itc,"ask");
lst.push_front(cinf);
cslot(xml,itc,it.getCurrent());
}
rslot(xml,it,node);
if( !lst.empty() )
addlist(is,code,lst);
}
}
// ------------------------------------------------------------------------------------------
src/Various/Makefile.am
View file @ 57922c6b
......@@ -3,14 +3,13 @@
############################################################################
noinst_LTLIBRARIES = libVarious.la
libVarious_la_CPPFLAGS = $(SIGC_CFLAGS)
libVarious_la_LIBADD = $(SIGC_LIBS)
libVarious_la_SOURCES = DebugStream.cc Debug.cc UniXML.cc MessageType.cc Configuration.cc SystemGuard.cc TextIndex.cc \
libVarious_la_CPPFLAGS = $(SIGC_CFLAGS) $(COMCPP_CFLAGS)
libVarious_la_LIBADD = $(SIGC_LIBS) $(COMCPP_LIBS)
libVarious_la_SOURCES = DebugStream.cc Debug.cc UniXML.cc MessageType.cc Configuration.cc TextIndex.cc \
Restorer_XML.cc \
NCRestorer.cc NCRestorer_XML.cc \
ISRestorer.cc ISRestorer_XML.cc \
RunLock.cc Mutex.cc SViewer.cc SMonitor.cc LT_Object.cc \
MessageInterface_XML.cc MessageInterface_idXML.cc WDTInterface.cc \
WDTInterface.cc \
CycleStorage.cc TableStorage.cc TableBlockStorage.cc
include $(top_builddir)/conf/setting.mk
......
src/Various/MessageInterface_XML.cc deleted 100644 → 0
View file @ 6bb862b7
// This file is part of the UniSet project.
/* This file is part of the UniSet project
* Copyright (C) 2003 Pavel Vainerman <pv@etersoft.ru>
*
* 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 <sstream>
#include <iomanip>
#include "MessageInterface_XML.h"
#include "Configuration.h"
// -----------------------------------------------------------------------------------------
using namespace UniSetTypes;
using namespace std;
// -----------------------------------------------------------------------------------------
MessageInterface_XML::MessageInterface_XML( const string xmlfile, int msize ):
msgmap(msize)
{
string mfile(xmlfile);
if( mfile.empty() )
mfile = conf->getConfFileName();
UniXML xml;
// try
// {
xml.open(mfile);
read(xml);
// }
// catch(...){}
}
// ------------------------------------------------------------------------------------------
MessageInterface_XML::MessageInterface_XML( UniXML& xml, int msize ):
msgmap(msize)
{
read(xml);
}
// ------------------------------------------------------------------------------------------
MessageInterface_XML::~MessageInterface_XML()
{
}
// ------------------------------------------------------------------------------------------
string MessageInterface_XML::getMessage( UniSetTypes::MessageCode code )
{
if( (unsigned)code<0 || (unsigned)code>=msgmap.size() )
return "";
return msgmap[code].text;
}
// ------------------------------------------------------------------------------------------
bool MessageInterface_XML::isExist( UniSetTypes::MessageCode code )
{
if( (unsigned)code<0 || (unsigned)code>= msgmap.size() )
return false;
return true;
}
// ------------------------------------------------------------------------------------------
UniSetTypes::MessageCode MessageInterface_XML::getCode( const string& msg )
{
for( unsigned int i=0; i<msgmap.size(); i++ )
{
if( msgmap[i].text == msg )
return msgmap[i].code;
}
return DefaultMessageCode;
}
// ------------------------------------------------------------------------------------------
UniSetTypes::MessageCode MessageInterface_XML::getCodeByIdName( const string& name )
{
for( unsigned int i=0; i<msgmap.size(); i++ )
{
if( msgmap[i].idname == name )
return msgmap[i].code;
}
return DefaultMessageCode;
}
// ------------------------------------------------------------------------------------------
void MessageInterface_XML::read( UniXML& xml )
{
xmlNode* root( xml.findNode(xml.getFirstNode(),"messages") );
if( !root )
{
ostringstream msg;
msg << "(MessageInterface_XML::read): не нашли корневого раздела 'messages'";
throw NameNotFound(msg.str());
}
UniXML_iterator it(root);
if( !it.goChildren() )
{
ostringstream msg;
msg << "(MessageInterface_XML::read): не удалось перейти к списку элементов 'messages'";
throw NameNotFound(msg.str());
}
unsigned int ind=0;
for( ;it.getCurrent(); it.goNext() )
{
msgmap[ind].idname = xml.getProp(it,"name");
msgmap[ind].text = xml.getProp(it,"text");
msgmap[ind].code = ind;
ind++;
if( ind >= msgmap.size() )
{
ostringstream msg;
msg << "(MessageInterface_XML::read): не хватило размера массива maxSize=" << msgmap.size();
unideb[Debug::WARN] << msg.str() << "... Делаем resize + 100\n";
msgmap.resize(msgmap.size()+100);
}
}
// подгоняем под реальный размер
msgmap.resize(ind);
}
// ------------------------------------------------------------------------------------------
std::ostream& MessageInterface_XML::printMessagesMap( std::ostream& os )
{
cout << "size: " << msgmap.size() << endl;
for( unsigned int i=0; i<msgmap.size(); i++ )
{
os << setw(5) << msgmap[i].code << " "
<< setw(10) << msgmap[i].idname << " "
<< setw(45) << msgmap[i].text << endl;
}
return os;
}
// -----------------------------------------------------------------------------------------
std::ostream& operator<<(std::ostream& os, MessageInterface_XML& mi )
{
return mi.printMessagesMap(os);
}
// -----------------------------------------------------------------------------------------
src/Various/MessageInterface_idXML.cc deleted 100644 → 0
View file @ 6bb862b7
/*! \file
* \brief Класс работы с сообщениями
* \author Pavel Vainerman
*/
/**************************************************************************/
#include <sstream>
#include <iomanip>
#include "Exceptions.h"
#include "MessageInterface_idXML.h"
#include "Configuration.h"
// -----------------------------------------------------------------------------------------
using namespace std;
using namespace UniSetTypes;
// -----------------------------------------------------------------------------------------
MessageInterface_idXML::MessageInterface_idXML( const std::string xmlfile )
{
UniXML xml;
// try
// {
xml.open(xmlfile);
build(xml);
// }
// catch(...){}
}
// -----------------------------------------------------------------------------------------
MessageInterface_idXML::MessageInterface_idXML( UniXML& xml )
{
build(xml);
}
// -----------------------------------------------------------------------------------------
MessageInterface_idXML::~MessageInterface_idXML()
{
}
// -----------------------------------------------------------------------------------------
string MessageInterface_idXML::getMessage( UniSetTypes::MessageCode code )
{
MapMessageKey::const_iterator it = mmk.find(code);
if( it != mmk.end() )
return it->second.text;
ostringstream err;
err << "Неизвестное сообщение с кодом " << code;
return err.str();
}
// -----------------------------------------------------------------------------------------
bool MessageInterface_idXML::isExist(UniSetTypes::MessageCode code)
{
if( mmk.find(code) != mmk.end() )
return true;
return false;
}
// -----------------------------------------------------------------------------------------
UniSetTypes::MessageCode MessageInterface_idXML::getCode( const string& msg )
{
for( MapMessageKey::const_iterator it = mmk.begin(); it!=mmk.end(); ++it )
{
if( it->second.text == msg )
return it->first;
}
return UniSetTypes::DefaultMessageCode;
}
// -----------------------------------------------------------------------------------------
UniSetTypes::MessageCode MessageInterface_idXML::getCodeByIdName( const string& name )
{
for( MapMessageKey::const_iterator it = mmk.begin(); it!=mmk.end(); ++it )
{
if( it->second.idname == name )
return it->first;
}
return UniSetTypes::DefaultMessageCode;
}
// -----------------------------------------------------------------------------------------
void MessageInterface_idXML::build( UniXML& xml )
{
xmlNode* root = xml.findNode(xml.getFirstNode(),"messages");
if( !root )
{
ostringstream msg;
msg << "(MessageInterface_idXML::build): не нашли корневого раздела <messages>";
throw NameNotFound(msg.str());
}
// Считываем список элементов
UniXML_iterator it(root);
if( !it.goChildren() )
{
ostringstream msg;
msg << "(MessageInterface_idXML::build): не удалось перейти к списку элементов <messages>";
throw NameNotFound(msg.str());
}
for( ;it.getCurrent(); it.goNext() )
{
MessageInfo inf;
inf.code = it.getIntProp("id");
if( inf.code <= 0 )
{
ostringstream msg;
msg << "(MessageInterface_idXML::build): НЕ УКАЗАН id для " << it.getProp("name");
throw NameNotFound(msg.str());
}
inf.idname = it.getProp("name");
inf.text = it.getProp("text");
mmk[inf.code] = inf;
}
}
// -----------------------------------------------------------------------------------------
std::ostream& MessageInterface_idXML::printMessagesMap( std::ostream& os )
{
cout << "size: " << mmk.size() << endl;
for( MapMessageKey::const_iterator it = mmk.begin(); it!=mmk.end(); ++it )
{
os << setw(5) << it->second.code << " "
<< setw(10) << it->second.idname << " "
<< setw(45) << it->second.text << endl;
}
return os;
}
// -----------------------------------------------------------------------------------------
std::ostream& operator<<(std::ostream& os, MessageInterface_idXML& mi )
{
return mi.printMessagesMap(os);
}
// -----------------------------------------------------------------------------------------
src/Various/MessageType.cc
View file @ 57922c6b
......@@ -162,145 +162,6 @@ SystemMessage::SystemMessage(const VoidMessage *msg)
assert(this->type == Message::SysCommand);
}
//--------------------------------------------------------------------------------------------
InfoMessage::InfoMessage():
id(DefaultObjectId),
infocode( UniSetTypes::DefaultMessageCode ),
character(InfoMessage::Normal),
broadcast(false),
route(false)
{
type = Message::Info;
}
InfoMessage::InfoMessage(ObjectId id, const string str, ObjectId node, Character ch,
Priority priority, ObjectId consumer):
id(id),
infocode( UniSetTypes::DefaultMessageCode ),
character(ch),
broadcast(true),
route(false)
{
assert(str.size() < size_of_info_message);
this->node = node;
type = Message::Info;
this->priority = priority;
strcpy(message, str.c_str());
this->consumer = consumer;
}
InfoMessage::InfoMessage(ObjectId id, MessageCode icode, ObjectId node,
Character ch, Priority priority, ObjectId consumer):
id(id),
infocode(icode),
character(ch),
broadcast(true),
route(false)
{
this->node = node;
type = Message::Info;
this->priority = priority;
this->consumer = consumer;
}
InfoMessage::InfoMessage(const VoidMessage *msg)
{
memcpy(this,msg,sizeof(*this));
assert(this->type == Message::Info);
}
//--------------------------------------------------------------------------------------------
AlarmMessage::AlarmMessage():
id(DefaultObjectId),
alarmcode(UniSetTypes::DefaultMessageCode),
causecode(UniSetTypes::DefaultMessageCode),
character(AlarmMessage::Normal),
broadcast(false),
route(false)
{
type = Message::Alarm;
}
AlarmMessage::AlarmMessage(ObjectId id, const string str, ObjectId node,
Character ch, Priority prior, ObjectId cons):
id(id),
alarmcode(UniSetTypes::DefaultMessageCode),
causecode(UniSetTypes::DefaultMessageCode),
character(ch),
broadcast(true),
route(false)
{
assert(str.size() < size_of_alarm_message);
this->node = node;
type = Message::Alarm;
this->priority = prior;
strcpy(message, str.c_str());
this->consumer = cons;
}
AlarmMessage::AlarmMessage(ObjectId id, const string str, MessageCode ccode,
ObjectId node, Character ch,
Priority prior, ObjectId cons):
id(id),
alarmcode(UniSetTypes::DefaultMessageCode),
causecode(ccode),
character(ch),
broadcast(true),
route(false)
{
assert(str.size() < size_of_alarm_message);
this->node = node;
type = Message::Alarm;
this->priority = prior;
strcpy(message, str.c_str());
this->consumer = cons;
}
AlarmMessage::AlarmMessage(ObjectId id, MessageCode acode, MessageCode ccode,
ObjectId node, Character ch,
Priority prior, ObjectId cons):
id(id),
alarmcode(acode),
causecode(ccode),
character(ch),
broadcast(true),
route(false)
{
this->node = node;
type = Message::Alarm;
this->priority = prior;
this->consumer = cons;
}
AlarmMessage::AlarmMessage(const VoidMessage *msg)
{
memcpy(this,msg,sizeof(*this));
assert(this->type == Message::Alarm);
}
//--------------------------------------------------------------------------------------------
DBMessage::DBMessage():
qtype(DBMessage::Query),
tblid(Unused)
{
type = Message::DataBase;
}
DBMessage::DBMessage(DBMessage::TypeOfQuery qtype, const string query, TypeOfMessage tblid,
Priority prior, ObjectId cons):
qtype(qtype),
tblid(tblid)
{
assert(query.size() < size_of_query);
type = Message::DataBase;
priority = prior;
this->consumer = cons;
strcpy(data, query.c_str());
}
DBMessage::DBMessage(const VoidMessage *msg)
{
memcpy(this,msg,sizeof(*this));
assert(this->type == Message::DataBase);
}
//--------------------------------------------------------------------------------------------
TimerMessage::TimerMessage():
id(UniSetTypes::DefaultTimerId)
{
......
src/Various/SMonitor.cc
View file @ 57922c6b
......@@ -41,8 +41,6 @@ void SMonitor::processingMessage( UniSetTypes::VoidMessage *msg)
{
switch(msg->type)
{
case Message::Alarm:
case Message::Info:
case Message::SensorInfo:
{
// cout << myname << "(sensorMessage): type="<< msg->type << " prior=" << msg->priority;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment