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

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 <signaldata/BackupSignalData.hpp>
  14. bool 
  15. printBACKUP_REQ(FILE * output, const Uint32 * theData, Uint32 len, Uint16 bno){
  16.   BackupReq* sig = (BackupReq*)theData;
  17.   fprintf(output, " senderData: %d DataLength: %dn", 
  18.   sig->senderData,
  19.   sig->backupDataLen);
  20.   return true;
  21. }
  22. bool 
  23. printBACKUP_DATA(FILE * output, const Uint32 * theData, Uint32 len, Uint16 bno){
  24.   BackupData * sig = (BackupData*)theData;
  25.   if(sig->requestType == BackupData::ClientToMaster){
  26.     fprintf(output, " ClientToMaster: senderData: %d backupId: %dn",
  27.     sig->senderData, sig->backupId);
  28.   } else if(sig->requestType == BackupData::MasterToSlave){
  29.     fprintf(output, " MasterToSlave: backupPtr: %d backupId: %dn",
  30.     sig->backupPtr, sig->backupId);
  31.   }
  32.   return false;
  33. }
  34. bool 
  35. printBACKUP_REF(FILE * output, const Uint32 * theData, Uint32 len, Uint16 bno){
  36.   BackupRef* sig = (BackupRef*)theData;
  37.   fprintf(output, " senderData: %d errorCode: %d masterRef: %dn",
  38.   sig->senderData,
  39.   sig->errorCode,
  40.   sig->masterRef);
  41.   return true;
  42. }
  43. bool 
  44. printBACKUP_CONF(FILE * output, const Uint32 * theData, Uint32 len, Uint16 bno){
  45.   BackupConf* sig = (BackupConf*)theData;
  46.   fprintf(output, " senderData: %d backupId: %dn",
  47.   sig->senderData,
  48.   sig->backupId);
  49.   return true;
  50. }
  51. bool 
  52. printBACKUP_ABORT_REP(FILE * out, const Uint32 * data, Uint32 len, Uint16 bno){
  53.   BackupAbortRep* sig = (BackupAbortRep*)data;
  54.   fprintf(out, " senderData: %d backupId: %d reason: %dn",
  55.   sig->senderData,
  56.   sig->backupId,
  57.   sig->reason);
  58.   return true;
  59. }
  60. bool 
  61. printBACKUP_COMPLETE_REP(FILE * out, const Uint32 * data, Uint32 len, Uint16 b){
  62.   BackupCompleteRep* sig = (BackupCompleteRep*)data;
  63.   fprintf(out, " senderData: %d backupId: %d records: %d bytes: %dn",
  64.   sig->senderData,
  65.   sig->backupId,
  66.   sig->noOfRecords,
  67.   sig->noOfBytes);
  68.   return true;
  69. }
  70. bool 
  71. printBACKUP_NF_COMPLETE_REP(FILE*, const Uint32*, Uint32, Uint16){
  72.   return false;
  73. }
  74. bool 
  75. printABORT_BACKUP_ORD(FILE * out, const Uint32 * data, Uint32 len, Uint16 b){
  76.   AbortBackupOrd* sig = (AbortBackupOrd*)data;
  77.   AbortBackupOrd::RequestType rt =(AbortBackupOrd::RequestType)sig->requestType;
  78.   switch(rt){
  79.   case AbortBackupOrd::ClientAbort:
  80.     fprintf(out, " ClientAbort: senderData: %d backupId: %dn",
  81.     sig->senderData, sig->backupId);
  82.     return true;
  83.     break;
  84.   case AbortBackupOrd::BackupComplete:
  85.     fprintf(out, " BackupComplete: backupPtr: %d backupId: %dn",
  86.     sig->backupPtr, sig->backupId);
  87.     return true;
  88.   case AbortBackupOrd::BackupFailure:
  89.     fprintf(out, " BackupFailure: backupPtr: %d backupId: %dn",
  90.     sig->backupPtr, sig->backupId);
  91.     return true;
  92.   case AbortBackupOrd::LogBufferFull:
  93.     fprintf(out, " LogBufferFull: backupPtr: %d backupId: %dn",
  94.     sig->backupPtr, sig->backupId);
  95.     return true;
  96.     break;
  97.   case AbortBackupOrd::FileOrScanError:
  98.     fprintf(out, " FileOrScanError: backupPtr: %d backupId: %dn",
  99.     sig->backupPtr, sig->backupId);
  100.     return true;
  101.     break;
  102.   case AbortBackupOrd::BackupFailureDueToNodeFail:
  103.     fprintf(out, " BackupFailureDueToNodeFail: backupPtr: %d backupId: %dn",
  104.     sig->backupPtr, sig->backupId);
  105.     return true;
  106.     break;
  107.   case AbortBackupOrd::OkToClean:
  108.     fprintf(out, " OkToClean: backupPtr: %d backupId: %dn",
  109.     sig->backupPtr, sig->backupId);
  110.     return true;
  111.     break;
  112.   }
  113.   return false;
  114. }