1 /* Copyright (c) 2003, 2005, 2006 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; version 2 of the License.
7 This program is distributed in the hope that it will be useful,
8 but WITHOUT ANY WARRANTY; without even the implied warranty of
9 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
10 GNU General Public License for more details.
12 You should have received a copy of the GNU General Public License
13 along with this program; if not, write to the Free Software
14 Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA */
16 #include <signaldata/SumaImpl.hpp>
19 printSUB_CREATE_REQ(FILE * output
, const Uint32
* theData
,
20 Uint32 len
, Uint16 receiverBlockNo
) {
21 const SubCreateReq
* const sig
= (SubCreateReq
*)theData
;
22 fprintf(output
, " senderRef: %x\n", sig
->senderRef
);
23 fprintf(output
, " senderData: %x\n", sig
->senderData
);
24 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
25 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
26 fprintf(output
, " subscriptionType: %x\n", sig
->subscriptionType
);
27 fprintf(output
, " tableId: %x\n", sig
->tableId
);
32 printSUB_CREATE_CONF(FILE * output
, const Uint32
* theData
,
33 Uint32 len
, Uint16 receiverBlockNo
) {
34 const SubCreateConf
* const sig
= (SubCreateConf
*)theData
;
35 fprintf(output
, " senderData: %x\n", sig
->senderData
);
40 printSUB_CREATE_REF(FILE * output
, const Uint32
* theData
,
41 Uint32 len
, Uint16 receiverBlockNo
) {
42 const SubCreateRef
* const sig
= (SubCreateRef
*)theData
;
43 fprintf(output
, " senderData: %x\n", sig
->senderData
);
48 printSUB_REMOVE_REQ(FILE * output
, const Uint32
* theData
,
49 Uint32 len
, Uint16 receiverBlockNo
)
51 const SubRemoveReq
* const sig
= (SubRemoveReq
*)theData
;
52 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
53 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
58 printSUB_REMOVE_CONF(FILE * output
, const Uint32
* theData
,
59 Uint32 len
, Uint16 receiverBlockNo
)
61 const SubRemoveConf
* const sig
= (SubRemoveConf
*)theData
;
62 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
63 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
64 fprintf(output
, " senderData: %x\n", sig
->senderData
);
69 printSUB_REMOVE_REF(FILE * output
, const Uint32
* theData
,
70 Uint32 len
, Uint16 receiverBlockNo
)
72 const SubRemoveRef
* const sig
= (SubRemoveRef
*)theData
;
73 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
74 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
75 fprintf(output
, " senderData: %x\n", sig
->senderData
);
76 fprintf(output
, " errorCode: %x\n", sig
->errorCode
);
81 printSUB_START_REQ(FILE * output
, const Uint32
* theData
,
82 Uint32 len
, Uint16 receiverBlockNo
) {
83 const SubStartReq
* const sig
= (SubStartReq
*)theData
;
84 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
85 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
86 fprintf(output
, " senderData: %x\n", sig
->senderData
);
91 printSUB_START_REF(FILE * output
, const Uint32
* theData
,
92 Uint32 len
, Uint16 receiverBlockNo
) {
93 const SubStartRef
* const sig
= (SubStartRef
*)theData
;
94 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
95 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
96 fprintf(output
, " startPart: %x\n", sig
->part
);
97 fprintf(output
, " senderData: %x\n", sig
->senderData
);
98 fprintf(output
, " errorCode: %x\n", sig
->errorCode
);
103 printSUB_START_CONF(FILE * output
, const Uint32
* theData
,
104 Uint32 len
, Uint16 receiverBlockNo
) {
105 const SubStartConf
* const sig
= (SubStartConf
*)theData
;
106 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
107 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
108 fprintf(output
, " startPart: %x\n", sig
->part
);
109 fprintf(output
, " senderData: %x\n", sig
->senderData
);
114 printSUB_STOP_REQ(FILE * output
, const Uint32
* theData
,
115 Uint32 len
, Uint16 receiverBlockNo
) {
116 const SubStopReq
* const sig
= (SubStopReq
*)theData
;
117 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
118 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
119 fprintf(output
, " senderData: %x\n", sig
->senderData
);
124 printSUB_STOP_REF(FILE * output
, const Uint32
* theData
,
125 Uint32 len
, Uint16 receiverBlockNo
) {
126 const SubStopRef
* const sig
= (SubStopRef
*)theData
;
127 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
128 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
129 fprintf(output
, " senderData: %x\n", sig
->senderData
);
130 fprintf(output
, " errorCode: %x\n", sig
->errorCode
);
135 printSUB_STOP_CONF(FILE * output
, const Uint32
* theData
,
136 Uint32 len
, Uint16 receiverBlockNo
) {
137 const SubStopConf
* const sig
= (SubStopConf
*)theData
;
138 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
139 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
140 fprintf(output
, " senderData: %x\n", sig
->senderData
);
145 printSUB_SYNC_REQ(FILE * output
, const Uint32
* theData
,
146 Uint32 len
, Uint16 receiverBlockNo
) {
147 const SubSyncReq
* const sig
= (SubSyncReq
*)theData
;
148 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
149 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
150 fprintf(output
, " syncPart: %x\n", sig
->part
);
155 printSUB_SYNC_REF(FILE * output
, const Uint32
* theData
,
156 Uint32 len
, Uint16 receiverBlockNo
) {
157 const SubSyncRef
* const sig
= (SubSyncRef
*)theData
;
158 fprintf(output
, " senderData: %x\n", sig
->senderData
);
159 fprintf(output
, " errorCode: %x\n", sig
->errorCode
);
164 printSUB_SYNC_CONF(FILE * output
, const Uint32
* theData
,
165 Uint32 len
, Uint16 receiverBlockNo
) {
166 const SubSyncConf
* const sig
= (SubSyncConf
*)theData
;
167 fprintf(output
, " senderData: %x\n", sig
->senderData
);
172 printSUB_TABLE_DATA(FILE * output
, const Uint32
* theData
,
173 Uint32 len
, Uint16 receiverBlockNo
) {
174 const SubTableData
* const sig
= (SubTableData
*)theData
;
175 fprintf(output
, " senderData: %x\n", sig
->senderData
);
176 fprintf(output
, " gci: %x\n", sig
->gci
);
177 fprintf(output
, " tableId: %x\n", sig
->tableId
);
178 fprintf(output
, " operation: %x\n",
179 SubTableData::getOperation(sig
->requestInfo
));
184 printSUB_SYNC_CONTINUE_REQ(FILE * output
, const Uint32
* theData
,
185 Uint32 len
, Uint16 receiverBlockNo
) {
186 const SubSyncContinueReq
* const sig
= (SubSyncContinueReq
*)theData
;
187 fprintf(output
, " subscriberData: %x\n", sig
->subscriberData
);
188 fprintf(output
, " noOfRowsSent: %x\n", sig
->noOfRowsSent
);
193 printSUB_SYNC_CONTINUE_REF(FILE * output
, const Uint32
* theData
,
194 Uint32 len
, Uint16 receiverBlockNo
) {
195 const SubSyncContinueRef
* const sig
= (SubSyncContinueRef
*)theData
;
196 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
197 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
202 printSUB_SYNC_CONTINUE_CONF(FILE * output
, const Uint32
* theData
,
203 Uint32 len
, Uint16 receiverBlockNo
) {
204 const SubSyncContinueConf
* const sig
= (SubSyncContinueConf
*)theData
;
205 fprintf(output
, " subscriptionId: %x\n", sig
->subscriptionId
);
206 fprintf(output
, " subscriptionKey: %x\n", sig
->subscriptionKey
);
211 printSUB_GCP_COMPLETE_REP(FILE * output
, const Uint32
* theData
,
212 Uint32 len
, Uint16 receiverBlockNo
) {
213 const SubGcpCompleteRep
* const sig
= (SubGcpCompleteRep
*)theData
;
214 fprintf(output
, " gci: %x\n", sig
->gci
);