X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=resource%2Finclude%2FInProcClientWrapper.h;h=62830d57acc9212a601219aca758c32274bfb3f2;hb=390866079e285d2c74918432c0d597d5da52f8a0;hp=ced111d4490048ab357024e77d03b68a4aa30b8a;hpb=00b3660e45c56cb3db35dc2596a054f801b5591a;p=platform%2Fupstream%2Fiotivity.git diff --git a/resource/include/InProcClientWrapper.h b/resource/include/InProcClientWrapper.h index ced111d..62830d5 100644 --- a/resource/include/InProcClientWrapper.h +++ b/resource/include/InProcClientWrapper.h @@ -18,8 +18,8 @@ // //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-= -#ifndef _IN_PROC_CLIENT_WRAPPER_H_ -#define _IN_PROC_CLIENT_WRAPPER_H_ +#ifndef OC_IN_PROC_CLIENT_WRAPPER_H_ +#define OC_IN_PROC_CLIENT_WRAPPER_H_ #include #include @@ -27,7 +27,6 @@ #include #include -#include #include #include #include @@ -39,38 +38,48 @@ namespace OC struct GetContext { GetCallback callback; + GetContext(GetCallback cb) : callback(cb){} }; struct SetContext { PutCallback callback; + SetContext(PutCallback cb) : callback(cb){} }; struct ListenContext { FindCallback callback; std::weak_ptr clientWrapper; + + ListenContext(FindCallback cb, std::weak_ptr cw) + : callback(cb), clientWrapper(cw){} }; struct DeviceListenContext { FindDeviceCallback callback; IClientWrapper::Ptr clientWrapper; + DeviceListenContext(FindDeviceCallback cb, IClientWrapper::Ptr cw) + : callback(cb), clientWrapper(cw){} }; struct SubscribePresenceContext { SubscribeCallback callback; + SubscribePresenceContext(SubscribeCallback cb) : callback(cb){} }; struct DeleteContext { DeleteCallback callback; + DeleteContext(DeleteCallback cb) : callback(cb){} }; struct ObserveContext { ObserveCallback callback; + ObserveContext(ObserveCallback cb) : callback(cb){} }; } @@ -84,49 +93,65 @@ namespace OC virtual ~InProcClientWrapper(); virtual OCStackResult ListenForResource(const std::string& serviceUrl, - const std::string& resourceType, FindCallback& callback, - QualityOfService QoS); + const std::string& resourceType, OCConnectivityType transportFlags, + FindCallback& callback, QualityOfService QoS); virtual OCStackResult ListenForDevice(const std::string& serviceUrl, - const std::string& deviceURI, FindDeviceCallback& callback, - QualityOfService QoS); + const std::string& deviceURI, OCConnectivityType transportFlags, + FindDeviceCallback& callback, QualityOfService QoS); - virtual OCStackResult GetResourceRepresentation(const std::string& host, - const std::string& uri, const QueryParamsMap& queryParams, - const HeaderOptions& headerOptions, + virtual OCStackResult GetResourceRepresentation( + const OCDevAddr& devAddr, + const std::string& uri, + const QueryParamsMap& queryParams, const HeaderOptions& headerOptions, GetCallback& callback, QualityOfService QoS); - virtual OCStackResult PutResourceRepresentation(const std::string& host, - const std::string& uri, const OCRepresentation& attributes, - const QueryParamsMap& queryParams, const HeaderOptions& headerOptions, - PutCallback& callback, QualityOfService QoS); + virtual OCStackResult PutResourceRepresentation( + const OCDevAddr& devAddr, + const std::string& uri, + const OCRepresentation& attributes, const QueryParamsMap& queryParams, + const HeaderOptions& headerOptions, PutCallback& callback, QualityOfService QoS); + + virtual OCStackResult PostResourceRepresentation( + const OCDevAddr& devAddr, + const std::string& uri, + const OCRepresentation& attributes, const QueryParamsMap& queryParams, + const HeaderOptions& headerOptions, PostCallback& callback, QualityOfService QoS); + + virtual OCStackResult DeleteResource( + const OCDevAddr& devAddr, + const std::string& uri, + const HeaderOptions& headerOptions, + DeleteCallback& callback, QualityOfService QoS); - virtual OCStackResult PostResourceRepresentation(const std::string& host, - const std::string& uri, const OCRepresentation& attributes, + virtual OCStackResult ObserveResource( + ObserveType observeType, OCDoHandle* handle, + const OCDevAddr& devAddr, + const std::string& uri, const QueryParamsMap& queryParams, const HeaderOptions& headerOptions, - PostCallback& callback, QualityOfService QoS); - - virtual OCStackResult DeleteResource(const std::string& host, const std::string& uri, - const HeaderOptions& headerOptions, DeleteCallback& callback, QualityOfService QoS); + ObserveCallback& callback, QualityOfService QoS); - virtual OCStackResult ObserveResource(ObserveType observeType, OCDoHandle* handle, - const std::string& host, const std::string& uri, const QueryParamsMap& queryParams, - const HeaderOptions& headerOptions, ObserveCallback& callback, QualityOfService QoS); + virtual OCStackResult CancelObserveResource( + OCDoHandle handle, + const std::string& host, + const std::string& uri, + const HeaderOptions& headerOptions, QualityOfService QoS); - virtual OCStackResult CancelObserveResource(OCDoHandle handle, const std::string& host, - const std::string& uri, const HeaderOptions& headerOptions, QualityOfService QoS); - - virtual OCStackResult SubscribePresence(OCDoHandle* handle, const std::string& host, - const std::string& resourceType, SubscribeCallback& presenceHandler); + virtual OCStackResult SubscribePresence( + OCDoHandle *handle, + const std::string& host, + const std::string& resourceType, + OCConnectivityType transportFlags, + SubscribeCallback& presenceHandler); virtual OCStackResult UnsubscribePresence(OCDoHandle handle); OCStackResult GetDefaultQos(QualityOfService& QoS); private: void listeningFunc(); std::string assembleSetResourceUri(std::string uri, const QueryParamsMap& queryParams); - std::string assembleSetResourcePayload(const OCRepresentation& attributes); - void assembleHeaderOptions(OCHeaderOption options[], - const HeaderOptions& headerOptions); + OCPayload* assembleSetResourcePayload(const OCRepresentation& attributes); + OCHeaderOption* assembleHeaderOptions(OCHeaderOption options[], + const HeaderOptions& headerOptions); std::thread m_listeningThread; bool m_threadRun; std::weak_ptr m_csdkLock; @@ -137,3 +162,4 @@ namespace OC } #endif +