Merge pull request #1906 from yichengq/261

rafthttp: log the type of message that is dropped when sending
This commit is contained in:
Yicheng Qin 2014-12-10 13:23:24 -08:00
commit d4dcd39b83

View File

@ -153,7 +153,8 @@ func (s *sender) Send(m raftpb.Message) error {
case s.q <- data:
return nil
default:
log.Printf("sender: reach the maximal serving to %s", s.u)
log.Printf("sender: dropping %s because maximal number %d of sender buffer entries to %s has been reached",
m.Type, senderBufSize, s.u)
return fmt.Errorf("reach maximal serving")
}
}