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 { 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()