开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
SignalCounter.hpp
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：3k
源码类别：

MySQL数据库

开发平台：

Visual C++

SignalCounter.hpp：源码内容
  1. /* Copyright (C) 2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  17. #ifndef SIGNAL_COUNTER_HPP
  18. #define SIGNAL_COUNTER_HPP
  20. #include <NodeBitmask.hpp>
  21. #include <ErrorReporter.hpp>
  23. class SignalCounter {
  24.   friend struct NodeReceiverGroup;
  25.   
  26. private:
  27.   Uint32 m_count;
  28.   NdbNodeBitmask m_nodes;
  30. public:
  31.   SignalCounter() { clearWaitingFor();}
  32.   void clearWaitingFor();
  33.   
  34.   /**
  35.    * When sending to different node
  36.    */
  37.   void setWaitingFor(Uint32 nodeId);
  38.   void clearWaitingFor(Uint32 nodeId);
  39.   void forceClearWaitingFor(Uint32 nodeId);
  40.   
  41.   bool isWaitingFor(Uint32 nodeId) const;
  42.   bool done() const;
  44.   const char * getText() const;
  46.   SignalCounter& operator=(const NdbNodeBitmask & bitmask);
  47.   SignalCounter& operator=(const NodeReceiverGroup& rg) { 
  48.     return (* this) = rg.m_nodes;
  49.   }
  51.   /**
  52.    * When sending to same node
  53.    */
  54.   SignalCounter& operator=(Uint32 count);
  55.   SignalCounter& operator--(int);
  56.   SignalCounter& operator++(int);
  57.   SignalCounter& operator+=(Uint32);
  58.   Uint32 getCount() const;
  59. };
  61. inline
  62. void 
  63. SignalCounter::setWaitingFor(Uint32 nodeId) {
  64.   if(!m_nodes.get(nodeId)){
  65.     m_nodes.set(nodeId);
  66.     m_count++;
  67.     return;
  68.   }
  69.   ErrorReporter::handleAssert("SignalCounter::set", __FILE__, __LINE__);
  70. }
  72. inline
  73. bool
  74. SignalCounter::isWaitingFor(Uint32 nodeId) const {
  75.   return m_nodes.get(nodeId);
  76. }
  78. inline
  79. bool
  80. SignalCounter::done() const {
  81.   return m_count == 0;
  82. }
  84. inline
  85. Uint32
  86. SignalCounter::getCount() const {
  87.   return m_count;
  88. }
  90. inline
  91. void
  92. SignalCounter::clearWaitingFor(Uint32 nodeId) {
  93.   if(m_nodes.get(nodeId) && m_count > 0){
  94.     m_count--;
  95.     m_nodes.clear(nodeId);
  96.     return;
  97.   }
  98.   ErrorReporter::handleAssert("SignalCounter::clear", __FILE__, __LINE__);
  99. }
  101. inline
  102. void
  103. SignalCounter::clearWaitingFor(){
  104.   m_count = 0;
  105.   m_nodes.clear();
  106. }
  108. inline
  109. void
  110. SignalCounter::forceClearWaitingFor(Uint32 nodeId){
  111.   if(isWaitingFor(nodeId)){
  112.     clearWaitingFor(nodeId);
  113.   }
  114. }
  116. inline
  117. SignalCounter&
  118. SignalCounter::operator=(Uint32 count){
  119.   m_count = count;
  120.   m_nodes.clear();
  121.   return * this;
  122. }
  124. inline
  125. SignalCounter&
  126. SignalCounter::operator--(int){
  127.   if(m_count > 0){
  128.     m_count--;
  129.     return * this;
  130.   }
  131.   ErrorReporter::handleAssert("SignalCounter::operator--", __FILE__, __LINE__);
  132.   return * this;
  133. }
  135. inline
  136. SignalCounter&
  137. SignalCounter::operator++(int){
  138.   m_count++;
  139.   return * this;
  140. }
  142. inline
  143. SignalCounter&
  144. SignalCounter::operator+=(Uint32 n){
  145.   m_count += n;
  146.   return * this;
  147. }
  149. inline
  150. const char *
  151. SignalCounter::getText() const {
  152.   static char buf[255];
  153.   static char nodes[NodeBitmask::TextLength+1];
  154.   BaseString::snprintf(buf, sizeof(buf), "[SignalCounter: m_count=%d %s]", m_count, m_nodes.getText(nodes));
  155.   return buf;
  156. }
  158. inline
  159. SignalCounter&
  160. SignalCounter::operator=(const NdbNodeBitmask & bitmask){
  161.   m_nodes = bitmask;
  162.   m_count = bitmask.count();
  163.   return * this;
  164. }
  166. #endif