scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-07 17:15:56 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

increased some transport buffer sizes

Browse source
This commit is contained in:
Todd Gruben 2015-01-13 19:30:28 +00:00
parent dce5ac60c4
commit f32ca7c3d4
2 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
core/http.go
View file

@ -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)

4
transport/tcp.go
View file

@ -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.