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
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
|
/*
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*
*/
/**
* \file rcvdat.h
*
* Qpid asynchronous store plugin library
*
* Contains structure for recovery status and offset data.
*
* \author Kim van der Riet
*/
#ifndef QPID_LEGACYSTORE_JRNL_RCVDAT_H
#define QPID_LEGACYSTORE_JRNL_RCVDAT_H
#include <cstddef>
#include <iomanip>
#include <map>
#include "qpid/legacystore/jrnl/jcfg.h"
#include <sstream>
#include <sys/types.h>
#include <vector>
namespace mrg
{
namespace journal
{
struct rcvdat
{
u_int16_t _njf; ///< Number of journal files
bool _ae; ///< Auto-expand mode
u_int16_t _aemjf; ///< Auto-expand mode max journal files
bool _owi; ///< Overwrite indicator
bool _frot; ///< First rotation flag
bool _jempty; ///< Journal data files empty
u_int16_t _ffid; ///< First file id
std::size_t _fro; ///< First record offset in ffid
u_int16_t _lfid; ///< Last file id
std::size_t _eo; ///< End offset (first byte past last record)
u_int64_t _h_rid; ///< Highest rid found
bool _lffull; ///< Last file is full
bool _jfull; ///< Journal is full
std::vector<u_int16_t> _fid_list; ///< Fid-lid mapping - list of fids in order of lid
std::vector<u_int32_t> _enq_cnt_list; ///< Number enqueued records found for each file
rcvdat():
_njf(0),
_ae(false),
_aemjf(0),
_owi(false),
_frot(false),
_jempty(true),
_ffid(0),
_fro(0),
_lfid(0),
_eo(0),
_h_rid(0),
_lffull(false),
_jfull(false),
_fid_list(),
_enq_cnt_list()
{}
void reset(const u_int16_t num_jfiles, const bool auto_expand, const u_int16_t ae_max_jfiles)
{
_njf = num_jfiles;
_ae = auto_expand;
_aemjf = ae_max_jfiles;
_owi = false;
_frot = false;
_jempty = true;
_ffid = 0;
_fro = 0;
_lfid = 0;
_eo = 0;
_h_rid = 0;
_lffull = false;
_jfull = false;
_fid_list.clear();
_enq_cnt_list.clear();
_enq_cnt_list.resize(num_jfiles, 0);
}
// Find first fid with enqueued records
u_int16_t ffid()
{
u_int16_t index = _ffid;
while (index != _lfid && _enq_cnt_list[index] == 0)
{
if (++index >= _njf)
index = 0;
}
return index;
}
std::string to_string(const std::string& jid)
{
std::ostringstream oss;
oss << "Recover file analysis (jid=\"" << jid << "\"):" << std::endl;
oss << " Number of journal files (_njf) = " << _njf << std::endl;
oss << " Auto-expand mode (_ae) = " << (_ae ? "TRUE" : "FALSE") << std::endl;
if (_ae) oss << " Auto-expand mode max journal files (_aemjf) = " << _aemjf << std::endl;
oss << " Overwrite indicator (_owi) = " << (_owi ? "TRUE" : "FALSE") << std::endl;
oss << " First rotation (_frot) = " << (_frot ? "TRUE" : "FALSE") << std::endl;
oss << " Journal empty (_jempty) = " << (_jempty ? "TRUE" : "FALSE") << std::endl;
oss << " First (earliest) fid (_ffid) = " << _ffid << std::endl;
oss << " First record offset in first fid (_fro) = 0x" << std::hex << _fro <<
std::dec << " (" << (_fro/JRNL_DBLK_SIZE) << " dblks)" << std::endl;
oss << " Last (most recent) fid (_lfid) = " << _lfid << std::endl;
oss << " End offset (_eo) = 0x" << std::hex << _eo << std::dec << " (" <<
(_eo/JRNL_DBLK_SIZE) << " dblks)" << std::endl;
oss << " Highest rid (_h_rid) = 0x" << std::hex << _h_rid << std::dec << std::endl;
oss << " Last file full (_lffull) = " << (_lffull ? "TRUE" : "FALSE") << std::endl;
oss << " Journal full (_jfull) = " << (_jfull ? "TRUE" : "FALSE") << std::endl;
oss << " Normalized fid list (_fid_list) = [";
for (std::vector<u_int16_t>::const_iterator i = _fid_list.begin(); i < _fid_list.end(); i++)
{
if (i != _fid_list.begin()) oss << ", ";
oss << *i;
}
oss << "]" << std::endl;
oss << " Enqueued records (txn & non-txn):" << std::endl;
for (unsigned i=0; i<_enq_cnt_list.size(); i++)
oss << " File " << std::setw(2) << i << ": " << _enq_cnt_list[i] <<
std::endl;
return oss.str();
}
std::string to_log(const std::string& jid)
{
std::ostringstream oss;
oss << "Recover file analysis (jid=\"" << jid << "\"):";
oss << " njf=" << _njf;
oss << " ae=" << (_owi ? "T" : "F");
oss << " aemjf=" << _aemjf;
oss << " owi=" << (_ae ? "T" : "F");
oss << " frot=" << (_frot ? "T" : "F");
oss << " jempty=" << (_jempty ? "T" : "F");
oss << " ffid=" << _ffid;
oss << " fro=0x" << std::hex << _fro << std::dec << " (" <<
(_fro/JRNL_DBLK_SIZE) << " dblks)";
oss << " lfid=" << _lfid;
oss << " eo=0x" << std::hex << _eo << std::dec << " (" <<
(_eo/JRNL_DBLK_SIZE) << " dblks)";
oss << " h_rid=0x" << std::hex << _h_rid << std::dec;
oss << " lffull=" << (_lffull ? "T" : "F");
oss << " jfull=" << (_jfull ? "T" : "F");
oss << " Enqueued records (txn & non-txn): [ ";
for (unsigned i=0; i<_enq_cnt_list.size(); i++)
{
if (i) oss << " ";
oss << "fid_" << std::setw(2) << std::setfill('0') << i << "=" << _enq_cnt_list[i];
}
oss << " ]";
return oss.str();
}
};
} // namespace journal
} // namespace mrg
#endif // ifndef QPID_LEGACYSTORE_JRNL_RCVDAT_H
|
