MySQL 5.6.14 Source Code Document
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
SumaImpl.cpp
1 /*
2  Copyright (C) 2003, 2005-2007 MySQL AB
3  All rights reserved. Use is subject to license terms.
4 
5  This program is free software; you can redistribute it and/or modify
6  it under the terms of the GNU General Public License as published by
7  the Free Software Foundation; version 2 of the License.
8 
9  This program is distributed in the hope that it will be useful,
10  but WITHOUT ANY WARRANTY; without even the implied warranty of
11  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12  GNU General Public License for more details.
13 
14  You should have received a copy of the GNU General Public License
15  along with this program; if not, write to the Free Software
16  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
17 */
18 
19 #include <signaldata/SumaImpl.hpp>
20 
21 bool
22 printSUB_CREATE_REQ(FILE * output, const Uint32 * theData,
23  Uint32 len, Uint16 receiverBlockNo) {
24  const SubCreateReq * const sig = (SubCreateReq *)theData;
25  fprintf(output, " senderRef: %x\n", sig->senderRef);
26  fprintf(output, " senderData: %x\n", sig->senderData);
27  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
28  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
29  fprintf(output, " subscriptionType: %x\n", sig->subscriptionType);
30  fprintf(output, " tableId: %x\n", sig->tableId);
31  fprintf(output, " schemaTransId: %x\n", sig->schemaTransId);
32  return false;
33 }
34 
35 bool
36 printSUB_CREATE_CONF(FILE * output, const Uint32 * theData,
37  Uint32 len, Uint16 receiverBlockNo) {
38  const SubCreateConf * const sig = (SubCreateConf *)theData;
39  fprintf(output, " senderData: %x\n", sig->senderData);
40  return false;
41 }
42 
43 bool
44 printSUB_CREATE_REF(FILE * output, const Uint32 * theData,
45  Uint32 len, Uint16 receiverBlockNo) {
46  const SubCreateRef * const sig = (SubCreateRef *)theData;
47  fprintf(output, " senderData: %x\n", sig->senderData);
48  return false;
49 }
50 
51 bool
52 printSUB_REMOVE_REQ(FILE * output, const Uint32 * theData,
53  Uint32 len, Uint16 receiverBlockNo)
54 {
55  const SubRemoveReq * const sig = (SubRemoveReq *)theData;
56  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
57  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
58  return false;
59 }
60 
61 bool
62 printSUB_REMOVE_CONF(FILE * output, const Uint32 * theData,
63  Uint32 len, Uint16 receiverBlockNo)
64 {
65  const SubRemoveConf * const sig = (SubRemoveConf *)theData;
66  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
67  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
68  fprintf(output, " senderData: %x\n", sig->senderData);
69  return false;
70 }
71 
72 bool
73 printSUB_REMOVE_REF(FILE * output, const Uint32 * theData,
74  Uint32 len, Uint16 receiverBlockNo)
75 {
76  const SubRemoveRef * const sig = (SubRemoveRef *)theData;
77  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
78  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
79  fprintf(output, " senderData: %x\n", sig->senderData);
80  fprintf(output, " errorCode: %x\n", sig->errorCode);
81  return false;
82 }
83 
84 bool
85 printSUB_START_REQ(FILE * output, const Uint32 * theData,
86  Uint32 len, Uint16 receiverBlockNo) {
87  const SubStartReq * const sig = (SubStartReq *)theData;
88  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
89  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
90  fprintf(output, " senderData: %x\n", sig->senderData);
91  return false;
92 }
93 
94 bool
95 printSUB_START_REF(FILE * output, const Uint32 * theData,
96  Uint32 len, Uint16 receiverBlockNo) {
97  const SubStartRef * const sig = (SubStartRef *)theData;
98  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
99  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
100  fprintf(output, " startPart: %x\n", sig->part);
101  fprintf(output, " senderData: %x\n", sig->senderData);
102  fprintf(output, " errorCode: %x\n", sig->errorCode);
103  return false;
104 }
105 
106 bool
107 printSUB_START_CONF(FILE * output, const Uint32 * theData,
108  Uint32 len, Uint16 receiverBlockNo) {
109  const SubStartConf * const sig = (SubStartConf *)theData;
110  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
111  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
112  fprintf(output, " startPart: %x\n", sig->part);
113  fprintf(output, " senderData: %x\n", sig->senderData);
114  return false;
115 }
116 
117 bool
118 printSUB_STOP_REQ(FILE * output, const Uint32 * theData,
119  Uint32 len, Uint16 receiverBlockNo) {
120  const SubStopReq * const sig = (SubStopReq *)theData;
121  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
122  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
123  fprintf(output, " senderData: %x\n", sig->senderData);
124  return false;
125 }
126 
127 bool
128 printSUB_STOP_REF(FILE * output, const Uint32 * theData,
129  Uint32 len, Uint16 receiverBlockNo) {
130  const SubStopRef * const sig = (SubStopRef *)theData;
131  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
132  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
133  fprintf(output, " senderData: %x\n", sig->senderData);
134  fprintf(output, " errorCode: %x\n", sig->errorCode);
135  return false;
136 }
137 
138 bool
139 printSUB_STOP_CONF(FILE * output, const Uint32 * theData,
140  Uint32 len, Uint16 receiverBlockNo) {
141  const SubStopConf * const sig = (SubStopConf *)theData;
142  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
143  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
144  fprintf(output, " senderData: %x\n", sig->senderData);
145  return false;
146 }
147 
148 bool
149 printSUB_SYNC_REQ(FILE * output, const Uint32 * theData,
150  Uint32 len, Uint16 receiverBlockNo) {
151  const SubSyncReq * const sig = (SubSyncReq *)theData;
152  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
153  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
154  fprintf(output, " syncPart: %x\n", sig->part);
155  return false;
156 }
157 
158 bool
159 printSUB_SYNC_REF(FILE * output, const Uint32 * theData,
160  Uint32 len, Uint16 receiverBlockNo) {
161  const SubSyncRef * const sig = (SubSyncRef *)theData;
162  fprintf(output, " senderData: %x\n", sig->senderData);
163  fprintf(output, " errorCode: %x\n", sig->errorCode);
164  return false;
165 }
166 
167 bool
168 printSUB_SYNC_CONF(FILE * output, const Uint32 * theData,
169  Uint32 len, Uint16 receiverBlockNo) {
170  const SubSyncConf * const sig = (SubSyncConf *)theData;
171  fprintf(output, " senderData: %x\n", sig->senderData);
172  return false;
173 }
174 
175 bool
176 printSUB_TABLE_DATA(FILE * output, const Uint32 * theData,
177  Uint32 len, Uint16 receiverBlockNo) {
178  const SubTableData * const sig = (SubTableData *)theData;
179  fprintf(output, " senderData: %x\n", sig->senderData);
180  fprintf(output, " gci_hi: %x\n", sig->gci_hi);
181  fprintf(output, " gci_lo: %x\n", sig->gci_lo);
182  fprintf(output, " tableId: %x\n", sig->tableId);
183  fprintf(output, " operation: %x\n",
184  SubTableData::getOperation(sig->requestInfo));
185  if (len == SubTableData::SignalLengthWithTransId)
186  {
187  fprintf(output, " TransId : %x %x\n",
188  sig->transId1, sig->transId2);
189  }
190  return false;
191 }
192 
193 bool
194 printSUB_SYNC_CONTINUE_REQ(FILE * output, const Uint32 * theData,
195  Uint32 len, Uint16 receiverBlockNo) {
196  const SubSyncContinueReq * const sig = (SubSyncContinueReq *)theData;
197  fprintf(output, " subscriberData: %x\n", sig->subscriberData);
198  fprintf(output, " noOfRowsSent: %x\n", sig->noOfRowsSent);
199  return false;
200 }
201 
202 bool
203 printSUB_SYNC_CONTINUE_REF(FILE * output, const Uint32 * theData,
204  Uint32 len, Uint16 receiverBlockNo) {
205  const SubSyncContinueRef * const sig = (SubSyncContinueRef *)theData;
206  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
207  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
208  return false;
209 }
210 
211 bool
212 printSUB_SYNC_CONTINUE_CONF(FILE * output, const Uint32 * theData,
213  Uint32 len, Uint16 receiverBlockNo) {
214  const SubSyncContinueConf * const sig = (SubSyncContinueConf *)theData;
215  fprintf(output, " subscriptionId: %x\n", sig->subscriptionId);
216  fprintf(output, " subscriptionKey: %x\n", sig->subscriptionKey);
217  return false;
218 }
219 
220 bool
221 printSUB_GCP_COMPLETE_REP(FILE * output, const Uint32 * theData,
222  Uint32 len, Uint16 receiverBlockNo) {
223  const SubGcpCompleteRep * const sig = (SubGcpCompleteRep *)theData;
224  fprintf(output, " gci_hi: %x gci_lo: %x\n", sig->gci_hi, sig->gci_lo);
225  return false;
226 }
227