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 ("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     OIC_LOG(INFO, TAG, "Entering applicationDiscoverCB (Application Layer CB)");
  45     OIC_LOG_V(INFO, TAG, "Device =============> Discovered %s @ %s:%d",
  46                                     clientResponse->resJSONPayload,
  47                                     clientResponse->devAddr.addr,
  48                                     clientResponse->devAddr.port);
  49     //return OC_STACK_DELETE_TRANSACTION;
  50     return OC_STACK_KEEP_TRANSACTION;
  51 }
  52
  53 int main() {
  54     OIC_LOG_V(INFO, TAG, "Starting occlient on address %s",addr);
  55
  56     /* Initialize OCStack*/
  57     if (OCInit(NULL, 0, OC_CLIENT) != OC_STACK_OK) {
  58         OIC_LOG(ERROR, TAG, "OCStack init error");
  59         return 0;
  60     }
  61
  62     /* Start a discovery query*/
  63     char szQueryUri[64] = { 0 };
  64     strcpy(szQueryUri, OC_EXPLICIT_DEVICE_DISCOVERY_URI);
  65     if (OCDoResource(NULL, OC_REST_GET, szQueryUri, 0, 0, OC_LOW_QOS,
  66             0, 0, 0) != OC_STACK_OK) {
  67         OIC_LOG(ERROR, TAG, "OCStack resource error");
  68         return 0;
  69     }
  70
  71     // Break from loop with Ctrl+C
  72     OIC_LOG(INFO, TAG, "Entering occlient main loop...");
  73     signal(SIGINT, handleSigInt);
  74     while (!gQuitFlag) {
  75
  76         if (OCProcess() != OC_STACK_OK) {
  77             OIC_LOG(ERROR, TAG, "OCStack process error");
  78             return 0;
  79         }
  80
  81         sleep(1);
  82     }
  83
  84     OIC_LOG(INFO, TAG, "Exiting occlient main loop...");
  85
  86     if (OCStop() != OC_STACK_OK) {
  87         OIC_LOG(ERROR, TAG, "OCStack stop error");
  88     }
  89
  90     return 0;
  91 }
  92