通讯编程

开发平台：

Visual C++

pushback-message.h：源码内容

							#ifndef ns_pushback_message_h
#define ns_pushback_message_h
#define PUSHBACK_REQUEST_MSG     1 
#define PUSHBACK_REFRESH_MSG     2
#define PUSHBACK_STATUS_MSG      3
#define PUSHBACK_CANCEL_MSG      4
class AggSpec;
class PushbackMessage {
 public:
  int msgID_;
  int senderID_;
  int targetID_;
  //id details of the downstream PBA.
  int qid_;
  int rlsID_;
  void set(int msg, int sender, int dest, int qid, int rlsID) {
    msgID_ = msg;
    senderID_ = sender;
    targetID_ = dest;
    qid_ = qid;
    rlsID_=rlsID;
  }
  static char * type(PushbackMessage * msg) {
    switch (msg->msgID_) {
    case PUSHBACK_REQUEST_MSG: return "REQUEST";
    case PUSHBACK_REFRESH_MSG: return "REFRESH";
    case PUSHBACK_STATUS_MSG: return "STATUS";
    case PUSHBACK_CANCEL_MSG: return "CANCEL";
    default: return "UNKNOWN";
    }
  }
};
class PushbackRequestMessage : public PushbackMessage {
 public:
  AggSpec * aggSpec_;  
  double limit_;
  int depth_;          //depth of the sender. 
  PushbackRequestMessage(int sender, int dest, int qid, int rlsID, 
			 AggSpec * aggSpec, double limit, int depth) {
    set(PUSHBACK_REQUEST_MSG, sender, dest, qid, rlsID);
    aggSpec_ = aggSpec;
    limit_=limit;
    depth_ = depth;
  }
};
class PushbackStatusMessage : public PushbackMessage {
 public:
  double arrivalRate_;   //in bps as always.
  int height_;           //height of sender.
 
  PushbackStatusMessage(int sender, int dest, int qid, int rlsID, 
			double arrivalRate, int height) {
    set(PUSHBACK_STATUS_MSG, sender, dest, qid, rlsID);
    arrivalRate_ = arrivalRate;
    height_=height;
  }
};
class PushbackRefreshMessage : public PushbackMessage {
 public:
  AggSpec * aggSpec_;
  double limit_;
  
  PushbackRefreshMessage(int sender, int dest, int qid, int rlsID, 
			 AggSpec * aggSpec, double newLimit) {
    set(PUSHBACK_REFRESH_MSG, sender, dest, qid, rlsID);
    aggSpec_= aggSpec;
    limit_=newLimit;
  }
};
class PushbackCancelMessage : public PushbackMessage {
 public:
  
  PushbackCancelMessage(int sender, int dest, int qid, int rlsID) {
    set(PUSHBACK_CANCEL_MSG, sender, dest, qid, rlsID);
  }
};
#endif

						