src/Npgsql/Replication/PgOutput/Messages/CommitPreparedMessage.cs - test-logs - dev-npgsql/npgsql

src/Npgsql/Replication/PgOutput/Messages/CommitPreparedMessage.cs

59 строк2 KB

Nino Floris

Remove obsolete UTF-8 BOMs (#6542)

13 апр 2026, 17:13

13 апр 2026, 17:135225216

using NpgsqlTypes;
using System;

namespace Npgsql.Replication.PgOutput.Messages;

/// <summary>
/// Logical Replication Protocol commit prepared message
/// </summary>
public sealed class CommitPreparedMessage : PreparedTransactionControlMessage
{
    /// <summary>
    /// Flags for the commit prepared; currently unused.
    /// </summary>
    public CommitPreparedFlags Flags { get; private set; }

    /// <summary>
    /// The LSN of the commit prepared.
    /// </summary>
    public NpgsqlLogSequenceNumber CommitPreparedLsn => FirstLsn;

    /// <summary>
    /// The end LSN of the commit prepared transaction.
    /// </summary>
    public NpgsqlLogSequenceNumber CommitPreparedEndLsn => SecondLsn;

    /// <summary>
    /// Commit timestamp of the transaction.
    /// </summary>
    public DateTime TransactionCommitTimestamp => Timestamp;

    internal CommitPreparedMessage() {}

    internal CommitPreparedMessage Populate(
        NpgsqlLogSequenceNumber walStart, NpgsqlLogSequenceNumber walEnd, DateTime serverClock, CommitPreparedFlags flags,
        NpgsqlLogSequenceNumber commitPreparedLsn, NpgsqlLogSequenceNumber commitPreparedEndLsn, DateTime transactionCommitTimestamp,
        uint transactionXid, string transactionGid)
    {
        base.Populate(walStart, walEnd, serverClock,
            firstLsn: commitPreparedLsn,
            secondLsn: commitPreparedEndLsn,
            timestamp: transactionCommitTimestamp,
            transactionXid: transactionXid,
            transactionGid: transactionGid);
        Flags = flags;
        return this;
    }

    /// <summary>
    /// Flags for the commit prepared; currently unused.
    /// </summary>
    [Flags]
    public enum CommitPreparedFlags : byte
    {
        /// <summary>
        /// No flags.
        /// </summary>
        None = 0
    }
}