Category

Development Platform
Home > SourceCode/Document > Database system > MySQL > View Code
OSE_Receiver.hpp
Package: mysql-4.1.16-win-src.zip　[view]
Upload User: romrleung
Upload Date: 2022-05-23
Package Size: 18897k
Code Size: 3k
Category:

MySQL

Development Platform:

Visual C++

OSE_Receiver.hpp：Code Content
  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 OSE_RECEIVER_HPP
  18. #define OSE_RECEIVER_HPP
  20. #include "ose.h"
  21. #include "OSE_Signals.hpp"
  22. #include <kernel_types.h>
  24. class OSE_Receiver {
  25. public:
  26.   OSE_Receiver(class TransporterRegistry *,
  27.        int recBufSize,
  28.        NodeId localNodeId);
  30.   ~OSE_Receiver();
  32.   bool hasData() const ;
  33.   bool isFull() const ;
  34.   
  35.   Uint32 getReceiveData(NodeId * remoteNodeId,
  36. Uint32 ** readPtr);
  37.   
  38.   void updateReceiveDataPtr(Uint32 szRead);
  39.   
  40.   bool doReceive(Uint32 timeOutMillis);
  42.   PROCESS createPhantom();
  43.   void destroyPhantom();
  44.   
  45. private:
  46.   class TransporterRegistry * theTransporterRegistry;
  47.   
  48.   NodeId localNodeId;
  49.   char localHostName[255];
  50.   
  51.   bool phantomCreated;
  52.   PROCESS phantomPid;
  53.   struct OS_redir_entry redir;
  54.   
  55.   int recBufReadIndex;
  56.   int recBufWriteIndex;
  57.   int recBufSize;
  58.   union SIGNAL **receiveBuffer;
  60.   // Stack for signals that are received out of order
  61.   int waitStackCount;
  62.   int waitStackSize;
  63.   union SIGNAL** waitStack;
  65.   // Counters for the next signal id
  66.   Uint32* nextSigId;
  68.   class OSE_Transporter * getTransporter(NodeId nodeId);
  70.   void insertReceiveBuffer(union SIGNAL * _sig);
  71.   void clearRecvBuffer(NodeId _nodeId);
  72.   bool checkWaitStack(NodeId _nodeId);
  73.   void clearWaitStack(NodeId _nodeId);
  74.   void insertWaitStack(union SIGNAL* _sig);
  75. };
  77. inline
  78. bool
  79. OSE_Receiver::hasData () const {
  80.   return recBufReadIndex != recBufWriteIndex;
  81. }
  83. inline
  84. bool
  85. OSE_Receiver::isFull () const {
  86.   return ((recBufWriteIndex + 1) % recBufSize) == recBufWriteIndex;
  87. }
  89. inline
  90. Uint32
  91. OSE_Receiver::getReceiveData(NodeId * remoteNodeId,
  92.      Uint32 ** readPtr){
  93.   NdbTransporterData *s = (NdbTransporterData *)receiveBuffer[recBufReadIndex];
  94.   if(recBufReadIndex != recBufWriteIndex){
  95.     * remoteNodeId = s->senderNodeId;
  96.     * readPtr      = &s->data[0];
  97.     return s->length;
  98.   }
  99.   return 0;
  100. }
  102. inline
  103. void
  104. OSE_Receiver::updateReceiveDataPtr(Uint32 bytesRead){
  105.   if(bytesRead != 0){
  106.     free_buf(&receiveBuffer[recBufReadIndex]);
  107.     recBufReadIndex = (recBufReadIndex + 1) % recBufSize;
  108.   }
  109. }
  111. inline 
  112. void
  113. OSE_Receiver::insertReceiveBuffer(union SIGNAL * _sig){
  114.   receiveBuffer[recBufWriteIndex] = _sig;
  115.   recBufWriteIndex = (recBufWriteIndex + 1) % recBufSize;
  116. }
  119. #endif