Skip to content

Commit

Permalink
chore: upgrade netpoll
Browse files Browse the repository at this point in the history
  • Loading branch information
ppzqh committed Mar 12, 2024
1 parent 5236e4f commit 6021da4
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 5 deletions.
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ require (
github.com/cloudwego/fastpb v0.0.4
github.com/cloudwego/frugal v0.1.14
github.com/cloudwego/localsession v0.0.2
github.com/cloudwego/netpoll v0.5.2-0.20240223104743-442f1dcc5fd8
github.com/cloudwego/netpoll v0.6.1-0.20240311120404-bb9c3f74620c
github.com/cloudwego/thriftgo v0.3.6
github.com/golang/mock v1.6.0
github.com/google/pprof v0.0.0-20220608213341-c488b8fa1db3
Expand Down
4 changes: 2 additions & 2 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -67,8 +67,8 @@ github.com/cloudwego/localsession v0.0.2/go.mod h1:kiJxmvAcy4PLgKtEnPS5AXed3xCiX
github.com/cloudwego/netpoll v0.2.4/go.mod h1:1T2WVuQ+MQw6h6DpE45MohSvDTKdy2DlzCx2KsnPI4E=
github.com/cloudwego/netpoll v0.3.1/go.mod h1:1T2WVuQ+MQw6h6DpE45MohSvDTKdy2DlzCx2KsnPI4E=
github.com/cloudwego/netpoll v0.4.0/go.mod h1:xVefXptcyheopwNDZjDPcfU6kIjZXZ4nY550k1yH9eQ=
github.com/cloudwego/netpoll v0.5.2-0.20240223104743-442f1dcc5fd8 h1:V3MCmC2xflvCSgTK3wptZqkINCHNKB4vb3BP1OYzPFk=
github.com/cloudwego/netpoll v0.5.2-0.20240223104743-442f1dcc5fd8/go.mod h1:xVefXptcyheopwNDZjDPcfU6kIjZXZ4nY550k1yH9eQ=
github.com/cloudwego/netpoll v0.6.1-0.20240311120404-bb9c3f74620c h1:2sEXWqPKzJINdLr7I/1rY7bIdMB4CTgjdcTH4mkjEpg=
github.com/cloudwego/netpoll v0.6.1-0.20240311120404-bb9c3f74620c/go.mod h1:xVefXptcyheopwNDZjDPcfU6kIjZXZ4nY550k1yH9eQ=
github.com/cloudwego/thriftgo v0.1.2/go.mod h1:LzeafuLSiHA9JTiWC8TIMIq64iadeObgRUhmVG1OC/w=
github.com/cloudwego/thriftgo v0.2.4/go.mod h1:8i9AF5uDdWHGqzUhXDlubCjx4MEfKvWXGQlMWyR0tM4=
github.com/cloudwego/thriftgo v0.2.7/go.mod h1:8i9AF5uDdWHGqzUhXDlubCjx4MEfKvWXGQlMWyR0tM4=
Expand Down
2 changes: 0 additions & 2 deletions pkg/remote/codec/default_codec.go
Original file line number Diff line number Diff line change
Expand Up @@ -196,7 +196,6 @@ func (c *defaultCodec) encodeMetaAndPayloadWithCRC32C(ctx context.Context, messa

// 1. encode payload and calculate crc32c checksum
payloadOut := netpoll.NewWriterByteBuffer(netpoll2.NewLinkBuffer())

if err = me.EncodePayload(ctx, message, payloadOut); err != nil {
return err
}
Expand All @@ -207,7 +206,6 @@ func (c *defaultCodec) encodeMetaAndPayloadWithCRC32C(ctx context.Context, messa
payloadOut.Release(err)
return err
}

crc32c := getCRC32C(payload)
strInfo := message.TransInfo().TransStrInfo()
if crc32c != "" && strInfo != nil {
Expand Down

0 comments on commit 6021da4

Please sign in to comment.