A class that manages a service that is running locally in Kanzi Connect Server. More...

#include <service_host.hpp>

Inheritance diagram for kanzi::connect::LocalServiceHost:

Public Member Functions
	LocalServiceHost (const persistence::SettingFactory settingFactory, VirtualFileClient fileClient, const string &type, AbstractServiceSharedPtr service, ServiceRuntimeDataRegistrySharedPtr registry=ServiceRuntimeDataRegistrySharedPtr())
	Constructor.

virtual	~LocalServiceHost () override
	Destructor.


virtual string	getIdentifier () const override
	Retrieve interface identifier.

virtual void	changeType (const string &type) override
	Changes the interface name at runtime.

virtual void	initialize (InterfaceDomainBase domain, ContentClientSharedPtr contentClient, WorkQueueInterface workQueue) override
	Initialize the service.

virtual void	uninitialize () override
	cleanup the service.

virtual AbstractSessionSharedPtr	acquireSession (ConnectedClientSharedPtr client, int sessionId) override
	Creates a session to this service.

virtual void	releaseSession (int clientId, int sessionId) override
	Releases a session.

virtual void	work (ConnectWorkItemSharedPtr workItem) override
	Routine that get(s) called periodically or especially when object itself has requested it to be called using the work queue.

virtual void	receiveMessage (ConnectedClientSharedPtr client, const MessagePackage &message) override
	Invoked for each message this service should handle.

virtual void	notifyClientDisconnected (int clientId) override
	Invoked to inform that specific client has disconnected.

virtual const AbstractService::ServiceDescription &	getDescription () override
	Retrieve the service description from service host.

virtual const AbstractService::ServiceState &	getState () override
	Retrieve the service state information.

virtual bool	local () const override
	Is this service local or not.

virtual int	clientID () const override
	Returns the client identifier.

virtual void	setState (const AbstractService::ServiceState &state) override
	Sets the service state.

virtual shared_ptr< ServiceServiceConcept::Session >	getServiceSession () const override
	Returns a session to remote service.

virtual AbstractServiceSharedPtr	getService () const override
	Returns a service instance.

virtual int	countSessions () const override
	Returns amount of sessions towards this service.

virtual ClientDescriptorSharedPtr	getClientDescriptor () override
	Return the client descriptor.

virtual RuntimeDataObjectSharedPtr	getConfigurationProperties () override
	Retrieve service configuration properties.

virtual string	getServiceRoutingInformationDescription (int serverclientid) override
	Must be overridden by the corresponding implementation.

virtual void	notifyAll (const MessagePackage &event) override
	Internal API for across service scripting, not for public use.

virtual RuntimeDataObject *	getRuntimeData () override
	Internal API for across service scripting, not for public use.

Public Member Functions inherited from kanzi::connect::ServiceHost
virtual void	ensureDomain (ConnectDomainSharedPtr domain)
	Ensure that service instance (if local) has domain set.

virtual const string	getHash ()

virtual const string	getServiceDescriptionSchema (bool details=false)
	Retrieve service description schema.

virtual bool	registerServiceRuntimeData (const string schema="")
	Invoked to register service runtime data.

virtual bool	registerServiceRuntimeDataSchemaChange (const string &xml)
	Invoked to change runtime data schema at runtime.

virtual bool	reportServiceRuntimeData (const string &path, const string &stream)
	Can be called, mainly for remote services, to inform about new service information that was received.

	ServiceHost (ServiceRuntimeDataRegistrySharedPtr registry=ServiceRuntimeDataRegistrySharedPtr())
	C++ constructor.

virtual void	setConfigurationProperties (RuntimeDataObjectSharedPtr properties)
	Stores service configuration properties.

virtual void	setConfigurationPropertyChangedCallback (ConfigurationPropertyChangedCallback callback)
	Install a callback to be invoked when configuration property changes.

virtual void	setHash (const string hash)

bool	subscribeForRuntimeDataSchemaChanges (GenericSyncObserver<> &observer)
	Start getting notifications of runtime data schema changes.

bool	unsubscribeForRuntimeDataSchemaChanges (GenericSyncObserver<> &observer)
	Stop receiving notifications of runtime data schema changes.

virtual	~ServiceHost ()
	Destructor.

Protected Member Functions
virtual void	getServiceDescriptionSchemaImpl (string &output) override

Additional Inherited Members
Public Types inherited from kanzi::connect::ServiceHost
typedef function< void(ServiceHost *, RuntimeDataObjectSharedPtr)	ConfigurationPropertyChangedCallback)
	Callback prototype to invoke when service configuration properties change.

