orte/examples/mpo/ddso/ddso_cb.c

   1 #include <stdio.h>
   2 #include <orte.h>
   3 #include <ddso.h>
   4
   5 void
   6 ofb_cbs_octet(const ORTESendInfo *info, void *vinstance, void *sendCallBackParam)
   7 {
   8   ofb_octet *instance = (ofb_octet *)vinstance;
   9
  10   switch (info->status) {
  11     case NEED_DATA:
  12       instance->value++;
  13       break;
  14     case CQL:  //criticalQueueLevel
  15       break;
  16   }
  17 }
  18
  19 void
  20 ofb_cbr_octet(const ORTERecvInfo *info, void *vinstance, void *recvCallBackParam)
  21 {
  22   ofb_octet *instance = (ofb_octet *)vinstance;
  23
  24   switch (info->status) {
  25     case NEW_DATA:
  26       printf("GUID:0x%x, value:%d\n", instance->guid, instance->value);
  27       break;
  28     case CQL:  //criticalQueueLevel
  29       break;
  30   }
  31 }
  32
  33 void
  34 ofb_cbs_short(const ORTESendInfo *info, void *vinstance, void *sendCallBackParam)
  35 {
  36   ofb_short *instance = (ofb_short *)vinstance;
  37
  38   switch (info->status) {
  39     case NEED_DATA:
  40       instance->value++;
  41       break;
  42     case CQL:  //criticalQueueLevel
  43       break;
  44   }
  45 }
  46
  47 void
  48 ofb_cbr_short(const ORTERecvInfo *info, void *vinstance, void *recvCallBackParam)
  49 {
  50   ofb_short *instance = (ofb_short *)vinstance;
  51
  52   switch (info->status) {
  53     case NEW_DATA:
  54       printf("GUID:0x%x, value:%d\n", instance->guid, instance->value);
  55       break;
  56     case CQL:  //criticalQueueLevel
  57       break;
  58   }
  59 }
  60
  61 void
  62 ofb_cbs_long(const ORTESendInfo *info, void *vinstance, void *sendCallBackParam)
  63 {
  64   ofb_long *instance = (ofb_long *)vinstance;
  65
  66   switch (info->status) {
  67     case NEED_DATA:
  68       instance->value++;
  69       break;
  70     case CQL:  //criticalQueueLevel
  71       break;
  72   }
  73 }
  74
  75 void
  76 ofb_cbr_long(const ORTERecvInfo *info, void *vinstance, void *recvCallBackParam)
  77 {
  78   ofb_long *instance = (ofb_long *)vinstance;
  79
  80   switch (info->status) {
  81     case NEW_DATA:
  82       printf("GUID:0x%x, value:%d\n", instance->guid, instance->value);
  83       break;
  84     case CQL:  //criticalQueueLevel
  85       break;
  86   }
  87 }