StartRec.cpp
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:2k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* Copyright (C) 2003 MySQL AB
  2.    This program is free software; you can redistribute it and/or modify
  3.    it under the terms of the GNU General Public License as published by
  4.    the Free Software Foundation; either version 2 of the License, or
  5.    (at your option) any later version.
  6.    This program is distributed in the hope that it will be useful,
  7.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  8.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  9.    GNU General Public License for more details.
  10.    You should have received a copy of the GNU General Public License
  11.    along with this program; if not, write to the Free Software
  12.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  13. #include <RefConvert.hpp>
  14. #include <signaldata/StartRec.hpp>
  15. #include <signaldata/StartFragReq.hpp>
  16. bool
  17. printSTART_REC_REQ(FILE * output, 
  18.   const Uint32 * theData, 
  19.   Uint32 len, 
  20.   Uint16 recBlockNo){
  21.   StartRecReq * sig = (StartRecReq *) theData;
  22.   fprintf(output, " receivingNodeId: %d senderRef: (%d, %d)n",
  23.   sig->receivingNodeId, 
  24.   refToNode(sig->senderRef),
  25.   refToBlock(sig->senderRef));
  26.   
  27.   fprintf(output, " keepGci: %d lastCompletedGci: %d newestGci: %dn",
  28.   sig->keepGci, 
  29.   sig->lastCompletedGci,
  30.   sig->newestGci);
  31.   return true;
  32. }
  33. bool
  34. printSTART_REC_CONF(FILE * output, 
  35.     const Uint32 * theData, 
  36.     Uint32 len, 
  37.     Uint16 recBlockNo){
  38.   StartRecConf * sig = (StartRecConf *) theData;
  39.   fprintf(output, " startingNodeId: %dn",
  40.   sig->startingNodeId);
  41.   return true;
  42. }
  43. bool 
  44. printSTART_FRAG_REQ(FILE * output, 
  45.     const Uint32 * theData, 
  46.     Uint32 len, 
  47.     Uint16 recBlockNo)
  48. {
  49.   StartFragReq* sig = (StartFragReq*)theData;
  50.   fprintf(output, " table: %d frag: %d lcpId: %d lcpNo: %d #nodes: %d n",
  51.   sig->tableId, sig->fragId, sig->lcpId, sig->lcpNo, 
  52.   sig->noOfLogNodes);
  53.   for(Uint32 i = 0; i<sig->noOfLogNodes; i++)
  54.   {
  55.     fprintf(output, " (node: %d startGci: %d lastGci: %d)",
  56.     sig->lqhLogNode[i],
  57.     sig->startGci[i],
  58.     sig->lastGci[i]);
  59.   }
  60.     
  61.   fprintf(output, "n");
  62.   return true; 
  63. }