src/ck-core/ckcallback-ccs.h

   1 /*
   2 Make CCS call a CkCallback instead of a flat C function.
   3
   4 Initial version by Orion Sky Lawlor, olawlor@acm.org, 2/8/2002
   5 */
   6 #ifndef _CKCALLBACK_CCS_H_
   7 #define _CKCALLBACK_CCS_H_
   8
   9 #include "charm++.h" /*for CkCallback, etc.*/
  10 #include "conv-ccs.h" /*for CcsDelayedReply struct*/
  11 #include "CkCallback.decl.h" /*for CMessage_CkCcsRequestMsg*/
  12
  13 /**
  14  * Message sent from CCS to callbacks.
  15  * You must eventually call CcsSendDelayedReply(msg->reply,...)
  16  * for each CCS-called callback.
  17  */
  18 class CkCcsRequestMsg : public CMessage_CkCcsRequestMsg {
  19 public:
  20         CcsDelayedReply reply; /*Object to send reply to*/
  21         int length; //Number of bytes of request data.
  22         char *data; //Actual data sent along with request.
  23 };
  24
  25 /**
  26  * Very generic message type: contains a bunch of bytes.
  27  */
  28 class CkDataMsg : public CMessage_CkDataMsg {
  29 public:
  30         int length; //Number of bytes of data below.
  31         char *data; //Message data.
  32         int checkTag; // For detecting message corruption
  33
  34         inline int getLength(void) const {return length;}
  35         inline int getSize(void) const {return length;}
  36         inline void *getData(void) const {return data;}
  37
  38         /// This is how you must create a CkDataMsg
  39         static CkDataMsg *buildNew(int length,const void *data);
  40
  41         void check(void);
  42 };
  43
  44
  45 #ifdef CcsRegisterHandler /*pollution from C conv-ccs header*/
  46 # undef CcsRegisterHandler
  47 #endif
  48
  49 /**
  50  * When a CCS request comes in from the network with this handlername,
  51  * call this callback with an appropriate CkCcsRequestMsg.
  52  * You must eventually call CcsSendDelayedReply(msg->reply,...)
  53  * each time this callback is activated.
  54  *
  55  * Unlike the regular converse CcsRegisterHandler (in conv-ccs.h),
  56  * this call need only be made once, on processor 0, and all processors
  57  * will be able to respond to the CCS request.
  58  */
  59 void CcsRegisterHandler(const char *ccs_handlername,const CkCallback &cb);
  60
  61
  62 #endif