From b3b8c3bc4fec872cb78259f6107fce9293906aa3 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Mon, 23 Jun 2014 17:23:41 -0500 Subject: [PATCH] more logging in topology --- db/topology.go | 2 +- transport/tcp.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/db/topology.go b/db/topology.go index 591247d72..7bfc919f4 100644 --- a/db/topology.go +++ b/db/topology.go @@ -334,7 +334,7 @@ func (d *Database) GetFragmentForBitmap(slice *Slice, bitmap *Bitmap) (*Fragment } frag_id_s, err := fsi.hashring.Get(fmt.Sprintf("%d", bitmap.Id)) if err != nil { - log.Println("ERROR FSI.GET:", bitmap.Id, bitmap.FrameType, frame, slice) + log.Println("ERROR FSI.GET:", bitmap.Id, bitmap.FrameType, d.Name, frame, slice) log.Println(err) return nil, err } diff --git a/transport/tcp.go b/transport/tcp.go index 09cfc314b..5bf113242 100644 --- a/transport/tcp.go +++ b/transport/tcp.go @@ -144,7 +144,7 @@ func (self *TcpTransport) listen() { } func (self *TcpTransport) manage(conn *net.Conn) { - con := &connection{self, make(chan *db.Message, 100), make(chan *db.Message, 100), conn, nil} + con := &connection{self, make(chan *db.Message, 1024), make(chan *db.Message, 1024), conn, nil} con.manage() }