Protected Attributes inherited from kanzi::connect::ServiceHost
ConfigurationPropertyChangedCallback	m_configurationPropertyChangedCallback

unique_ptr< RuntimeDataChildChangeMonitor >	m_configurationPropertyChangeMonitor

ServiceRuntimeDataRegistry::ContentRegistrationToken	m_runtimeDataRegistrationToken

ServiceRuntimeDataRegistrySharedPtr	m_runtimeDataRegistry
	Runtime data registry for convenient access.

GenericSyncPublisher	m_runtimeDataSchemaChangePublisher
	Publisher to use when runtime data schema changes within the ServiceHost.

AbstractService::RuntimeDataSchemaChangeSubscriptionToken	m_runtimeDataSchemaChangeSubscriptionToken

Detailed Description

A class that manages a service that is running locally in Kanzi Connect Server.

Constructor & Destructor Documentation

◆ LocalServiceHost()

kanzi::connect::LocalServiceHost::LocalServiceHost	(	const persistence::SettingFactory *	settingFactory,
		VirtualFileClient *	fileClient,
		const string &	type,
		AbstractServiceSharedPtr	service,
		ServiceRuntimeDataRegistrySharedPtr	registry = ServiceRuntimeDataRegistrySharedPtr() )

Constructor.

◆ ~LocalServiceHost()

virtual kanzi::connect::LocalServiceHost::~LocalServiceHost ( )

overridevirtual

Destructor.

Member Function Documentation

◆ acquireSession()

virtual AbstractSessionSharedPtr kanzi::connect::LocalServiceHost::acquireSession	(	ConnectedClientSharedPtr	client,
		int	sessionId )

overridevirtual

Creates a session to this service.

Parameters

client	identifies the client.
sessionId	identifies the session.

Returns: session instance. ownership not transfered.

Implements kanzi::connect::ServiceHost.

◆ changeType()

virtual void kanzi::connect::LocalServiceHost::changeType ( const string & type )

overridevirtual

Changes the interface name at runtime.

Parameters

type	new type for the interface.

Implements kanzi::connect::ServiceHost.

◆ clientID()

virtual int kanzi::connect::LocalServiceHost::clientID ( ) const

overridevirtual

Returns the client identifier.

Relevant only for remote clients. Will return -1 for local clients.

Returns: client identifier.

Implements kanzi::connect::ServiceHost.

◆ countSessions()

virtual int kanzi::connect::LocalServiceHost::countSessions ( ) const

overridevirtual

Returns amount of sessions towards this service.

Returns: amount of sessions

Implements kanzi::connect::ServiceHost.

◆ getClientDescriptor()

virtual ClientDescriptorSharedPtr kanzi::connect::LocalServiceHost::getClientDescriptor ( )

overridevirtual

Return the client descriptor.

Relevant only for remote services.

Returns: client descriptor

Implements kanzi::connect::ServiceHost.

◆ getConfigurationProperties()

virtual RuntimeDataObjectSharedPtr kanzi::connect::LocalServiceHost::getConfigurationProperties ( )

overridevirtual

Retrieve service configuration properties.

Returns: properties as shared object.

Implements kanzi::connect::ServiceHost.

◆ getDescription()

virtual const AbstractService::ServiceDescription & kanzi::connect::LocalServiceHost::getDescription ( )

overridevirtual

Retrieve the service description from service host.

Returns: const reference to service description

Implements kanzi::connect::ServiceHost.

◆ getIdentifier()

virtual string kanzi::connect::LocalServiceHost::getIdentifier ( ) const

overridevirtual

Retrieve interface identifier.

Returns: interface ID this service handles.

Implements kanzi::connect::ServiceHost.

◆ getRuntimeData()

virtual RuntimeDataObject * kanzi::connect::LocalServiceHost::getRuntimeData ( )

inlineoverridevirtual

Internal API for across service scripting, not for public use.

Request a pointer to service host runtime data. Returned data (if any) may be a mirror to a service registry so modifying values here may not be visible for the hosted service itself.

Reimplemented from kanzi::connect::ServiceHost.

◆ getService()

virtual AbstractServiceSharedPtr kanzi::connect::LocalServiceHost::getService ( ) const

overridevirtual

Returns a service instance.

Relevant only for local services.

Returns: service

Implements kanzi::connect::ServiceHost.

◆ getServiceDescriptionSchemaImpl()

virtual void kanzi::connect::LocalServiceHost::getServiceDescriptionSchemaImpl ( string & output )

