X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=peer-conn-msg-writer.go;h=1bacc59d188c59ceb726abf4911939092ac9f574;hb=050e5cbab8e26a9b28e57a7bc2a964b6d2ceb899;hp=0dbc4ead45c4ee27c73e5edf1a3ccee9878cdb48;hpb=e931f0c113c3514a504d72f2dfa2e4f2485a18e7;p=btrtrc.git

diff --git a/peer-conn-msg-writer.go b/peer-conn-msg-writer.go
index 0dbc4ead..1bacc59d 100644
--- a/peer-conn-msg-writer.go
+++ b/peer-conn-msg-writer.go
@@ -104,6 +104,9 @@ func (cn *peerConnMsgWriter) run(keepAliveTimeout time.Duration) {
 			if err == nil && n != len(next) {
 				panic("expected full write")
 			}
+			if err != nil {
+				break
+			}
 		}
 		if err != nil {
 			cn.logger.WithDefaultLevel(log.Debug).Printf("error writing: %v", err)