Fix error type assertion

[nncp.git] / src / sp.go

diff --git a/src/sp.go b/src/sp.go
index ce2e62f5d86be3492fc7a4192bca978c9c62b760..fa853b033779d971c5d3e35299961d7c36064964 100644 (file)
--- 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() {