#include <mutex>
#include <condition_variable>
#include <iostream>
+#include <mutex>
+
+#define DO_ACTION "DoAction"
+#define GET_ACTIONSET "GetActionSet"
+#define ACTIONSET "ActionSet"
+#define DELETE_ACTIONSET "DelActionSet"
using namespace std;
using namespace OC;
namespace PH = std::placeholders;
+std::mutex resourceLock;
OCResourceHandle resourceHandle;
-
shared_ptr< OCResource > g_resource;
vector< string > lights;
-
std::mutex blocker;
std::condition_variable cv;
void foundResource(std::shared_ptr< OCResource > resource)
{
+ std::lock_guard<std::mutex> lock(resourceLock);
+ if(g_resource)
+ {
+ std::cout << "Found another resource, ignoring"<<std::endl;
+ return;
+ }
+
std::string resourceURI;
std::string hostAddress;
{
string resourceURI = resource->uri();
cout << resourceURI << endl;
+ cout << "HOST :: " << resource->host() << endl;
if (resourceURI == "/core/a/collection")
{
g_resource = resource;
+ resource->get("", DEFAULT_INTERFACE, QueryParamsMap(), onGet);
}
-
- g_resource->get("", DEFAULT_INTERFACE, QueryParamsMap(), onGet);
printf("HOST :: %s\n", resource->host().c_str());
}
}
catch (std::exception& e)
{
- std::cout << "" << std::endl;
+ std::cerr << "Exception in foundResource: "<< e.what() << std::endl;
}
}
}
}
-string buildActionSetDesc()
+string buildActionSetDesc(unsigned int delay = 0, unsigned int type = 0)
{
string actionsetDesc = "";
actionsetDesc = "allbulboff";
actionsetDesc.append("*");
+ actionsetDesc.append(std::to_string(delay)); // Set delay time.
+ actionsetDesc.append(" ");
+ actionsetDesc.append(std::to_string(type)); // Set action type.
+ actionsetDesc.append("*");
for (auto iter = lights.begin(); iter != lights.end(); ++iter)
{
actionsetDesc.append("uri=").append((*iter));
int main(int argc, char* argv[])
{
ostringstream requestURI;
- requestURI << OC_WELL_KNOWN_QUERY << "?rt=a.collection";
-
- OCConnectivityType connectivityType = OC_WIFI;
-
- if(argc == 2)
- {
- try
- {
- std::size_t inputValLen;
- int optionSelected = stoi(argv[1], &inputValLen);
-
- if(inputValLen == strlen(argv[1]))
- {
- if(optionSelected == 0)
- {
- connectivityType = OC_ETHERNET;
- }
- else if(optionSelected == 1)
- {
- connectivityType = OC_WIFI;
- }
- else
- {
- std::cout << "Invalid connectivity type selected. Using default WIFI"
- << std::endl;
- }
- }
- else
- {
- std::cout << "Invalid connectivity type selected. Using default WIFI" << std::endl;
- }
- }
- catch(exception& e)
- {
- std::cout << "Invalid input argument. Using WIFI as connectivity type" << std::endl;
- }
- }
- else
- {
- std::cout<<"Usage: groupclient <ConnectivityType(0|1)>\n";
- std::cout<<"ConnectivityType: Default WIFI\n";
- std::cout<<"ConnectivityType 0: ETHERNET\n";
- std::cout<<"ConnectivityType 1: WIFI\n";
- }
+ requestURI << OC_RSRVD_WELL_KNOWN_URI << "?rt=a.collection";
PlatformConfig config
{ OC::ServiceType::InProc, ModeType::Client, "0.0.0.0", 0, OC::QualityOfService::LowQos };
string resourceTypeName = "a.collection";
OCPlatform::findResource("", requestURI.str(),
- connectivityType, &foundResource);
+ CT_DEFAULT, &foundResource);
//Non-intensive block until foundResource callback is called by OCPlatform
//and onGet gets resource.
}
break;
case 2:
- rep.setValue("DoAction", std::string("allbulboff"));
+ rep.setValue(DO_ACTION, std::string("allbulboff"));
if (g_resource)
{
g_resource->post("a.collection", GROUP_INTERFACE, rep, QueryParamsMap(),
}
break;
case 3:
- rep.setValue("GetActionSet", std::string("allbulboff"));
+ rep.setValue(GET_ACTIONSET, std::string("allbulboff"));
if (g_resource)
{
g_resource->post("a.collection", GROUP_INTERFACE, rep, QueryParamsMap(),
}
return 0;
}
+