diff --git a/synced-pool.go b/synced-pool.go index dcd658d..a80024c 100644 --- a/synced-pool.go +++ b/synced-pool.go @@ -278,10 +278,13 @@ func (r *RemoteHost) ConfirmChange(id CartId, host string) error { w.Write([]byte(fmt.Sprintf("%s;%s", id, host))) return nil }) - t, _, err := ReceivePacket(r.connection) + t, data, err := ReceivePacket(r.connection) if err != nil { return err } + if t == AckError { + return fmt.Errorf("error from remote: %s, from %s", string(data), r.Host) + } if t != AckChange { return fmt.Errorf("unexpected message type %d", t) }