tests/converse/megacon/specmsg.c

   1 #include <stdio.h>
   2 #include <converse.h>
   3
   4 typedef struct specmsg_chare_s
   5 {
   6   int next;
   7 }
   8 *specmsg_chare;
   9
  10 CpmDeclareSimple(specmsg_chare);
  11 #define CpmPack_specmsg_chare(x) (0)
  12 #define CpmUnpack_specmsg_chare(x) (0)
  13
  14 #include "specmsg.cpm.h"
  15
  16 void Cpm_megacon_ack(CpmDestination);
  17
  18 void specmsg_fail()
  19 {
  20   CmiError("specmsg: CmiDeliverSpecificMsg failed.\n");
  21   exit(1);
  22 }
  23
  24 CpmInvokable specmsg_step1(specmsg_chare c)
  25 {
  26   if (c->next != 1) specmsg_fail();
  27   c->next++;
  28 }
  29
  30 CpmInvokable specmsg_step2(specmsg_chare c)
  31 {
  32   if (c->next != 2) specmsg_fail();
  33   c->next++;
  34 }
  35
  36 CpmInvokable specmsg_step3(specmsg_chare c)
  37 {
  38   if (c->next != 3) specmsg_fail();
  39   c->next++;
  40 }
  41
  42 CpmInvokable specmsg_step4(specmsg_chare c)
  43 {
  44   if (c->next != 4) specmsg_fail();
  45   c->next++;
  46 }
  47
  48 CpmInvokable specmsg_begin()
  49 {
  50   struct specmsg_chare_s c;
  51   int i;
  52   Cpm_specmsg_request(CpmSend(0), CmiMyPe(), &c);
  53   if (CmiMyPe()==0)
  54     for (i=0; i<CmiNumPes(); i++)
  55       CmiDeliverSpecificMsg(CpvAccess(CpmIndex_specmsg_request));
  56   c.next = 1;
  57   CmiDeliverSpecificMsg(CpvAccess(CpmIndex_specmsg_step1));
  58   CmiDeliverSpecificMsg(CpvAccess(CpmIndex_specmsg_step2));
  59   CmiDeliverSpecificMsg(CpvAccess(CpmIndex_specmsg_step3));
  60   CmiDeliverSpecificMsg(CpvAccess(CpmIndex_specmsg_step4));
  61   Cpm_megacon_ack(CpmSend(0));
  62 }
  63
  64 CpmInvokable specmsg_request(int pe, specmsg_chare c)
  65 {
  66   Cpm_specmsg_step3(CpmSend(pe), c);
  67   Cpm_specmsg_step2(CpmSend(pe), c);
  68   Cpm_specmsg_step4(CpmSend(pe), c);
  69   Cpm_specmsg_step1(CpmSend(pe), c);
  70 }
  71
  72 void specmsg_init()
  73 {
  74   int pe;
  75   for (pe=1; pe<CmiNumPes(); pe++)
  76     Cpm_specmsg_begin(CpmSend(pe));
  77   specmsg_begin();
  78 }
  79
  80 void specmsg_moduleinit()
  81 {
  82   CpmInitializeThisModule();
  83 }
  84