| /* |
| * |
| * 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 |
