perf: use kitex BinaryProtocol replace apache BinaryProtocol

YangruiEmma · Aug 15, 2024 · d3aea58 · d3aea58
1 parent 5668b82
commit d3aea58
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/remote/codec/thrift/thrift.go b/pkg/remote/codec/thrift/thrift.go
@@ -211,7 +211,7 @@ func encodeBasicThrift(out remote.ByteBuffer, ctx context.Context, method string
 	}
 	_ = thrift.Binary.WriteMessageBegin(b, method, thrift.TMessageType(msgType), seqID)
 
-	if err := apache.ThriftWrite(apache.NewDefaultTransport(out), data); err != nil {
+	if err := apache.ThriftWrite(out, data); err != nil {
 		return err
 	}
 	return nil

diff --git a/pkg/remote/codec/thrift/thrift_data.go b/pkg/remote/codec/thrift/thrift_data.go
@@ -212,7 +212,7 @@ func decodeBasicThriftData(trans remote.ByteBuffer, data interface{}) error {
 	if err = verifyUnmarshalBasicThriftDataType(data); err != nil {
 		return err
 	}
-	if err = apache.ThriftRead(apache.NewDefaultTransport(trans), data); err != nil {
+	if err = apache.ThriftRead(trans, data); err != nil {
 		return remote.NewTransError(remote.ProtocolError, err)
 	}
 	return nil