Enum JournalRecordV62 

pub enum JournalRecordV62 {
    EndBlock,
    Mutation {
        object_id: u64,
        mutation: MutationV62,
    },
    Commit,
    Discard(u64),
    DidFlushDevice(u64),
    DataChecksums(u64, Range<u64>, ChecksumsV38, bool),
    CommitBorrowed(u64),
}

Variants

EndBlock

Mutation

Fields

object_id: u64

mutation: MutationV62

Commit

Commits records in the transaction.

Discard(u64)

Discard all mutations with offsets greater than or equal to the given offset.

DidFlushDevice(u64)

Indicates the device was flushed at the given journal offset. Note that this really means that at this point in the journal offset, we can be certain that there’s no remaining buffered data in the block device; the buffers and the disk contents are consistent. We insert one of these records after a flush along with the next transaction to go through. If that never comes (either due to graceful or hard shutdown), the journal reset on the next mount will serve the same purpose and count as a flush, although it is necessary to defensively flush the device before replaying the journal (if possible, i.e. not read-only) in case the block device connection was reused.

DataChecksums(u64, Range<u64>, ChecksumsV38, bool)

Checksums for a data range written by this transaction, for a particular store identified by the u64 object id. A transaction is only valid if these checksums are right. The range is the device offset the checksums are for.

A boolean indicates whether this range is being written to for the first time. For overwrite extents, we only check the checksums for a block if it has been written to for the first time since the last flush, because otherwise we can’t roll it back anyway so it doesn’t matter. For copy-on-write extents, the bool is always true.

CommitBorrowed(u64)

Commits records in a transaction that borrows metadata space, recording the total bytes currently held in ObjectManager::metadata_reservation (M_total).

Trait Implementations

impl Clone for JournalRecordV62

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for JournalRecordV62

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for JournalRecordV62

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<JournalRecordV56> for JournalRecordV62

fn from(item: JournalRecordV56) -> Self

Converts to this type from the input type.

impl From<JournalRecordV57> for JournalRecordV62

fn from(item: JournalRecordV57) -> Self

Converts to this type from the input type.

impl From<JournalRecordV59> for JournalRecordV62

fn from(item: JournalRecordV59) -> Self

Converts to this type from the input type.

impl From<JournalRecordV60> for JournalRecordV62

fn from(item: JournalRecordV60) -> Self

Converts to this type from the input type.

impl From<JournalRecordV61> for JournalRecordV62

fn from(from: JournalRecordV61) -> Self

Converts to this type from the input type.

impl Serialize for JournalRecordV62

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TypeFingerprint for JournalRecordV62

fn fingerprint() -> String

impl Versioned for JournalRecordV62

fn max_serialized_size() -> Option<u64>

Maximum size of a serialized version of this type. Serialization and deserialization will fail if the limit is exceeded. If None, there is no limit. None is preferred over u64::MAX because serializing and deserializing with a limit has runtime overhead.

fn deserialize_from<R>(reader: &mut R, _version: Version) -> Result<Self>

where R: Read + ?Sized, for<'de> Self: Deserialize<'de>,

fn serialize_into<W>(&self, writer: &mut W) -> Result<()>

where W: Write, Self: Serialize,

impl VersionedLatest for JournalRecordV62

fn deserialize_from_version<R>(reader: &mut R, version: Version) -> Result<Self>

where R: Read, Self: Sized,

Deserializes from a given version format and upgrades to the latest version.

fn deserialize_with_version<R>(reader: &mut R) -> Result<(Self, Version)>

where R: Read, Self: Sized,

Like deserialize_from_version but reads Version from reader first, then uses it to deserialize self.

fn serialize_with_version<W>(&self, writer: &mut W) -> Result<()>

where W: Write, Self: Sized,

Like serialize_into but serialized Version first, then self.