kanzi::connect::Connection Class Reference

A class that represents the connection to network server and maintains listener for the network traffic. More...

#include <connection.hpp>

Inheritance diagram for kanzi::connect::Connection:

Classes
class	StateObserver
	Alternate approach to listen connection state events - traditional observer pattern. More...
class	WorkNotifyCallback
	Callback interface used to notify listeners that there is work to be done. More...

Public Types
typedef function< void(State)>	ConnectionStateCallbackFunction
	Callback function type for connection state changes.
typedef shared_ptr< void >	ConnectionStateSubscriptionToken
	Subscription token for connection callbacks.
enum	State { Connecting , Connected , Disconnected }
	Enumeration for connection state. More...

Public Member Functions
ConnectionStateSubscriptionToken	addStateSubscription (ConnectionStateCallbackFunction function)
	Subscribe to connection state changes.
ConnectionStateSubscriptionToken	addStateSubscriptionEx (StateObserver *observer)
	Subscribe to connection state changes.
void	clearWorkCallback ()
	Clears a previously set work callback.
bool	connect (const string &adapter, const ClientConnectionAdapter::Parameters &parameters, Wait *signal=0)
	Starts connecting to server.
bool	connectEx (const string &adapter, const ClientConnectionAdapter::Parameters &parameters)
	Starts connecting to server.
	Connection (InterfaceDomain *domain, Wait *signal)
	Constructor.
ClientConnectionAdapterSharedPtr	createAdapter (const string &identifier)
	Create connection adapter based on name.
void	disconnect ()
	Disconnects from server.
string	getAdapterParameter (const string &parameter)
	Retrieve parameter of currently used adapter.
string	getAdapterState (const string &parameter)
	Retrieve state of currently used adapter.
string	getAdapterType ()
	Retrieve currently used adapter type.
MessageDispatcher *	getMessageDispatcher ()
	Retrieve message dispatcher that is used to send / receive data across network.
State	getState () const
	Returns current connection state.
Connection::WorkNotifyCallback *	getWorkCallback () const
	Retrieve previously set work notification callback.
void	notifyWorkAvailable ()
	Notify work available callback if one has been set.
bool	registerConnectionAdapter (const string &identifier, ConnectionAdapterCreateFunc creator)
	Registers new connection adapter type.
void	removeStateSubscription (ConnectionStateSubscriptionToken token)
	Unsubscribe from connection state changes.
void	setWorkCallback (WorkNotifyCallback *callback)
	Registers a work callback.
bool	unregisterConnectionAdapter (const string &identifier)
	Unregister connection adapter.
void	work ()
	Performs work, process received data and connection state changes.
virtual	~Connection ()
	Destructor. (virtual for SWIG).
Public Member Functions inherited from kanzi::connect::ConnectionAdapterProvider
virtual	~ConnectionAdapterProvider ()

Static Public Member Functions
static string	state2String (const State state)
	Convert state to human readable string.

Detailed Description

A class that represents the connection to network server and maintains listener for the network traffic.

This class also handles the internal data exchange between the interfaces and the messages that are sent/received across network.

Member Typedef Documentation

ConnectionStateCallbackFunction

typedef function<void(State)> kanzi::connect::Connection::ConnectionStateCallbackFunction

Callback function type for connection state changes.

ConnectionStateSubscriptionToken

typedef shared_ptr<void> kanzi::connect::Connection::ConnectionStateSubscriptionToken

Subscription token for connection callbacks.

Member Enumeration Documentation

State

enum kanzi::connect::Connection::State

Enumeration for connection state.

Enumerator
Connecting	Client is connecting in to server, but connection is not yet established.
Connected	Connection is established and services are connected.
Disconnected	There is no connection and services are unavailable.

Constructor & Destructor Documentation

Connection()

kanzi::connect::Connection::Connection	(	InterfaceDomain *	domain,
		Wait *	signal )

Constructor.

Parameters

domain	Interface domain that provides access to all network interfaces.
signal	Signal that can be used to trigger work().

~Connection()

virtual kanzi::connect::Connection::~Connection ( )

virtual

Destructor. (virtual for SWIG).

Member Function Documentation

addStateSubscription()

ConnectionStateSubscriptionToken kanzi::connect::Connection::addStateSubscription

(

ConnectionStateCallbackFunction

function

)

Subscribe to connection state changes.

Parameters