overrideprotectedvirtual

See also: ServiceHost::getServiceDescriptionSchemaImpl

Implements kanzi::connect::ServiceHost.

◆ getServiceRoutingInformationDescription()

virtual string kanzi::connect::LocalServiceHost::getServiceRoutingInformationDescription ( int serverclientid )

overridevirtual

Must be overridden by the corresponding implementation.

Returns: xml format routing information for the service.

Implements kanzi::connect::ServiceHost.

◆ getServiceSession()

virtual shared_ptr< ServiceServiceConcept::Session > kanzi::connect::LocalServiceHost::getServiceSession ( ) const

inlineoverridevirtual

Returns a session to remote service.

Relevant only for remote services.

Returns: session

Implements kanzi::connect::ServiceHost.

◆ getState()

virtual const AbstractService::ServiceState & kanzi::connect::LocalServiceHost::getState ( )

overridevirtual

Retrieve the service state information.

Returns: const reference to service state information.

Implements kanzi::connect::ServiceHost.

◆ initialize()

virtual void kanzi::connect::LocalServiceHost::initialize	(	InterfaceDomainBase *	domain,
		ContentClientSharedPtr	contentClient,
		WorkQueueInterface *	workQueue )

overridevirtual

Initialize the service.

Parameters

domain	environment where the service is run in.
contentClient	access to content system
workQueue	interface to work queue used to dispatch work service is ready will eventually cause the services work() method to be invoked.

Implements kanzi::connect::ServiceHost.

◆ local()

virtual bool kanzi::connect::LocalServiceHost::local ( ) const

overridevirtual

Is this service local or not.

Returns: true if service is local

Implements kanzi::connect::ServiceHost.

◆ notifyAll()

virtual void kanzi::connect::LocalServiceHost::notifyAll ( const MessagePackage & event )

inlineoverridevirtual

Internal API for across service scripting, not for public use.

Notify all client sessions with message.

Reimplemented from kanzi::connect::ServiceHost.

◆ notifyClientDisconnected()

virtual void kanzi::connect::LocalServiceHost::notifyClientDisconnected ( int clientId )

overridevirtual

Invoked to inform that specific client has disconnected.

Parameters

clientId Identifies the client.

Implements kanzi::connect::ServiceHost.

◆ receiveMessage()

virtual void kanzi::connect::LocalServiceHost::receiveMessage	(	ConnectedClientSharedPtr	client,
		const MessagePackage &	message )

overridevirtual

Invoked for each message this service should handle.

Parameters

client	identifies the message sender
message	the message to process.

Implements kanzi::connect::ServiceHost.

◆ releaseSession()

virtual void kanzi::connect::LocalServiceHost::releaseSession	(	int	clientId,
		int	sessionId )

overridevirtual

Releases a session.

Parameters

clientId	identifies the client
sessionId	identifies the session

Implements kanzi::connect::ServiceHost.

◆ setState()

virtual void kanzi::connect::LocalServiceHost::setState ( const AbstractService::ServiceState & state )

overridevirtual

Sets the service state.

Relevant only for remote clients.

Parameters

state new state for remote clients.

Implements kanzi::connect::ServiceHost.

◆ uninitialize()

virtual void kanzi::connect::LocalServiceHost::uninitialize ( )

overridevirtual

cleanup the service.

Implements kanzi::connect::ServiceHost.

◆ work()

virtual void kanzi::connect::LocalServiceHost::work ( ConnectWorkItemSharedPtr workItem )

overridevirtual

Routine that get(s) called periodically or especially when object itself has requested it to be called using the work queue.

Parameters

workItem Item to be processed.

Implements kanzi::connect::ServiceHost.

The documentation for this class was generated from the following file:

service_service/service_host.hpp

Public Member Functions

Protected Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ LocalServiceHost()

◆ ~LocalServiceHost()

Member Function Documentation

◆ acquireSession()

◆ changeType()

◆ clientID()

◆ countSessions()

◆ getClientDescriptor()

◆ getConfigurationProperties()

◆ getDescription()

◆ getIdentifier()

◆ getRuntimeData()

◆ getService()

◆ getServiceDescriptionSchemaImpl()

◆ getServiceRoutingInformationDescription()

◆ getServiceSession()

◆ getState()

◆ initialize()

◆ local()

◆ notifyAll()

◆ notifyClientDisconnected()

◆ receiveMessage()

◆ releaseSession()

◆ setState()

◆ uninitialize()

◆ work()