check sendSRR response

2013-09-17 19:18:50 -04:00 · 2013-09-17 19:18:50 -04:00 · 0e62627e27
parent 851ca9ceea
commit 0e62627e27
1 changed files with 6 additions and 0 deletions
--- a/peer.go
+++ b/peer.go
@ -255,6 +255,12 @@ func (p *Peer) sendSnapshotRecoveryRequest() {
 	req := newSnapshotRecoveryRequest(p.server.name, p.server.lastSnapshot)
 	debugln("peer.snap.recovery.send: ", p.Name)
 	resp := p.server.Transporter().SendSnapshotRecoveryRequest(p.server, p, req)
+
+	if resp == nil {
+		debugln("peer.snap.recovery.timeout: ", p.Name)
+		return
+	}
+
 	if resp.Success {
 		p.prevLogIndex = req.LastIndex
 	} else {