resource/csdk/stack/test/linux/occlient.c

   1 //******************************************************************
   2 //
   3 // Copyright 2014 Intel Mobile Communications GmbH All Rights Reserved.
   4 //
   5 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
   6 //
   7 // Licensed under the Apache License, Version 2.0 (the "License");
   8 // you may not use this file except in compliance with the License.
   9 // You may obtain a copy of the License at
  10 //
  11 //      http://www.apache.org/licenses/LICENSE-2.0
  12 //
  13 // Unless required by applicable law or agreed to in writing, software
  14 // distributed under the License is distributed on an "AS IS" BASIS,
  15 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16 // See the License for the specific language governing permissions and
  17 // limitations under the License.
  18 //
  19 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
  20
  21
  22 #include <stdio.h>
  23 #include <stdlib.h>
  24 #include <string.h>
  25 #include <signal.h>
  26 #include <unistd.h>
  27 #include <ocstack.h>
  28 #include <logger.h>
  29
  30 #define TAG PCF("occlient")
  31
  32 int gQuitFlag = 0;
  33
  34 /* SIGINT handler: set gQuitFlag to 1 for graceful termination */
  35 void handleSigInt(int signum) {
  36     if (signum == SIGINT) {
  37         gQuitFlag = 1;
  38     }
  39 }
  40
  41 // This is a function called back when a device is discovered
  42 OCStackApplicationResult applicationDiscoverCB(
  43         OCClientResponse * clientResponse) {
  44     uint8_t remoteIpAddr[4];
  45     uint16_t remotePortNu;
  46     OC_LOG(INFO, TAG, "Entering applicationDiscoverCB (Application Layer CB)");
  47     OCDevAddrToIPv4Addr((OCDevAddr *) clientResponse->addr, remoteIpAddr,
  48             remoteIpAddr + 1, remoteIpAddr + 2, remoteIpAddr + 3);
  49     OCDevAddrToPort((OCDevAddr *) clientResponse->addr, &remotePortNu);
  50     OC_LOG_V(INFO, TAG, "Device =============> Discovered %s @ %d.%d.%d.%d:%d",clientResponse->resJSONPayload,remoteIpAddr[0], remoteIpAddr[1], remoteIpAddr[2], remoteIpAddr[3], remotePortNu);
  51     //return OC_STACK_DELETE_TRANSACTION;
  52     return OC_STACK_KEEP_TRANSACTION;
  53 }
  54
  55 int main() {
  56     OC_LOG_V(INFO, TAG, "Starting occlient on address %s",addr);
  57
  58     /* Initialize OCStack*/
  59     if (OCInit(NULL, 0, OC_CLIENT) != OC_STACK_OK) {
  60         OC_LOG(ERROR, TAG, "OCStack init error");
  61         return 0;
  62     }
  63
  64     /* Start a discovery query*/
  65     char szQueryUri[64] = { 0 };
  66     strcpy(szQueryUri, OC_EXPLICIT_DEVICE_DISCOVERY_URI);
  67     if (OCDoResource(NULL, OC_REST_GET, szQueryUri, 0, 0, OC_LOW_QOS,
  68             0, 0, 0) != OC_STACK_OK) {
  69         OC_LOG(ERROR, TAG, "OCStack resource error");
  70         return 0;
  71     }
  72
  73     // Break from loop with Ctrl+C
  74     OC_LOG(INFO, TAG, "Entering occlient main loop...");
  75     signal(SIGINT, handleSigInt);
  76     while (!gQuitFlag) {
  77
  78         if (OCProcess() != OC_STACK_OK) {
  79             OC_LOG(ERROR, TAG, "OCStack process error");
  80             return 0;
  81         }
  82
  83         sleep(1);
  84     }OC_LOG(INFO, TAG, "Exiting occlient main loop...");
  85
  86     if (OCStop() != OC_STACK_OK) {
  87         OC_LOG(ERROR, TAG, "OCStack stop error");
  88     }
  89
  90     return 0;
  91 }
  92