X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Fsp.go;h=fa853b033779d971c5d3e35299961d7c36064964;hb=8acf65085c9baac6ab39a90a51f66f2b9b4649b5;hp=ce2e62f5d86be3492fc7a4192bca978c9c62b760;hpb=1d2ce674b042d07fd9b37a46578c8b62bb0345b7;p=nncp.git

diff --git a/src/sp.go b/src/sp.go
index ce2e62f..fa853b0 100644
--- a/src/sp.go
+++ b/src/sp.go
@@ -680,6 +680,9 @@ func (state *SPState) StartWorkers(
 			conn.SetReadDeadline(time.Now().Add(DefaultDeadline * time.Second))
 			payload, err := state.ReadSP(conn)
 			if err != nil {
+				if err == io.EOF {
+					break
+				}
 				unmarshalErr := err.(*xdr.UnmarshalError)
 				netErr, ok := unmarshalErr.Err.(net.Error)
 				if ok && netErr.Timeout() {