|
| UniSetManager (uniset::ObjectId id) |
|
| UniSetManager (const std::string &name, const std::string §ion) |
|
virtual uniset::ObjectType | getType () override |
|
virtual void | broadcast (const uniset::TransportMessage &msg) override |
|
virtual uniset::SimpleInfoSeq * | getObjectsInfo (CORBA::Long MaxLength=300, const char *userparam=0) override |
|
virtual bool | add (const std::shared_ptr< UniSetObject > &obj) |
|
virtual bool | remove (const std::shared_ptr< UniSetObject > &obj) |
|
size_t | objectsCount () const |
|
PortableServer::POA_ptr | getPOA () |
|
PortableServer::POAManager_ptr | getPOAManager () |
|
std::shared_ptr< UniSetManager > | get_mptr () |
|
| UniSetObject (const std::string &name, const std::string §ion) |
|
| UniSetObject (uniset::ObjectId id) |
|
virtual CORBA::Boolean | exist () override |
|
virtual uniset::ObjectId | getId () override |
|
const uniset::ObjectId | getId () const |
|
std::string | getName () const |
|
const std::string | getStrType () |
|
virtual uniset::SimpleInfo * | getInfo (const char *userparam="") override |
|
virtual uniset::SimpleInfo * | apiRequest (const char *query) override |
|
virtual void | push (const uniset::TransportMessage &msg) override |
| поместить сообщение в очередь
|
|
virtual void | pushMessage (const char *msg, ::CORBA::Long mtype, const ::uniset::Timespec &tm, const ::uniset::ProducerInfo &pi, ::CORBA::Long priority, ::CORBA::Long consumer) override |
| поместить текстовое сообщение в очередь
|
|
virtual Poco::JSON::Object::Ptr | httpGet (const Poco::URI::QueryParameters &p) override |
|
virtual Poco::JSON::Object::Ptr | httpHelp (const Poco::URI::QueryParameters &p) override |
|
uniset::ObjectPtr | getRef () const |
|
std::shared_ptr< UniSetObject > | get_ptr () |
|
virtual timeout_t | askTimer (uniset::TimerId timerid, timeout_t timeMS, clock_t ticks=-1, uniset::Message::Priority p=uniset::Message::High) override |
|
timeout_t | checkTimers (UniSetObject *obj) |
|
timeout_t | getTimeInterval (uniset::TimerId timerid) const |
|
timeout_t | getTimeLeft (uniset::TimerId timerid) const |
|
virtual Poco::JSON::Object::Ptr | httpRequest (const std::string &req, const Poco::URI::QueryParameters &p) |
|
|
virtual bool | addManager (const std::shared_ptr< UniSetManager > &mngr) |
|
virtual bool | removeManager (const std::shared_ptr< UniSetManager > &mngr) |
|
virtual bool | addObject (const std::shared_ptr< UniSetObject > &obj) |
|
virtual bool | removeObject (const std::shared_ptr< UniSetObject > &obj) |
|
void | objects (OManagerCommand cmd) |
|
void | managers (OManagerCommand cmd) |
|
void | initPOA (const std::weak_ptr< UniSetManager > &rmngr) |
|
virtual bool | activateObject () override |
|
virtual bool | deactivateObject () override |
|
const std::shared_ptr< UniSetObject > | findObject (const std::string &name) const |
|
const std::shared_ptr< UniSetManager > | findManager (const std::string &name) const |
|
const std::shared_ptr< UniSetObject > | deepFindObject (const std::string &name) const |
|
void | getAllObjectsList (std::vector< std::shared_ptr< UniSetObject > > &vec, size_t lim=1000) |
|
int | getObjectsInfo (const std::shared_ptr< UniSetManager > &mngr, uniset::SimpleInfoSeq *seq, int begin, const long uplimit, const char *userparam) |
|
void | apply_for_objects (OFunction f) |
|
void | apply_for_managers (MFunction f) |
|
virtual void | processingMessage (const uniset::VoidMessage *msg) |
|
virtual void | sysCommand (const uniset::SystemMessage *sm) |
|
virtual void | sensorInfo (const uniset::SensorMessage *sm) |
|
virtual void | timerInfo (const uniset::TimerMessage *tm) |
|
virtual void | onTextMessage (const uniset::TextMessage *tm) |
|
VoidMessagePtr | receiveMessage () |
|
VoidMessagePtr | waitMessage (timeout_t msec=UniSetTimer::WaitUpTime) |
|
void | termWaiting () |
|
size_t | countMessages () |
|
size_t | getCountOfLostMessages () const |
|
void | uterminate () |
|
void | thread (bool create) |
|
void | offThread () |
|
void | onThread () |
|
virtual void | callback () |
|
void | setID (uniset::ObjectId id) |
|
void | setThreadPriority (Poco::Thread::Priority p) |
|
void | setMaxSizeOfMessageQueue (size_t s) |
|
size_t | getMaxSizeOfMessageQueue () const |
|
bool | isActive () const |
|
void | setActive (bool set) |
|
virtual Poco::JSON::Object::Ptr | httpGetMyInfo (Poco::JSON::Object::Ptr root) |
|
Poco::JSON::Object::Ptr | request_configure (const std::string &req, const Poco::URI::QueryParameters &p) |
|
Poco::JSON::Object::Ptr | request_configure_get (const std::string &req, const Poco::URI::QueryParameters &p) |
|
Poco::JSON::Object::Ptr | request_configure_by_name (const std::string &name, const std::string &props) |
|
Poco::JSON::Object::Ptr | request_params (const std::string &req, const Poco::URI::QueryParameters &p) |
|
virtual Poco::JSON::Object::Ptr | request_params_get (const std::string &req, const Poco::URI::QueryParameters &p) |
|
virtual Poco::JSON::Object::Ptr | request_params_set (const std::string &req, const Poco::URI::QueryParameters &p) |
|
virtual std::string | getTimerName (int id) const |
|
TimersList | getTimersList () const |
|
- Содержит в себе функции управления объектами. их регистрации и т.п. Создается менеджер объектов, после чего вызывается initObjects() для инициализации объектов которыми управляет данный менеджер... Менеджер в свою очередь сам является объектом и обладает всеми его свойствами
Для пересылки сообщения всем подчиненным объектам используется функция UniSetManager::broadcast(const TransportMessage& msg)
- У базового менеджера имеются базовые три функции см. UniSetManager_i.
- Заметки
- Только при вызове функции UniSetManager::broadcast() происходит формирование сообщения всем подчиненным объектам... Если команда происходит при помощи push, то пересылки всем подчинённым объектам не происходит...