DefaultContentLoader

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

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

Unnamed Group

void start(ContentQueryArgumentsSharedPtr args) override

See

kanzi::connect::ContentLoader

void startRuntime(const string uri, int credits, int creditReturnInterval) 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.

void stop() override

Function to stop / cancel the tracking process.

Public Functions

DefaultContentLoader(ClientSharedPtr client)

Constructor.

Parameters

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

~DefaultContentLoader() 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.

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

Retrieve associated P2P endpoint.

Return

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

string getUri() const

const string &runtimeSubscribedToService() const

const string &runtimeSubscriptionWaitsService() const

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

void stopBecauseServiceVanished()

Stop because the bound service vanished.