Attachment 897321 Details for Bug 1098118 – Proposed alternative patch

[patch] Proposed alternative patch

RHBZ1098118.diff (text/plain), 4.48 KB, created by Kim van der Riet on 2014-05-19 21:05:55 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Kim van der Riet

Created: 2014-05-19 21:05:55 UTC

Size: 4.48 KB

patch

obsolete

>Index: cpp/src/qpid/linearstore/journal/jerrno.cpp
>===================================================================
>--- cpp/src/qpid/linearstore/journal/jerrno.cpp	(revision 1594215)
>+++ cpp/src/qpid/linearstore/journal/jerrno.cpp	(working copy)
>@@ -95,6 +95,7 @@
> const uint32_t jerrno::JERR_RCVM_NULLXID         = 0x0904;
> const uint32_t jerrno::JERR_RCVM_NOTDBLKALIGNED  = 0x0905;
> const uint32_t jerrno::JERR_RCVM_NULLFID         = 0x0907;
>+const uint32_t jerrno::JERR_RCVM_INVALIDEFPID    = 0x0908;
> 
> // class data_tok
> const uint32_t jerrno::JERR_DTOK_ILLEGALSTATE    = 0x0a00;
>@@ -188,6 +189,7 @@
>     _err_map[JERR_RCVM_NULLXID] = "JERR_RCVM_NULLXID: Null XID when XID length non-null in header";
>     _err_map[JERR_RCVM_NOTDBLKALIGNED] = "JERR_RCVM_NOTDBLKALIGNED: Offset is not data block (dblk)-aligned";
>     _err_map[JERR_RCVM_NULLFID] = "JERR_RCVM_NULLFID: Null file id (FID)";
>+    _err_map[JERR_RCVM_INVALIDEFPID] = "JERR_RCVM_INVALIDEFPID: Invalid EFP identity (partition/size)";
> 
>     // class data_tok
>     _err_map[JERR_DTOK_ILLEGALSTATE] = "JERR_MTOK_ILLEGALSTATE: Attempted to change to illegal state.";
>Index: cpp/src/qpid/linearstore/journal/jerrno.h
>===================================================================
>--- cpp/src/qpid/linearstore/journal/jerrno.h	(revision 1594215)
>+++ cpp/src/qpid/linearstore/journal/jerrno.h	(working copy)
>@@ -113,6 +113,7 @@
>         static const uint32_t JERR_RCVM_NULLXID;        ///< Null XID when XID length non-null in header
>         static const uint32_t JERR_RCVM_NOTDBLKALIGNED; ///< Offset is not data block (dblk)-aligned
>         static const uint32_t JERR_RCVM_NULLFID;        ///< Null file ID (FID)
>+        static const uint32_t JERR_RCVM_INVALIDEFPID;   ///< Invalid EFP identity (partition/size)
> 
>         // class data_tok
>         static const uint32_t JERR_DTOK_ILLEGALSTATE;   ///< Attempted to change to illegal state
>Index: cpp/src/qpid/linearstore/journal/RecoveryManager.cpp
>===================================================================
>--- cpp/src/qpid/linearstore/journal/RecoveryManager.cpp	(revision 1594215)
>+++ cpp/src/qpid/linearstore/journal/RecoveryManager.cpp	(working copy)
>@@ -99,10 +99,20 @@
>     // Analyze file headers of existing journal files
>     efpIdentity_t efpIdentity;
>     analyzeJournalFileHeaders(efpIdentity);
>-    *emptyFilePoolPtrPtr = emptyFilePoolManager->getEmptyFilePool(efpIdentity);
>-    efpFileSize_kib_ = (*emptyFilePoolPtrPtr)->fileSize_kib();
> 
>     if (!journalEmptyFlag_) {
>+        *emptyFilePoolPtrPtr = emptyFilePoolManager->getEmptyFilePool(efpIdentity);
>+        if (! *emptyFilePoolPtrPtr) {
>+            // TODO: At a later time, this could be used to establish a new pool size provided the partition exists.
>+            // If the partition does not exist, this is always an error. For now, throw an exception, as this should
>+            // not occur in any practical application. Once multiple partitions and mixed EFPs are supported, this
>+            // needs to be resolved. Note that EFP size is always a multiple of QLS_SBLK_SIZE_BYTES (currently 4096
>+            // bytes, any other value cannot be used and should be rejected as an error.
>+            std::ostringstream oss;
>+            oss << "Invalid EFP identity: Partition=" << efpIdentity.pn_ << " Size=" << efpIdentity.ds_ << "k";
>+            throw jexception(jerrno::JERR_RCVM_INVALIDEFPID, oss.str(), "RecoveryManager", "analyzeJournals");
>+        }
>+        efpFileSize_kib_ = (*emptyFilePoolPtrPtr)->fileSize_kib();
> 
>         // Read all records, establish remaining enqueued records
>         if (inFileStream_.is_open()) {
>@@ -409,15 +419,14 @@
>             if (fileHeader._file_number > highestFileNumber_) {
>                 highestFileNumber_ = fileHeader._file_number;
>             }
>+            // TODO: Logic weak here for detecting error conditions in journal, specifically when no
>+            // valid files exist, or files from mixed EFPs. Currently last read file header determines
>+            // efpIdentity.
>+            efpIdentity.pn_ = fileHeader._efp_partition;
>+            efpIdentity.ds_ = fileHeader._data_size_kib;
>         }
>     }
> 
>-    // TODO: Logic weak here for detecting error conditions in journal, specifically when no
>-    // valid files exist, or files from mixed EFPs. Currently last read file header determines
>-    // efpIdentity.
>-    efpIdentity.pn_ = fileHeader._efp_partition;
>-    efpIdentity.ds_ = fileHeader._data_size_kib;
>-
>     if (fileNumberMap_.empty()) {
>         journalEmptyFlag_ = true;
>     } else {

Actions: View | Diff

Attachments on bug 1098118: 895945 | 897321 | 897664