function

Callback function.

Returns

Token that can be used to unsubscribe the callback.

addStateSubscriptionEx()

ConnectionStateSubscriptionToken kanzi::connect::Connection::addStateSubscriptionEx

(

StateObserver *

observer

)

Subscribe to connection state changes.

Parameters

observer

interface used to report changes

Returns

Token that can be used unsubscribe the callback.

clearWorkCallback()

void kanzi::connect::Connection::clearWorkCallback

(

)

Clears a previously set work callback.

connect()

bool kanzi::connect::Connection::connect	(	const string &	adapter,
		const ClientConnectionAdapter::Parameters &	parameters,
		Wait *	signal = 0 )

Starts connecting to server.

Parameters

adapter	Connection adapter type to use.
parameters	Configuration parameters for adapter.
signal	Signal to invoke when connection is established, optional.

Returns

true if state allowed a new connection establishment to start. false if not.

connectEx()

bool kanzi::connect::Connection::connectEx	(	const string &	adapter,
		const ClientConnectionAdapter::Parameters &	parameters )

Starts connecting to server.

This is override meant to be used by external language bindings.

Parameters

adapter	Connection adapter type to use.
parameters	Configuration parameters for adapter.

Returns

true if state allowed a new connection establishment to start. false if not.

createAdapter()

ClientConnectionAdapterSharedPtr kanzi::connect::Connection::createAdapter ( const string & identifier )

virtual

Create connection adapter based on name.

Parameters

identifier

Identifier of the connection adapter. This name needs to match with the ones in configuration files.

Returns

newly created adapter

Implements kanzi::connect::ConnectionAdapterProvider.

disconnect()

void kanzi::connect::Connection::disconnect

(

)

Disconnects from server.

getAdapterParameter()

string kanzi::connect::Connection::getAdapterParameter

(

const string &

parameter

)

Retrieve parameter of currently used adapter.

Parameters

parameter

Parameter to retrieve from adapter.

Returns

State of given parameter.

getAdapterState()

string kanzi::connect::Connection::getAdapterState

(

const string &

parameter

)

Retrieve state of currently used adapter.

Parameters

parameter

Parameter to retrieve from adapter.

Returns

State of given parameter.

getAdapterType()

string kanzi::connect::Connection::getAdapterType

(

)

Retrieve currently used adapter type.

Returns

Adapter type.

getMessageDispatcher()

MessageDispatcher * kanzi::connect::Connection::getMessageDispatcher

(

)

Retrieve message dispatcher that is used to send / receive data across network.

Returns

Message dispatcher object.

getState()

State kanzi::connect::Connection::getState

(

)

const

Returns current connection state.

Returns

State enumeration representing the current state of operation.

getWorkCallback()

Connection::WorkNotifyCallback * kanzi::connect::Connection::getWorkCallback

(

)

const

Retrieve previously set work notification callback.

Returns

work notification interface. can be nullptr. ownership not transfered.

notifyWorkAvailable()

void kanzi::connect::Connection::notifyWorkAvailable

(

)

Notify work available callback if one has been set.

registerConnectionAdapter()

bool kanzi::connect::Connection::registerConnectionAdapter	(	const string &	identifier,
		ConnectionAdapterCreateFunc	creator )

Registers new connection adapter type.

Parameters

identifier	Identifier of the connection adapter. This name needs to match with the ones in configuration files.
creator	Function that instantiates a connection adapter of given type.

removeStateSubscription()

void kanzi::connect::Connection::removeStateSubscription

(

ConnectionStateSubscriptionToken

token

)

Unsubscribe from connection state changes.

Parameters

token

Token that was received when subscription was made.

setWorkCallback()

void kanzi::connect::Connection::setWorkCallback

(

WorkNotifyCallback *

callback

)

Registers a work callback.

Parameters

callback

method to invoke when there is work to be done.

state2String()

static string kanzi::connect::Connection::state2String ( const State state )

static

Convert state to human readable string.

Parameters

state

The state to convert

Returns

string which represents given state

unregisterConnectionAdapter()

bool kanzi::connect::Connection::unregisterConnectionAdapter

(

const string &

identifier

)

Unregister connection adapter.

Parameters

identifier

Identifier of the connection adapter.

work()

void kanzi::connect::Connection::work

(

)

Performs work, process received data and connection state changes.

---

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

• connect/connection.hpp