Skip to content

Commit 9ff5944

Browse files
fix: set default to 4k to cpu (#32)
1 parent 1925cd3 commit 9ff5944

File tree

5 files changed

+7
-9
lines changed

5 files changed

+7
-9
lines changed

example/go.sum

+2-4
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,6 @@ cloud.google.com/go/storage v1.6.0/go.mod h1:N7U0C8pVQ/+NIKOBQyamJIeKQKkZ+mxpohl
3333
cloud.google.com/go/storage v1.8.0/go.mod h1:Wv1Oy7z6Yz3DshWRJFhqM/UCfaWIRTdp0RXyy7KQOVs=
3434
cloud.google.com/go/storage v1.10.0/go.mod h1:FLPqc6j+Ki4BU591ie1oL6qBQGu2Bl/tZ9ullr3+Kg0=
3535
dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU=
36-
dubbo.apache.org/dubbo-go/v3 v3.0.0-rc2.0.20211007054845-07e6f4405545 h1:7hwhZ5YPaRexPOyHVTFcYqIsBcB8s/uFdEyKts5yXS4=
37-
dubbo.apache.org/dubbo-go/v3 v3.0.0-rc2.0.20211007054845-07e6f4405545/go.mod h1:84/HH7kK42HDa3DXrtj0Eyy2bVBstV3Z3sF0s4NcXZY=
3836
dubbo.apache.org/dubbo-go/v3 v3.0.0-rc2.0.20211011045321-e213f97fda57 h1:8s534SRhqQ7Kl6SNJKOoS2PtmEWuGz6zpEj9hixvs/A=
3937
dubbo.apache.org/dubbo-go/v3 v3.0.0-rc2.0.20211011045321-e213f97fda57/go.mod h1:84/HH7kK42HDa3DXrtj0Eyy2bVBstV3Z3sF0s4NcXZY=
4038
github.com/Azure/go-ansiterm v0.0.0-20170929234023-d6e3b3328b78/go.mod h1:LmzpDX56iTiv29bbRTIsUNlaFfuhWRQBWjQdVyAevI8=
@@ -182,8 +180,8 @@ github.com/dubbogo/go-zookeeper v1.0.3/go.mod h1:fn6n2CAEer3novYgk9ULLwAjuV8/g4D
182180
github.com/dubbogo/gost v1.9.0/go.mod h1:pPTjVyoJan3aPxBPNUX0ADkXjPibLo+/Ib0/fADXSG8=
183181
github.com/dubbogo/gost v1.11.12/go.mod h1:vIcP9rqz2KsXHPjsAwIUtfJIJjppQLQDcYaZTy/61jI=
184182
github.com/dubbogo/gost v1.11.17/go.mod h1:vIcP9rqz2KsXHPjsAwIUtfJIJjppQLQDcYaZTy/61jI=
185-
github.com/dubbogo/gost v1.11.18-0.20211011142005-8a95129ef6e2 h1:UU3dQZo/NE6VUf6ib5lyAjDfxuI6qX+aq8OZZx649JE=
186-
github.com/dubbogo/gost v1.11.18-0.20211011142005-8a95129ef6e2/go.mod h1:vIcP9rqz2KsXHPjsAwIUtfJIJjppQLQDcYaZTy/61jI=
183+
github.com/dubbogo/gost v1.11.18 h1:e9WRvDQut6cePYcQEOUC15vGSfftO7q9G2+Vw2s4CHE=
184+
github.com/dubbogo/gost v1.11.18/go.mod h1:vIcP9rqz2KsXHPjsAwIUtfJIJjppQLQDcYaZTy/61jI=
187185
github.com/dubbogo/jsonparser v1.0.1/go.mod h1:tYAtpctvSP/tWw4MeelsowSPgXQRVHHWbqL6ynps8jU=
188186
github.com/dubbogo/net v0.0.4 h1:Rn9aMPZwOiRE22YhtxmDEE3H0Q3cfVRNhuEjNMelJ/8=
189187
github.com/dubbogo/net v0.0.4/go.mod h1:1CGOnM7X3he+qgGNqjeADuE5vKZQx/eMSeUkpU3ujIc=

internal/codec/codec_impl/codec_impl.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ func (h *GenericCodec) UnmarshalRequest(data []byte) ([]interface{}, error) {
155155
if err != nil {
156156
return nil, err
157157
}
158-
result := make([]interface{}, 0)
158+
result := make([]interface{}, 0, len(wrapperRequest.Args))
159159

160160
for _, value := range wrapperRequest.Args {
161161
decoder := hessian.NewDecoder(value)

internal/codec/twoway_codec_impl/twoway_codec_impl.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -61,9 +61,9 @@ func NewPBWrapperTwoWayCodec(codecName constant.CodecType) (common.TwoWayCodec,
6161

6262
// MarshalRequest marshal interface @v to []byte
6363
func (h *PBWrapperTwoWayCodec) MarshalRequest(v interface{}) ([]byte, error) {
64-
argsBytes := make([][]byte, 0)
65-
argsTypes := make([]string, 0)
6664
reqList := v.([]interface{})
65+
argsBytes := make([][]byte, 0, len(reqList))
66+
argsTypes := make([]string, 0, len(reqList))
6767
for _, value := range reqList {
6868
data, err := h.codec.Marshal(value)
6969
if err != nil {

pkg/common/constant/constant.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ const (
2323
TRIPLE = "tri"
2424

2525
// DefaultHttp2ControllerReadBufferSize is default read buffer size of triple client/server
26-
DefaultHttp2ControllerReadBufferSize = 1000000
26+
DefaultHttp2ControllerReadBufferSize = 4096
2727

2828
// DefaultTimeout is default timeout seconds of triple client
2929
DefaultTimeout = 15

pkg/http2/server.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,7 @@ func skipHeader(frameData []byte) ([]byte, uint32) {
195195
func readSplitData(ctx context.Context, rBody io.ReadCloser) chan *bytes.Buffer {
196196
cbm := make(chan *bytes.Buffer)
197197
go func() {
198-
buf := make([]byte, 4098) // todo configurable
198+
buf := make([]byte, 4096) // todo configurable
199199
for {
200200
splitBuffer := bytes.NewBuffer(make([]byte, 0))
201201

0 commit comments

Comments
 (0)