#include <stdexcept>
#include <condition_variable>
#include <mutex>
+#include <atomic>
#include "OCPlatform.h"
#include "OCApi.h"
const uint16_t API_VERSION = 2048;
const uint16_t TOKEN = 3000;
+static void printUsage()
+{
+ std::cout << "Usage: fridgeclient <0|1>" <<std::endl;
+ std::cout << "connectivityType: Default IP" << std::endl;
+ std::cout << "connectivityType 0: IP" << std::endl;
+}
class ClientFridge
{
public:
- ClientFridge()
+ ClientFridge(OCConnectivityType ct): m_callbackCount(0),
+ m_callsMade(0),m_connectivityType(ct)
{
+ std::ostringstream requestURI;
+ requestURI << OC_RSRVD_WELL_KNOWN_URI << "?rt=intel.fridge";
std::cout << "Fridge Client has started " <<std::endl;
FindCallback f (std::bind(&ClientFridge::foundDevice, this, PH::_1));
-
OCStackResult result = OCPlatform::findResource(
- "", "coap://224.0.1.187/oc/core?rt=intel.fridge", f);
+ "", requestURI.str(), CT_DEFAULT, f);
if(OC_STACK_OK != result)
{
// its duties, so we block on the CV until we have completed
// what we are looking to do
std::unique_lock<std::mutex> lk(m_mutex);
- m_cv.wait(lk);
+ m_cv.wait(lk, [this]{ return m_callbackCount!=0 && m_callbackCount == m_callsMade;});
}
}
std::vector<std::string> lightTypes = {"intel.fridge.light"};
std::vector<std::string> ifaces = {DEFAULT_INTERFACE};
OCResource::Ptr light = constructResourceObject(resource->host(),
- "/light", false, lightTypes, ifaces);
+ "/light", m_connectivityType, false, lightTypes, ifaces);
if(!light)
{
}
std::vector<std::string> doorTypes = {"intel.fridge.door"};
-
OCResource::Ptr leftdoor = constructResourceObject(resource->host(),
- "/door/left", false, doorTypes, ifaces);
+ "/door/left", m_connectivityType, false, doorTypes, ifaces);
+
if(!leftdoor)
{
std::cout << "Error: Left Door Resource Object construction returned null\n";
}
OCResource::Ptr rightdoor = constructResourceObject(resource->host(),
- "/door/right", false, doorTypes, ifaces);
+ "/door/right", m_connectivityType, false, doorTypes, ifaces);
+
if(!rightdoor)
{
std::cout << "Error: Right Door Resource Object construction returned null\n";
}
OCResource::Ptr randomdoor = constructResourceObject(resource->host(),
- "/door/random", false, doorTypes, ifaces);
+ "/door/random", m_connectivityType, false, doorTypes, ifaces);
if(!randomdoor)
{
std::cout << "Error: Random Door Resource Object construction returned null\n";
// Below, header options are set only for device resource
resource->setHeaderOptions(headerOptions);
+ ++m_callsMade;
resource->get(QueryParamsMap(), GetCallback(
std::bind(&ClientFridge::getResponse, this, "Device", PH::_1,
PH::_2, PH::_3, resource, 0)
));
+ ++m_callsMade;
light->get(QueryParamsMap(), GetCallback(
std::bind(&ClientFridge::getResponse, this, "Fridge Light", PH::_1,
PH::_2, PH::_3, light, 1)
));
+ ++m_callsMade;
leftdoor->get(QueryParamsMap(), GetCallback(
std::bind(&ClientFridge::getResponse, this, "Left Door", PH::_1,
PH::_2, PH::_3, leftdoor, 2)
));
+ ++m_callsMade;
rightdoor->get(QueryParamsMap(), GetCallback(
std::bind(&ClientFridge::getResponse, this, "Right Door", PH::_1,
PH::_2, PH::_3, rightdoor, 3)
));
+ ++m_callsMade;
randomdoor->get(QueryParamsMap(), GetCallback(
std::bind(&ClientFridge::getResponse, this, "Random Door", PH::_1,
PH::_2, PH::_3, randomdoor, 4)
));
+ ++m_callsMade;
resource->deleteResource(DeleteCallback(
std::bind(&ClientFridge::deleteResponse, this, "Device", PH::_1,
PH::_2, resource, 0)
// however be a better fit to wrap each call in an object so a fuller context (and additional
// requests) can be easily made inside of a simple context
void getResponse(const std::string& resourceName, const HeaderOptions& headerOptions,
- const OCRepresentation rep, const int eCode, OCResource::Ptr resource, int getId)
+ const OCRepresentation& rep, const int eCode, OCResource::Ptr resource, int getId)
{
std::cout << "Got a response from get from the " << resourceName << std::endl;
std::cout << "Get ID is "<<getId<<" and resource URI is " << resource->uri() << std::endl;
+ std::cout << "Get eCode is "<< eCode << std::endl;
printHeaderOptions(headerOptions);
break;
}
}
+ ++m_callbackCount;
+
+ if(m_callbackCount == m_callsMade)
+ {
+ m_cv.notify_all();
+ }
}
//Callback function to handle response for deleteResource call.
void deleteResponse(const std::string& resourceName, const HeaderOptions& headerOptions,
- const int eCode, OCResource::Ptr resource, int deleteId)
+ const int /*eCode*/, OCResource::Ptr resource, int deleteId)
{
std::cout << "Got a response from delete from the "<< resourceName << std::endl;
std::cout << "Delete ID is "<<deleteId<<" and resource URI is "<<resource->uri()<<std::endl;
printHeaderOptions(headerOptions);
+
+ ++m_callbackCount;
+
+ if(m_callbackCount == m_callsMade)
+ {
+ m_cv.notify_all();
+ }
}
//Function to print the headerOptions received from the server
std::mutex m_mutex;
std::condition_variable m_cv;
+ std::atomic<int> m_callbackCount;
+ std::atomic<int> m_callsMade;
+ OCConnectivityType m_connectivityType;
};
-int main()
+int main(int argc, char* argv[])
{
+ OCConnectivityType connectivityType = CT_ADAPTER_IP;
+ if(argc == 2)
+ {
+ try
+ {
+ std::size_t inputValLen;
+ int optionSelected = std::stoi(argv[1], &inputValLen);
+
+ if(inputValLen == strlen(argv[1]))
+ {
+ if(optionSelected == 0)
+ {
+ std::cout << "Using IP."<< std::endl;
+ connectivityType = CT_ADAPTER_IP;
+ }
+ else
+ {
+ std::cout << "Invalid connectivity type selected. Using default IP" << std::endl;
+ printUsage();
+ }
+ }
+ else
+ {
+ std::cout << "Invalid connectivity type selected. Using default IP" << std::endl;
+ }
+ }
+ catch(std::exception&)
+ {
+ std::cout << "Invalid input argument. Using IP as connectivity type" << std::endl;
+ }
+ }
+ else
+ {
+ printUsage();
+ std::cout << "Default input argument. Using IP as connectivity type" << std::endl;
+ }
+
PlatformConfig cfg
{
ServiceType::InProc,
};
OCPlatform::Configure(cfg);
- ClientFridge cf;
+ ClientFridge cf(connectivityType);
return 0;
}
+
projects / platform / upstream / iotivity.git / blobdiff