diff options
Diffstat (limited to 'plumbing/transport/fetch_pack.go')
-rw-r--r-- | plumbing/transport/fetch_pack.go | 24 |
1 files changed, 23 insertions, 1 deletions
diff --git a/plumbing/transport/fetch_pack.go b/plumbing/transport/fetch_pack.go index 3b2a39c..5346e9d 100644 --- a/plumbing/transport/fetch_pack.go +++ b/plumbing/transport/fetch_pack.go @@ -33,7 +33,7 @@ func (i *UploadPackInfo) Decode(r io.Reader) error { ar := advrefs.New() if err := d.Decode(ar); err != nil { if err == advrefs.ErrEmpty { - return plumbing.NewPermanentError(err) + return err } return plumbing.NewUnexpectedError(err) } @@ -128,6 +128,28 @@ func (r *UploadPackRequest) Have(h ...plumbing.Hash) { r.Haves = append(r.Haves, h...) } +func (r *UploadPackRequest) IsEmpty() bool { + return isSubset(r.Wants, r.Haves) +} + +func isSubset(needle []plumbing.Hash, haystack []plumbing.Hash) bool { + for _, h := range needle { + found := false + for _, oh := range haystack { + if h == oh { + found = true + break + } + } + + if !found { + return false + } + } + + return true +} + func (r *UploadPackRequest) String() string { b, _ := ioutil.ReadAll(r.Reader()) return string(b) |