diff --git a/dht.go b/dht.go index d304c3a1b02..0f101e2c1a8 100644 --- a/dht.go +++ b/dht.go @@ -147,17 +147,10 @@ func (dht *IpfsDHT) putValueToPeer(ctx context.Context, p peer.ID, pmes := pb.NewMessage(pb.Message_PUT_VALUE, key, 0) pmes.Record = rec rpmes, err := dht.sendRequest(ctx, p, pmes) - switch err { - case ErrReadTimeout: - log.Warningf("read timeout: %s %s", p.Pretty(), key) - fallthrough - default: - return err - case nil: - break - } - if err != nil { + if err == ErrReadTimeout { + log.Warningf("read timeout: %s %s", p.Pretty(), key) + } return err }