grepimpl.hpp

mysql-5.0.22.tar.gz源码包

/**
 * @class GrepSubSyncRef
 * @brief
 */
class GrepSubSyncRef {
  /**
   * Sender(s)/Reciver(s)
   */
  friend class Grep;
  
  friend bool printGREP_SUB_SYNC_REF(FILE *, 
				     const Uint32 *, 
				     Uint32, 
				     Uint16);
public:
  STATIC_CONST( SignalLength = 6 );
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
  Uint32 senderRef;
  Uint32 err;
  Uint32 senderData;
  Uint32 part;
};


/**
 * @class GrepSubSyncConf
 * @brief
 */
class GrepSubSyncConf {
   /**
    * Sender(s)/Reciver(s)
   */
   friend class Grep;
   
   friend bool printGREP_SUB_SYNC_CONF(FILE *, 
				       const Uint32 *, 
				       Uint32, 
				       Uint16);
 public:
   STATIC_CONST( SignalLength = 7 );
   Uint32 subscriptionId;
   Uint32 subscriptionKey;
   Uint32 senderRef;
   Uint32 senderData;
   Uint32 part;
   Uint32 firstGCI;
   Uint32 lastGCI;
};



/*****************************************************************************
 * SCAN (SYNC)  Internal between PS DB nodes
 *****************************************************************************/

/**
 * @class GrepSyncReq
 * @brief
 */
class GrepSyncReq {
  /**
   * Sender(s)/Reciver(s)
   */
  friend class GrepParticipant;
  
  friend bool printGREP_SYNC_REQ(FILE *, 
				   const Uint32 *, 
				   Uint32, 
				   Uint16);
public:
  STATIC_CONST( SignalLength = 4 );
 
  Uint32 senderData;
  Uint32 part;
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
};


/**
 * @class GrepSyncRef
 * @brief
 */
class GrepSyncRef {
  /**
   * Sender(s)/Reciver(s)
   */

  friend class GrepParticipant;  

  friend bool printGREP_SYNC_REF(FILE *, 
				 const Uint32 *, 
				 Uint32, 
				 Uint16);
public:
  enum ErrorCode {
    NF_FakeErrorREF = GrepError::NF_FakeErrorREF
  };
  STATIC_CONST( SignalLength = 6 );
  Uint32 senderRef;
  Uint32 senderData;
  Uint32 part;
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
  union {
    Uint32 err;
    Uint32 errorCode;
  };
};


/**
 * @class GrepSyncConf
 * @brief
 */
class GrepSyncConf 
{
  /**
   * Sender(s)/Reciver(s)
   */
  friend class GrepParticipant;
  
  friend bool printGREP_SYNC_CONF(FILE *, const Uint32 *, Uint32, Uint16);

public:
  STATIC_CONST( SignalLength = 8 );
  Uint32 senderRef;
  Uint32 senderData;
  Uint32 part;
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
  Uint32 senderNodeId;
  Uint32 firstGCI;
  Uint32 lastGCI;
};

/*****************************************************************************
 * ABORT - remove subscription
 *****************************************************************************/

/**
 * @class GrepSubRemoveReq
 * @brief Between PS and SS
 */
class GrepSubRemoveReq {
  /**
   * Sender(s)/Reciver(s)
   */
  friend class Grep;
  
  friend bool printGREP_SUB_REMOVE_REQ(FILE *, const Uint32 *, 
				       Uint32, Uint16);
public:
  STATIC_CONST( SignalLength = 4 );

  Uint32 senderRef;
  Uint32 senderData;
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
};


/**
 * @class GrepSubRemoveRef
 * @brief Between PS and SS
 */
class GrepSubRemoveRef {
  /**
   * Sender(s)/Reciver(s)
   */
  friend class Grep;
  
  friend bool printGREP_SUB_REMOVE_REF(FILE *, const Uint32 *, 
				       Uint32, Uint16);
public:
  STATIC_CONST( SignalLength = 5 );

  Uint32 senderRef;
  Uint32 senderData;
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
  Uint32 err;
};


/**
 * @class 
 * @brief
 */
class GrepSubRemoveConf {
  /**
   * Sender(s)/Reciver(s)
   */
  friend class Grep;
  
  friend bool printGREP_SUB_REMOVE_CONF(FILE *, 
				      const Uint32 *, 
				      Uint32, 
				      Uint16);
public:
  STATIC_CONST( SignalLength = 4 );

  Uint32 senderRef;
  Uint32 senderData;
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
};


/**
 * @class 
 * @brief
 */
class GrepRemoveReq {
  /**
   * Sender(s)/Reciver(s)
   */
  friend class GrepParticipant;
  
