From bae4ed58e484073ecd1a7f73a571c50e7ccb246c Mon Sep 17 00:00:00 2001 From: siddontang Date: Fri, 24 Oct 2014 20:32:49 +0800 Subject: [PATCH 1/2] benchmark add GOMAXPROCS --- cmd/ledis-benchmark/main.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/cmd/ledis-benchmark/main.go b/cmd/ledis-benchmark/main.go index dad16f2..8f7d65d 100644 --- a/cmd/ledis-benchmark/main.go +++ b/cmd/ledis-benchmark/main.go @@ -5,6 +5,7 @@ import ( "fmt" "github.com/siddontang/ledisdb/client/go/ledis" "math/rand" + "runtime" "sync" "sync/atomic" "time" @@ -246,6 +247,8 @@ func benchZRevRangeByRank() { } func main() { + runtime.GOMAXPROCS(runtime.NumCPU()) + flag.Parse() if *number <= 0 { From 688d697bb715e9b96b15bb64fb1cb4212c2858b1 Mon Sep 17 00:00:00 2001 From: siddontang Date: Fri, 24 Oct 2014 20:39:29 +0800 Subject: [PATCH 2/2] use 4096 for connection read buffer --- server/client_resp.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/client_resp.go b/server/client_resp.go index 93edef9..cd5bee3 100644 --- a/server/client_resp.go +++ b/server/client_resp.go @@ -33,7 +33,7 @@ func newClientRESP(conn net.Conn, app *App) { c.client = newClient(app) c.conn = conn - c.rb = bufio.NewReaderSize(conn, 256) + c.rb = bufio.NewReaderSize(conn, 4096) c.resp = newWriterRESP(conn) c.remoteAddr = conn.RemoteAddr().String()