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

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

MySQL数据库

开发平台：

Visual C++

SumaImpl.cpp：源码内容
  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. #include <signaldata/SumaImpl.hpp>
  19. bool
  20. printSUB_CREATE_REQ(FILE * output, const Uint32 * theData, 
  21.     Uint32 len, Uint16 receiverBlockNo) {
  22.   const SubCreateReq * const sig = (SubCreateReq *)theData;
  23.   fprintf(output, " subscriberRef: %xn", sig->subscriberRef);
  24.   fprintf(output, " subscriberData: %xn", sig->subscriberData);
  25.   fprintf(output, " subscriptionId: %xn", sig->subscriptionId);
  26.   fprintf(output, " subscriptionKey: %xn", sig->subscriptionKey);
  27.   fprintf(output, " subscriptionType: %xn", sig->subscriptionType);
  28.   fprintf(output, " tableId: %xn", sig->tableId);
  29.   return false;
  30. }
  32. bool
  33. printSUB_CREATE_CONF(FILE * output, const Uint32 * theData, 
  34.      Uint32 len, Uint16 receiverBlockNo) {
  35.   const SubCreateConf * const sig = (SubCreateConf *)theData;
  36.   fprintf(output, " subscriptionId: %xn", sig->subscriptionId);
  37.   fprintf(output, " subscriptionKey: %xn", sig->subscriptionKey);
  38.   fprintf(output, " subscriberData: %xn", sig->subscriberData);
  39.   return false;
  40. }
  42. bool
  43. printSUB_START_REQ(FILE * output, const Uint32 * theData, 
  44.    Uint32 len, Uint16 receiverBlockNo) {
  45.   const SubStartReq * const sig = (SubStartReq *)theData;
  46.   fprintf(output, " subscriptionId: %xn", sig->subscriptionId);
  47.   fprintf(output, " subscriptionKey: %xn", sig->subscriptionKey);
  48.   fprintf(output, " startPart: %xn", sig->part);
  49.   return false;
  50. }
  52. bool
  53. printSUB_START_REF(FILE * output, const Uint32 * theData, 
  54.    Uint32 len, Uint16 receiverBlockNo) {
  55.   const SubStartRef * const sig = (SubStartRef *)theData;
  56.   fprintf(output, " subscriptionId: %xn", sig->subscriptionId);
  57.   fprintf(output, " subscriptionKey: %xn", sig->subscriptionKey);
  58.   fprintf(output, " startPart: %xn", sig->part);
  59.   fprintf(output, " subscriberData: %xn", sig->subscriberData);
  60.   fprintf(output, " err: %xn", sig->err);
  61.   return false;
  62. }
  64. bool
  65. printSUB_START_CONF(FILE * output, const Uint32 * theData, 
  66.     Uint32 len, Uint16 receiverBlockNo) {
  67.   const SubStartConf * const sig = (SubStartConf *)theData;
  68.   fprintf(output, " subscriptionId: %xn", sig->subscriptionId);
  69.   fprintf(output, " subscriptionKey: %xn", sig->subscriptionKey);
  70.   fprintf(output, " startPart: %xn", sig->part);
  71.   fprintf(output, " subscriberData: %xn", sig->subscriberData);
  72.   return false;
  73. }
  75. bool
  76. printSUB_SYNC_REQ(FILE * output, const Uint32 * theData, 
  77.   Uint32 len, Uint16 receiverBlockNo) {
  78.   const SubSyncReq * const sig = (SubSyncReq *)theData;
  79.   fprintf(output, " subscriptionId: %xn", sig->subscriptionId);
  80.   fprintf(output, " subscriptionKey: %xn", sig->subscriptionKey);
  81.   fprintf(output, " syncPart: %xn", sig->part);
  82.   return false;
  83. }
  85. bool
  86. printSUB_SYNC_REF(FILE * output, const Uint32 * theData, 
  87.   Uint32 len, Uint16 receiverBlockNo) {
  88.   const SubSyncRef * const sig = (SubSyncRef *)theData;
  89.   fprintf(output, " subscriptionId: %xn", sig->subscriptionId);
  90.   fprintf(output, " subscriptionKey: %xn", sig->subscriptionKey);
  91.   fprintf(output, " syncPart: %xn", sig->part);
  92.   fprintf(output, " subscriberData: %xn", sig->subscriberData);
  93.   fprintf(output, " err: %xn", sig->err);
  94.   return false;
  95. }
  97. bool
  98. printSUB_SYNC_CONF(FILE * output, const Uint32 * theData, 
  99.    Uint32 len, Uint16 receiverBlockNo) {
  100.   const SubSyncConf * const sig = (SubSyncConf *)theData;
  101.   fprintf(output, " subscriptionId: %xn", sig->subscriptionId);
  102.   fprintf(output, " subscriptionKey: %xn", sig->subscriptionKey);
  103.   fprintf(output, " syncPart: %xn", sig->part);
  104.   fprintf(output, " subscriberData: %xn", sig->subscriberData);
  105.   return false;
  106. }
  108. bool
  109. printSUB_META_DATA(FILE * output, const Uint32 * theData, 
  110.    Uint32 len, Uint16 receiverBlockNo) {
  111.   const SubMetaData * const sig = (SubMetaData *)theData;
  112.   fprintf(output, " gci: %xn", sig->gci);
  113.   fprintf(output, " senderData: %xn", sig->senderData);
  114.   fprintf(output, " subscriberData: %xn", sig->subscriberData);
  115.   fprintf(output, " tableId: %xn", sig->tableId);
  116.   return false;
  117. }
  119. bool
  120. printSUB_TABLE_DATA(FILE * output, const Uint32 * theData, 
  121.     Uint32 len, Uint16 receiverBlockNo) {
  122.   const SubTableData * const sig = (SubTableData *)theData;
  123.   fprintf(output, " senderData: %xn", sig->senderData);
  124.   fprintf(output, " subscriberData: %xn", sig->subscriberData);
  125.   fprintf(output, " gci: %xn", sig->gci);
  126.   fprintf(output, " tableId: %xn", sig->tableId);
  127.   fprintf(output, " operation: %xn", sig->operation);
  128.   fprintf(output, " noOfAttributes: %xn", sig->noOfAttributes);
  129.   fprintf(output, " dataSize: %xn", sig->dataSize);
  130.   return false;
  131. }
  133. bool
  134. printSUB_SYNC_CONTINUE_REQ(FILE * output, const Uint32 * theData, 
  135.    Uint32 len, Uint16 receiverBlockNo) {
  136.   const SubSyncContinueReq * const sig = (SubSyncContinueReq *)theData;
  137.   fprintf(output, " subscriberData: %xn", sig->subscriberData);
  138.   fprintf(output, " noOfRowsSent: %xn", sig->noOfRowsSent);
  139.   return false;
  140. }
  142. bool
  143. printSUB_SYNC_CONTINUE_REF(FILE * output, const Uint32 * theData, 
  144.    Uint32 len, Uint16 receiverBlockNo) {
  145.   const SubSyncContinueRef * const sig = (SubSyncContinueRef *)theData;
  146.   fprintf(output, " subscriptionId: %xn", sig->subscriptionId);
  147.   fprintf(output, " subscriptionKey: %xn", sig->subscriptionKey);
  148.   return false;
  149. }
  151. bool
  152. printSUB_SYNC_CONTINUE_CONF(FILE * output, const Uint32 * theData, 
  153.     Uint32 len, Uint16 receiverBlockNo) {
  154.   const SubSyncContinueConf * const sig = (SubSyncContinueConf *)theData;
  155.   fprintf(output, " subscriptionId: %xn", sig->subscriptionId);
  156.   fprintf(output, " subscriptionKey: %xn", sig->subscriptionKey);
  157.   return false;
  158. }
  160. bool
  161. printSUB_GCP_COMPLETE_REP(FILE * output, const Uint32 * theData, 
  162.   Uint32 len, Uint16 receiverBlockNo) {
  163.   const SubGcpCompleteRep * const sig = (SubGcpCompleteRep *)theData;
  164.   fprintf(output, " gci: %xn", sig->gci);
  165.   return false;
  166. }