From f32ca7c3d4b6cb1beb9f6a0295fc739987ec9044 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Tue, 13 Jan 2015 19:30:28 +0000 Subject: [PATCH] increased some transport buffer sizes --- core/http.go | 1 + transport/tcp.go | 4 ++-- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/core/http.go b/core/http.go index b26c04c2e..85194a3cb 100644 --- a/core/http.go +++ b/core/http.go @@ -269,6 +269,7 @@ func (self *WebService) HandleQuery(w http.ResponseWriter, r *http.Request) { http.Error(w, "Only POST allowed", http.StatusMethodNotAllowed) return } + util.SendInc("webservice_Query") err := r.ParseForm() if err != nil { http.Error(w, err.Error(), http.StatusBadRequest) diff --git a/transport/tcp.go b/transport/tcp.go index 61a1ccaa1..1af9a9556 100644 --- a/transport/tcp.go +++ b/transport/tcp.go @@ -149,8 +149,8 @@ func NewTcpTransport(service *core.Service) *TcpTransport { var network bytes.Buffer // Stand-in for a network connection p.service = service p.port = config.GetInt("port_tcp") - p.inbox = make(chan *db.Message, 100) - p.outbox = make(chan db.Envelope, 100) + p.inbox = make(chan *db.Message, 2048) + p.outbox = make(chan db.Envelope, 2048) p.connections = make(map[GUID]*connection) p.reg = make(chan *newconnection) p.enc = gob.NewEncoder(&network) // Will write to network.