From ef8b13c1ef0f6b001912c2ca337e0d036efb2140 Mon Sep 17 00:00:00 2001 From: Juliana Fajardini Date: Fri, 4 Apr 2025 14:34:26 -0700 Subject: [PATCH] pgsql: use generic name for TerminationMessage msg Since this structure can be used for different messages with other meanings. Related to Task #4854 --- rust/src/pgsql/logger.rs | 2 +- rust/src/pgsql/parser.rs | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/rust/src/pgsql/logger.rs b/rust/src/pgsql/logger.rs index 7fb3343654..ae28101431 100644 --- a/rust/src/pgsql/logger.rs +++ b/rust/src/pgsql/logger.rs @@ -102,7 +102,7 @@ fn log_request(req: &PgsqlFEMessage, flags: u32) -> Result { diff --git a/rust/src/pgsql/parser.rs b/rust/src/pgsql/parser.rs index 034d3bf2e8..2bddbb1138 100644 --- a/rust/src/pgsql/parser.rs +++ b/rust/src/pgsql/parser.rs @@ -278,7 +278,7 @@ pub struct CopyOutResponse { } #[derive(Debug, PartialEq, Eq)] -pub struct TerminationMessage { +pub struct NoPayloadMessage { pub identifier: u8, pub length: u32, } @@ -300,7 +300,7 @@ pub enum PgsqlBEMessage { CommandComplete(RegularPacket), CopyOutResponse(CopyOutResponse), ConsolidatedCopyDataOut(ConsolidatedDataRowPacket), - CopyDone(TerminationMessage), + CopyDone(NoPayloadMessage), ReadyForQuery(ReadyForQueryMessage), RowDescription(RowDescriptionMessage), ConsolidatedDataRow(ConsolidatedDataRowPacket), @@ -384,7 +384,7 @@ pub enum PgsqlFEMessage { SASLResponse(RegularPacket), SimpleQuery(RegularPacket), CancelRequest(CancelRequestMessage), - Terminate(TerminationMessage), + Terminate(NoPayloadMessage), UnknownMessageType(RegularPacket), } @@ -776,7 +776,7 @@ fn parse_terminate_message(i: &[u8]) -> IResult<&[u8], PgsqlFEMessage, PgsqlPars let (i, length) = parse_exact_length(i, PGSQL_LENGTH_FIELD)?; Ok(( i, - PgsqlFEMessage::Terminate(TerminationMessage { identifier, length }), + PgsqlFEMessage::Terminate(NoPayloadMessage { identifier, length }), )) } @@ -1066,7 +1066,7 @@ fn parse_copy_done(i: &[u8]) -> IResult<&[u8], PgsqlBEMessage, PgsqlParseError<& let (i, identifier) = verify(be_u8, |&x| x == b'c')(i)?; let (i, length) = parse_exact_length(i, PGSQL_LENGTH_FIELD)?; Ok(( - i, PgsqlBEMessage::CopyDone(TerminationMessage { + i, PgsqlBEMessage::CopyDone(NoPayloadMessage { identifier, length }) -- 2.47.2