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.