1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
/* Copyright (C) 2003 MySQL AB
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
#ifndef UTIL_EXECUTE_HPP
#define UTIL_EXECUTE_HPP
#include "SignalData.hpp"
#include <SimpleProperties.hpp>
/**
* UTIL_EXECUTE_REQ, UTIL_EXECUTE_CONF, UTIL_EXECUTE_REF
*/
/**
* @class UtilExecuteReq
* @brief Execute transaction in Util block
*
* Data format:
* - UTIL_EXECUTE_REQ <prepareId> <ListOfAttributeHeaderValuePairs>
*/
class UtilExecuteReq {
/** Sender(s) / Receiver(s) */
friend class DbUtil;
friend class Trix;
/** For printing */
friend bool printUTIL_EXECUTE_REQ(FILE * output, const Uint32 * theData,
Uint32 len, Uint16 receiverBlockNo);
public:
STATIC_CONST( SignalLength = 3 );
STATIC_CONST( HEADER_SECTION = 0 );
STATIC_CONST( DATA_SECTION = 1 );
STATIC_CONST( NoOfSections = 2 );
GET_SET_SENDERREF
GET_SET_SENDERDATA
void setPrepareId(Uint32 pId) { prepareId = pId; }; // !! unsets release flag
Uint32 getPrepareId() { return prepareId & 0xFF; };
void setReleaseFlag() { prepareId |= 0x100; };
bool getReleaseFlag() { return (prepareId & 0x100) != 0; };
private:
Uint32 senderData; // MUST be no 1!
Uint32 senderRef;
Uint32 prepareId; // Which prepared transaction to execute
};
/**
* @class UtilExecuteConf
*
* Data format:
* - UTIL_PREPARE_CONF <UtilPrepareId>
*/
class UtilExecuteConf {
/**
* Sender(s) / Receiver(s)
*/
friend class DbUtil;
friend class Trix;
/**
* For printing
*/
friend bool printUTIL_EXECUTE_CONF(FILE * output,
const Uint32 * theData,
Uint32 len,
Uint16 receiverBlockNo);
public:
STATIC_CONST( SignalLength = 1 );
GET_SET_SENDERDATA
private:
Uint32 senderData; // MUST be no 1!
};
/**
* @class UtilExecuteRef
*
* Data format:
* - UTIL_PREPARE_REF
*/
class UtilExecuteRef {
/**
* Sender(s) / Receiver(s)
*/
friend class DbUtil;
friend class Trix;
/**
* For printing
*/
friend bool printUTIL_EXECUTE_REF(FILE * output,
const Uint32 * theData,
Uint32 len,
Uint16 receiverBlockNo);
public:
STATIC_CONST( SignalLength = 3 );
enum ErrorCode {
IllegalKeyNumber = 1,
IllegalAttrNumber = 2,
TCError = 3,
IllegalPrepareId = 4,
AllocationError = 5,
MissingDataSection = 6,
MissingData = 7
};
GET_SET_SENDERDATA
GET_SET_ERRORCODE
GET_SET_TCERRORCODE
private:
Uint32 senderData; // MUST be no 1!
Uint32 errorCode;
Uint32 TCErrorCode;
};
#endif
|
