OmniEvents
|
Classes | |
class | Callback |
Interface for classes that wish to receive callbacks from deferred requests. More... | |
class | ConsumerAdmin_i |
class | Daemon |
Interface class that contains various methods for running omniEvents as a background task. More... | |
class | DaemonImpl |
Utility class that contains various methods for running omniEvents as a Unix daemon. More... | |
class | EventChannel_i |
Servant for CosEventChannelAdmin::EventChannel objects, also inherits from omni_thread. More... | |
class | EventChannelFactory_i |
class | EventChannelStore |
Container for Event Channels. More... | |
class | EventQueue |
The EventQueue is a circular buffer, that contains _size-1 events. More... | |
class | Filter |
Event filter interface. More... | |
class | FilterByRepositoryId |
Allows only events of a certain CORBA RepositoryId to pass. More... | |
class | FilterByTCKind |
The most basic event filter allows only events of a certain CORBA TCKind to pass. More... | |
class | Mapper |
A dummy servant that installs itself into the INSPOA and redirects all calls to the real destination. More... | |
class | omni_mutex_kcol |
The opposite of omni_mutex_lock, unlocks the mutex upon construction and re-locks it upon destruction. More... | |
class | omniEventsLog |
class | omniEventsLogWorker |
class | Orb |
Singleton class that owns the ORB and various initial references. More... | |
class | PersistNode |
class | Proxy |
Base class for three of the four Proxy servants. More... | |
class | ProxyManager |
Base class for ServantActivator classes that manage Proxy servants. More... | |
class | ProxyPullConsumer_i |
Implementation of the ProxyPullConsumer interface. More... | |
class | ProxyPullConsumerManager |
class | ProxyPullSupplier_i |
Servant for ProxyPullSupplier interface. More... | |
class | ProxyPullSupplierManager |
class | ProxyPushConsumer_i |
Default servant for ProxyPushConsumer objects. More... | |
class | ProxyPushSupplier_i |
class | ProxyPushSupplierManager |
class | RegistryKey |
Opens a windows registry key, and closed it upon destruction. More... | |
class | Servant |
Base class for servants. More... | |
class | Service |
Singleton class that contains various methods for running a Windows service. More... | |
class | SupplierAdmin_i |
class | timestamp |
This class can be used to generate timestamps. More... | |
class | Win |
Utility class, contains functions that Windows should have, but doesn't. More... | |
class | WriteLock |
Obtains an output stream to the active persistancy logfile, and locks it for exclusive access. More... | |
Functions | |
void | shutdown0 (void) |
Param to atexit(). | |
void | shutdown2 (int s, void *) |
Param to on_exit(). | |
void | usage (int argc, char **argv) |
void | insertArgs (int &argc, char **&argv, int idx, int nargs) |
Utility function, used to manipulate argv when using omniORB3. | |
template<class T > | |
T::_ptr_type | string_to_ (const char *oidStr) |
Converts a string to a narrowed reference. | |
CORBA::Object_ptr | createReference (PortableServer::POA_ptr poa, const char *repositoryId) |
Helper method called by createNarrowedReference(). | |
char * | newUniqueId () |
Generates a unique object ID string, based upon the current PID and time. | |
template<class T > | |
T::_ptr_type | createNarrowedReference (PortableServer::POA_ptr poa, const char *repositoryId) |
Helper method that creates a new CORBA object and then narrows it to the appropriate type. | |
const char * | version () |
Returns the constant version ID and copyright string. | |
Variables | |
DaemonImpl | daemon |
Singleton - only at file scope. | |
static Service | service |
Singleton - only at file scope. | |
timestamp | ts |
T::_ptr_type OmniEvents::createNarrowedReference | ( | PortableServer::POA_ptr | poa, |
const char * | repositoryId | ||
) |
Helper method that creates a new CORBA object and then narrows it to the appropriate type.
Wrapper around POA::create_reference_with_id. The type T must match the repositoryId parameter. Called by a class' createObject() method.
poa | POA to own new object. |
repositoryId | Identifies the type of object to make. e.g. _tc_ProxyPushSupplier->id(). |
Definition at line 96 of file Servant.h.
References createNarrowedReference(), and createReference().
Referenced by OmniEvents::ProxyPushSupplierManager::_add_ref(), OmniEvents::ProxyPushSupplierManager::_remove_ref(), OmniEvents::Servant::activateObjectWithId(), OmniEvents::ProxyPushConsumer_i::Connection::callback(), OmniEvents::ProxyPushSupplier_i::callback(), OmniEvents::ProxyPullConsumerManager::collect(), OmniEvents::ProxyPullConsumer_i::collect(), OmniEvents::SupplierAdmin_i::collect(), OmniEvents::ProxyPullSupplier_i::connect_pull_consumer(), OmniEvents::ProxyPullConsumer_i::connect_pull_supplier(), OmniEvents::ProxyPushSupplier_i::connect_push_consumer(), OmniEvents::ProxyPushConsumer_i::connect_push_supplier(), OmniEvents::ProxyPushConsumer_i::Connection::Connection(), createNarrowedReference(), OmniEvents::ProxyPullConsumerManager::createObject(), OmniEvents::ProxyPullSupplierManager::createObject(), OmniEvents::ProxyPushConsumer_i::createObject(), OmniEvents::ProxyPushSupplierManager::createObject(), createReference(), OmniEvents::ProxyPushConsumer_i::currentObjectId(), OmniEvents::Servant::deactivateObject(), OmniEvents::ProxyPullConsumerManager::disconnect(), OmniEvents::ProxyPullSupplierManager::disconnect(), OmniEvents::ProxyPushConsumer_i::disconnect(), OmniEvents::ProxyPushSupplierManager::disconnect(), OmniEvents::ProxyPullConsumer_i::disconnect_pull_consumer(), OmniEvents::ProxyPullSupplier_i::disconnect_pull_supplier(), OmniEvents::ProxyPushConsumer_i::disconnect_push_consumer(), OmniEvents::ProxyPushSupplier_i::disconnect_push_supplier(), OmniEvents::ProxyPushSupplierManager::etherealize(), OmniEvents::ProxyPullSupplierManager::incarnate(), OmniEvents::ProxyPushSupplierManager::incarnate(), newUniqueId(), OmniEvents::ProxyPushSupplier_i::output(), OmniEvents::ProxyPushConsumer_i::Connection::output(), OmniEvents::ProxyPushConsumer_i::ProxyPushConsumer_i(), OmniEvents::ProxyPushSupplierManager::ProxyPushSupplierManager(), OmniEvents::ProxyPushConsumer_i::push(), OmniEvents::ProxyPushConsumer_i::reincarnate(), OmniEvents::SupplierAdmin_i::reincarnate(), OmniEvents::ProxyPullConsumer_i::reincarnate(), OmniEvents::ProxyPullSupplier_i::reincarnate(), OmniEvents::ProxyPushSupplier_i::reincarnate(), OmniEvents::ProxyPushSupplierManager::run_undetached(), OmniEvents::Servant::Servant(), OmniEvents::ProxyPullSupplier_i::touch(), OmniEvents::ProxyPushSupplier_i::trigger(), OmniEvents::ProxyPullConsumerManager::triggerRequest(), OmniEvents::ProxyPullConsumer_i::triggerRequest(), OmniEvents::ProxyPullSupplier_i::try_pull(), OmniEvents::ProxyPushConsumer_i::Connection::~Connection(), OmniEvents::Servant::~Servant(), and OmniEvents::SupplierAdmin_i::~SupplierAdmin_i().
CORBA::Object_ptr OmniEvents::createReference | ( | PortableServer::POA_ptr | poa, |
const char * | repositoryId | ||
) |
Helper method called by createNarrowedReference().
poa | POA to own new object. |
repositoryId | Identifies the type of object to make. e.g. _tc_ProxyPushSupplier->id(). |
Definition at line 54 of file Servant.cc.
References createNarrowedReference(), and newUniqueId().
Referenced by createNarrowedReference().
Utility function, used to manipulate argv when using omniORB3.
Definition at line 97 of file omniEvents.cc.
char * OmniEvents::newUniqueId | ( | ) |
Generates a unique object ID string, based upon the current PID and time.
Definition at line 71 of file Servant.cc.
References createNarrowedReference(), and mutex.
Referenced by OmniEvents::EventChannelFactory_i::create_object(), and createReference().
Param to atexit().
Param to atexit()
Definition at line 114 of file daemon_unix.cc.
References daemon, and OmniEvents::DaemonImpl::shutdown().
Referenced by OmniEvents::DaemonImpl::daemonize(), and OmniEvents::Service::daemonize().
Param to on_exit().
Definition at line 115 of file daemon_unix.cc.
References daemon, and OmniEvents::DaemonImpl::shutdown().
Referenced by OmniEvents::DaemonImpl::daemonize().
Converts a string to a narrowed reference.
Definition at line 132 of file Orb.h.
References OmniEvents::Orb::_orb, and OmniEvents::Orb::inst().
Definition at line 49 of file omniEvents.cc.
References OMNIEVENTS_LOG_DEFAULT_LOCATION, OMNIEVENTS_LOGDIR_ENV_VAR, and PACKAGE_NAME.
Returns the constant version ID and copyright string.
Definition at line 32 of file version.cc.
References PACKAGE_STRING.
DaemonImpl OmniEvents::daemon |
Singleton - only at file scope.
Although we initialize the value to NULL, we don't trust that the runtime will actually initialise it.
Definition at line 94 of file daemon_unix.cc.
Referenced by OmniEvents::Daemon::Daemon(), OmniEvents::Daemon::daemonize(), OmniEvents::Daemon::foreground(), OmniEvents::DaemonImpl::log(), OmniEvents::Daemon::pidfile(), OmniEvents::Daemon::runningOk(), shutdown0(), shutdown2(), OmniEvents::Daemon::tracefile(), and OmniEvents::Daemon::~Daemon().
|
static |
Singleton - only at file scope.
Definition at line 166 of file daemon_windows.cc.
Referenced by OmniEvents::Service::ctrlHandler(), OmniEvents::Service::install(), OmniEvents::Service::log(), and OmniEvents::Service::uninstall().
timestamp OmniEvents::ts |
Definition at line 275 of file omniEventsLog.cc.
Referenced by OmniEvents::omniEventsLog::checkpoint().