DefaultContentLoader

class kanzi::connect::DefaultContentLoader : public ContentLoader, private ContentObserver

Implementation of content loader that connects to Content Manager in Kanzi Connect server.

Unnamed Group

virtual void start (ContentQueryArgumentsSharedPtr args) KZ_OVERRIDE

See

kanzi::connect::ContentLoader

virtual void startRuntime (const string uri, int credits, int creditReturnInterval) KZ_OVERRIDE

Starts runtime loading of data from a specific address.

Parameters

• uri: the uri where from to load.

• credits: total amount of transfer credits.

• creditReturnInterval: after how many received packets credits are returned to sender.

virtual void stop () KZ_OVERRIDE

Function to stop / cancel the tracking process.

Public Functions

DefaultContentLoader(ClientSharedPtr client)

Constructor.

Parameters

• client: Access to server, message dispatcher and task queue

virtual  ~DefaultContentLoader () KZ_OVERRIDE

Destructor.

bool connectUsingUnreliableBearer()

Determines whether this content loader will (eventually) connect using unreliable bearer.

Return

true if unreliable bearer will be used.

InterfaceDomain *getDomain() const

Return access to server interfaces.

Return

Interface domain, gateway to server interfaces.

inline shared_ptr<p2p::RoutingRules::Endpoint> getP2PEndpoint()

Retrieve associated P2P endpoint.

Return

P2P endpoint in case this loader is bound to P2P connection.

inline string getUri() const

inline const string &runtimeSubscribedToService() const

inline const string &runtimeSubscriptionWaitsService() const

inline void setP2PEndpoint(shared_ptr<p2p::RoutingRules::Endpoint> endpoint)

void stopBecauseServiceVanished()

Stop because the bound service vanished.