orte/examples/reliable/BestEffortSubscriber.c

   1 /*
   2  *  $Id: BestEffortSubscriber.c,v 0.0.0.1 2003/12/27
   3  *
   4  *  DEBUG:  section                     ReliableSubscriber
   5  *  AUTHOR: Petr Smolik                 petr.smolik@wo.cz
   6  *
   7  *  ORTE - OCERA Real-Time Ethernet     http://www.ocera.org/
   8  *  --------------------------------------------------------------------
   9  *
  10  *  This program is free software; you can redistribute it and/or modify
  11  *  it under the terms of the GNU General Public License as published by
  12  *  the Free Software Foundation; either version 2 of the License, or
  13  *  (at your option) any later version.
  14  *
  15  *  This program is distributed in the hope that it will be useful,
  16  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  17  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  18  *  GNU General Public License for more details.
  19  *
  20  */
  21
  22 #include <stdio.h>
  23 #ifdef __RTL__
  24   #include <posix/pthread.h>
  25 #endif
  26 #include "orte_api.h"
  27
  28 ORTEDomain        *d;
  29 char              instance2Recv[64];
  30
  31 void
  32 recvCallBack(const ORTERecvInfo *info,void *vinstance, void *recvCallBackParam) {
  33   char *instance=(char*)vinstance;
  34
  35   switch (info->status) {
  36     case NEW_DATA:
  37       printf("%s\n",instance);
  38       break;
  39     case DEADLINE:
  40       printf("deadline occured\n");
  41       break;
  42   }
  43 }
  44
  45
  46 int
  47 main(int argc, char *args[]) {
  48   ORTESubscription *s;
  49   NtpTime         deadline,minimumSeparation;
  50
  51   ORTEInit();
  52   //ORTEVerbositySetOptions("ALL,10");
  53   d=ORTEDomainAppCreate(ORTE_DEFAULT_DOMAIN,NULL,NULL);
  54   ORTETypeRegisterAdd(d,"HelloMsg",NULL,NULL,64);
  55   NTPTIME_BUILD(deadline,3);
  56   NTPTIME_BUILD(minimumSeparation,0);
  57   s=ORTESubscriptionCreate(
  58        d,
  59        IMMEDIATE,
  60        BEST_EFFORTS,
  61        "Reliable HelloMsg",
  62        "HelloMsg",
  63        &instance2Recv,
  64        &deadline,
  65        &minimumSeparation,
  66        recvCallBack,
  67        NULL);
  68   #ifndef __RTL__
  69   while (1)
  70     ORTESleepMs(1000);
  71   #endif
  72   return 0;
  73 }
  74
  75 #ifdef __RTL__
  76 void
  77 hello_init(void) {
  78   main(0,NULL);
  79 }
  80 void
  81 hello_exit(void) {
  82   ORTEDomainAppDestroy(d);
  83 }
  84 MODULE_LICENSE("GPL");
  85 module_init(hello_init);
  86 module_exit(hello_exit);
  87 #endif
  88