: callback(cb), clientWrapper(cw){}
};
- struct ListenContext2
+ struct ListenErrorContext
+ {
+ FindCallback callback;
+ FindErrorCallback errorCallback;
+ std::weak_ptr<IClientWrapper> clientWrapper;
+
+ ListenErrorContext(FindCallback cb1, FindErrorCallback cb2,
+ std::weak_ptr<IClientWrapper> cw)
+ : callback(cb1), errorCallback(cb2), clientWrapper(cw){}
+ };
+
+ struct ListenResListContext
{
FindResListCallback callback;
std::weak_ptr<IClientWrapper> clientWrapper;
- ListenContext2(FindResListCallback cb, std::weak_ptr<IClientWrapper> cw)
+ ListenResListContext(FindResListCallback cb, std::weak_ptr<IClientWrapper> cw)
: callback(cb), clientWrapper(cw){}
};
- struct ListenErrorContext
+ struct ListenResListWithErrorContext
{
- FindCallback callback;
+ FindResListCallback callback;
FindErrorCallback errorCallback;
std::weak_ptr<IClientWrapper> clientWrapper;
- ListenErrorContext(FindCallback cb1, FindErrorCallback cb2,
+ ListenResListWithErrorContext(FindResListCallback cb1, FindErrorCallback cb2,
std::weak_ptr<IClientWrapper> cw)
: callback(cb1), errorCallback(cb2), clientWrapper(cw){}
};
DirectPairingContext(DirectPairingCallback cb) : callback(cb){}
};
+#ifdef TCP_ADAPTER
+ struct KeepAliveContext
+ {
+ KeepAliveCallback callback;
+ KeepAliveContext(KeepAliveCallback cb) : callback(cb){}
+ };
+#endif
#ifdef WITH_MQ
struct MQTopicContext
const std::string& resourceType, OCConnectivityType transportFlags,
FindCallback& callback, QualityOfService QoS);
- virtual OCStackResult ListenForResource2(const std::string& serviceUrl,
+ virtual OCStackResult ListenForResourceList(const std::string& serviceUrl,
const std::string& resourceType, OCConnectivityType transportFlags,
FindResListCallback& callback, QualityOfService QoS);
+ virtual OCStackResult ListenForResourceListWithError(const std::string& serviceUrl,
+ const std::string& resourceType, OCConnectivityType connectivityType,
+ FindResListCallback& callback, FindErrorCallback& errorCallback,
+ QualityOfService QoS);
+
virtual OCStackResult ListenErrorForResource(const std::string& serviceUrl,
const std::string& resourceType, OCConnectivityType transportFlags,
FindCallback& callback, FindErrorCallback& errorCallback, QualityOfService QoS);
MQTopicCallback& callback, QualityOfService QoS);
#endif
+ virtual OCStackResult stop();
+ virtual OCStackResult start();
+
+#ifdef TCP_ADAPTER
+ virtual OCStackResult findKeepAliveResource(std::string host,
+ KeepAliveCallback resultCallback);
+ virtual OCStackResult sendKeepAliveRequest(std::string host, const OCRepresentation& rep,
+ KeepAliveCallback resultCallback);
+#endif
+
private:
void listeningFunc();
std::string assembleSetResourceUri(std::string uri, const QueryParamsMap& queryParams);