  friend bool printGREP_REMOVE_REQ(FILE *, 
				   const Uint32 *, 
				   Uint32, 
				   Uint16);
public:
  STATIC_CONST( SignalLength = 4 );
 
  Uint32 senderRef;
  Uint32 senderData;
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
};


/**
 * @class 
 * @brief
 */
class GrepRemoveRef {
  /**
   * Sender(s)/Reciver(s)
   */

  friend class GrepParticipant;  

  friend bool printGREP_REMOVE_REF(FILE *, 
				 const Uint32 *, 
				 Uint32, 
				 Uint16);
public:
  enum ErrorCode {
    NF_FakeErrorREF = GrepError::NF_FakeErrorREF
  };
  STATIC_CONST( SignalLength = 5 );
  Uint32 senderRef;
  Uint32 senderData;
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
  union {
    Uint32 err;
    Uint32 errorCode;
  };
};


/**
 * @class 
 * @brief
 */
class GrepRemoveConf {
  /**
   * Sender(s)/Reciver(s)
   */

  friend class GrepParticipant;
  
  friend bool printGREP_REMOVE_CONF(FILE *, 
				    const Uint32 *, 
				    Uint32, 
				    Uint16);
public:
  STATIC_CONST( SignalLength = 5 );
  Uint32 senderRef;
  Uint32 senderData; 
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
  Uint32 senderNodeId;
};


/*****************************************************************************
 * WAIT FOR CGP
 *****************************************************************************/

/**
 * @class GrepWaitGcpReq
 * @brief
 */
class GrepWaitGcpReq {
  /**
   * Sender(s)/Reciver(s)
   */

  friend class GrepParticipant;
  
  friend bool printGREP_WAITGCP_REQ(FILE *, const Uint32 *, 
				    Uint32, Uint16);
public:
  STATIC_CONST( SignalLength = 5 );
  
  Uint32 senderData;
  Uint32 gcp;
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
  Uint32 senderNodeId;
};

/**
 * @class GrepWaitGcpConf
 * @brief
 */
class GrepWaitGcpConf {
  /**
   * Sender(s)/Reciver(s)
   */

  friend class GrepParticipant;
  
  friend bool printGREP_WAITGCP_CONF(FILE *, 
				     const Uint32 *, 
				     Uint32, 
				     Uint16);
public:
  STATIC_CONST( SignalLength = 4 );
  
  Uint32 senderData;
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
  Uint32 senderNodeId;
};



class GrepCreateSubscriptionIdConf {
  friend class Grep;
  
  friend bool printGREP_CREATE_SUBSCRIPTION_ID_CONF(FILE *, const Uint32 *, 
					       Uint32, Uint16);
public:
  STATIC_CONST( SignalLength = 3 );
  
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
  union { // Haven't decide what to call it
    Uint32 senderData;
    Uint32 subscriberData;
  };
};



class GrepStartMe {
  friend class Grep;  
  friend bool printGREP_START_ME(FILE *, const Uint32 *, 
				 Uint32, Uint16);
public:
  STATIC_CONST( SignalLength = 1 );
  Uint32 senderRef;
};




/**
 * @class GrepAddSubReq
 * @brief
 */
class GrepAddSubReq {
  /**
   * Sender(s)/Reciver(s)
   */
  friend class GrepParticipant;
  
  friend bool printGREP_ADD_SUB_REQ(FILE *, 
				    const Uint32 *, 
				    Uint32, 
				    Uint16);
public:
  STATIC_CONST( SignalLength = 7 );
  Uint32 senderRef;
  Uint32 senderData;
  Uint32 subscriberData;
  Uint32 subscriberRef;
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
  Uint32 subscriptionType;
};


/**
 * @class GrepAddSubRef
 * @brief
 */
class GrepAddSubRef {
  /**
   * Sender(s)/Reciver(s)
   */

  friend class GrepParticipant;  

  friend bool printGREP_CREATE_REF(FILE *, 
				   const Uint32 *, 
				   Uint32, 
				   Uint16);
public:
  STATIC_CONST( SignalLength = 5 );
  Uint32 senderData;
  Uint32 err;
  Uint32 subscriptionId;
  Uint32 subscriptionKey;
  Uint32 subscriptionType;
};


/**
 * @class GrepAddSubConf
 * @brief
 */
class GrepAddSubConf {
  /**
   * Sender(s)/Reciver(s)
   */

  friend class GrepParticipant;
  
  friend bool printGREP_CREATE_CONF(FILE *, 
				   const Uint32 *, 
				   Uint32, 
				   Uint16);
public:
  STATIC_CONST( SignalLength = 1 );
  Uint32 noOfSub;
};

#endif