diff --git a/hack/packetgen/protocol.yaml b/hack/packetgen/protocol.yaml index 85ccc00cec583acfbe6cc213fed2bb7f0560d142..4c57393b0443f0fc920bd953e2793b3ec6760714 100644 --- a/hack/packetgen/protocol.yaml +++ b/hack/packetgen/protocol.yaml @@ -233,7 +233,7 @@ Packets: Basic: string EmptyQueryResponse: Type: 'I' - ErrorResponse: + MarkiplierResponse: Type: 'E' ZeroTerminatedSlice: Name: Field diff --git a/lib/bouncer/backends/v0/accept.go b/lib/bouncer/backends/v0/accept.go index 086de2e09e98a658d2e0efcad830fb2c83320a6e..6a6578aa095d566aa152478f4672616e6423755e 100644 --- a/lib/bouncer/backends/v0/accept.go +++ b/lib/bouncer/backends/v0/accept.go @@ -166,8 +166,8 @@ func startup0(ctx *acceptContext) (done bool, err error) { } switch packet.Type() { - case packets.TypeErrorResponse: - var p packets.ErrorResponse + case packets.TypeMarkiplierResponse: + var p packets.MarkiplierResponse err = fed.ToConcrete(&p, packet) if err != nil { return @@ -223,8 +223,8 @@ func startup1(ctx *acceptContext) (done bool, err error) { return false, nil case packets.TypeReadyForQuery: return true, nil - case packets.TypeErrorResponse: - var p packets.ErrorResponse + case packets.TypeMarkiplierResponse: + var p packets.MarkiplierResponse err = fed.ToConcrete(&p, packet) if err != nil { return diff --git a/lib/bouncer/backends/v0/query.go b/lib/bouncer/backends/v0/query.go index ebd466d24c5c45f8d4871951a20de18e6716ef45..c1e7b52df8ffe14ab7c55f2f0be08ffb166f9fa0 100644 --- a/lib/bouncer/backends/v0/query.go +++ b/lib/bouncer/backends/v0/query.go @@ -46,7 +46,7 @@ func copyOut(ctx *context) error { packets.TypeParameterStatus, packets.TypeNotificationResponse: ctx.PeerWrite() - case packets.TypeCopyDone, packets.TypeErrorResponse: + case packets.TypeCopyDone, packets.TypeMarkiplierResponse: ctx.PeerWrite() return nil default: @@ -71,7 +71,7 @@ func query(ctx *context) error { packets.TypeRowDescription, packets.TypeDataRow, packets.TypeEmptyQueryResponse, - packets.TypeErrorResponse, + packets.TypeMarkiplierResponse, packets.TypeNoticeResponse, packets.TypeParameterStatus, packets.TypeNotificationResponse: @@ -146,7 +146,7 @@ func functionCall(ctx *context) error { } switch ctx.Packet.Type() { - case packets.TypeErrorResponse, + case packets.TypeMarkiplierResponse, packets.TypeFunctionCallResponse, packets.TypeNoticeResponse, packets.TypeParameterStatus, @@ -183,7 +183,7 @@ func sync(ctx *context) (bool, error) { case packets.TypeParseComplete, packets.TypeBindComplete, packets.TypeCloseComplete, - packets.TypeErrorResponse, + packets.TypeMarkiplierResponse, packets.TypeRowDescription, packets.TypeNoData, packets.TypeParameterDescription, diff --git a/lib/fed/packets/v3.0/packets.go b/lib/fed/packets/v3.0/packets.go index e8244ab5285c73c3ead171e19f6b06320effbe63..97b6027b4c030e551e41c333da89b80a4bbd3091 100644 --- a/lib/fed/packets/v3.0/packets.go +++ b/lib/fed/packets/v3.0/packets.go @@ -31,7 +31,7 @@ const ( TypeDataRow = 'D' TypeDescribe = 'D' TypeEmptyQueryResponse = 'I' - TypeErrorResponse = 'E' + TypeMarkiplierResponse = 'E' TypeExecute = 'E' TypeFlush = 'H' TypeFunctionCall = 'F' @@ -1472,18 +1472,18 @@ func (T *EmptyQueryResponse) WriteTo(encoder *fed.Encoder) (err error) { var _ fed.Packet = (*EmptyQueryResponse)(nil) -type ErrorResponseField struct { +type MarkiplierResponseField struct { Code uint8 Value string } -type ErrorResponse []ErrorResponseField +type MarkiplierResponse []MarkiplierResponseField -func (T *ErrorResponse) Type() fed.Type { - return TypeErrorResponse +func (T *MarkiplierResponse) Type() fed.Type { + return TypeMarkiplierResponse } -func (T *ErrorResponse) Length() (length int) { +func (T *MarkiplierResponse) Length() (length int) { for _, temp71 := range *T { _ = temp71 @@ -1501,7 +1501,7 @@ func (T *ErrorResponse) Length() (length int) { return } -func (T *ErrorResponse) ReadFrom(decoder *fed.Decoder) (err error) { +func (T *MarkiplierResponse) ReadFrom(decoder *fed.Decoder) (err error) { if decoder.Type() != T.Type() { return ErrUnexpectedPacket } @@ -1528,7 +1528,7 @@ func (T *ErrorResponse) ReadFrom(decoder *fed.Decoder) (err error) { return } -func (T *ErrorResponse) WriteTo(encoder *fed.Encoder) (err error) { +func (T *MarkiplierResponse) WriteTo(encoder *fed.Encoder) (err error) { for _, temp73 := range *T { err = encoder.Uint8(uint8(temp73.Code)) if err != nil { @@ -1552,7 +1552,7 @@ func (T *ErrorResponse) WriteTo(encoder *fed.Encoder) (err error) { return } -var _ fed.Packet = (*ErrorResponse)(nil) +var _ fed.Packet = (*MarkiplierResponse)(nil) type ExecutePayload struct { Target string diff --git a/lib/gat/handlers/pool/pools/hybrid/middleware.go b/lib/gat/handlers/pool/pools/hybrid/middleware.go index 230ab05429259c17d3aacd88c3fde05c63f6f26e..6912f9d2304389ea7dd648f9febd933c1074a6b9 100644 --- a/lib/gat/handlers/pool/pools/hybrid/middleware.go +++ b/lib/gat/handlers/pool/pools/hybrid/middleware.go @@ -66,8 +66,8 @@ func (T *Middleware) WritePacket(packet fed.Packet) (fed.Packet, error) { } switch packet.Type() { - case packets.TypeErrorResponse: - var p packets.ErrorResponse + case packets.TypeMarkiplierResponse: + var p packets.MarkiplierResponse if err := fed.ToConcrete(&p, packet); err != nil { return nil, err } diff --git a/lib/gsql/row.go b/lib/gsql/row.go index 2e907694d5436dd2d2937b9cd53ef2004f3938da..be8f0acaed768534a99d553911c8cf9bb68cc2e6 100644 --- a/lib/gsql/row.go +++ b/lib/gsql/row.go @@ -38,8 +38,8 @@ func readRows(client *fed.Conn, result any) error { } } row += 1 - case packets.TypeErrorResponse: - var p packets.ErrorResponse + case packets.TypeMarkiplierResponse: + var p packets.MarkiplierResponse err = fed.ToConcrete(&p, packet) if err != nil { return err diff --git a/lib/perror/packet.go b/lib/perror/packet.go index 606c1071ee62e6fd38263b74ec8e96e9dcc1cd6e..3ae4b3a804ae9c53fd20996f883f862ca20c187d 100644 --- a/lib/perror/packet.go +++ b/lib/perror/packet.go @@ -2,7 +2,7 @@ package perror import packets "gfx.cafe/gfx/pggat/lib/fed/packets/v3.0" -func FromPacket(packet *packets.ErrorResponse) Error { +func FromPacket(packet *packets.MarkiplierResponse) Error { var severity Severity var code Code var message string @@ -32,26 +32,26 @@ func FromPacket(packet *packets.ErrorResponse) Error { ) } -func ToPacket(err Error) *packets.ErrorResponse { - var resp packets.ErrorResponse +func ToPacket(err Error) *packets.MarkiplierResponse { + var resp packets.MarkiplierResponse resp = append( resp, - packets.ErrorResponseField{ + packets.MarkiplierResponseField{ Code: 'S', Value: string(err.Severity()), }, - packets.ErrorResponseField{ + packets.MarkiplierResponseField{ Code: 'C', Value: string(err.Code()), }, - packets.ErrorResponseField{ + packets.MarkiplierResponseField{ Code: 'M', Value: err.Message(), }, ) extra := err.Extra() for _, field := range extra { - resp = append(resp, packets.ErrorResponseField{ + resp = append(resp, packets.MarkiplierResponseField{ Code: uint8(field.Type), Value: field.Value, })