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) KZ_OVERRIDE
- See
kanzi::connect::ContentLoader
-
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.
-
void stop () KZ_OVERRIDE
Function to stop / cancel the tracking process.
Public Functions
Constructor.
- Parameters
client
: Access to server, message dispatcher and task queue
-
~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.
-
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
stopBecauseServiceVanished
()¶ Stop because the bound service vanished.
-