(
t plumbing.ObjectType,
seen map[plumbing.Hash]struct{},
)
| 624 | } |
| 625 | |
| 626 | func (s *ObjectStorage) buildPackfileIters( |
| 627 | t plumbing.ObjectType, |
| 628 | seen map[plumbing.Hash]struct{}, |
| 629 | ) (storer.EncodedObjectIter, error) { |
| 630 | if err := s.requireIndex(); err != nil { |
| 631 | return nil, err |
| 632 | } |
| 633 | |
| 634 | packs, err := s.dir.ObjectPacks() |
| 635 | if err != nil { |
| 636 | return nil, err |
| 637 | } |
| 638 | return &lazyPackfilesIter{ |
| 639 | hashes: packs, |
| 640 | open: func(h plumbing.Hash) (storer.EncodedObjectIter, error) { |
| 641 | pack, err := s.dir.ObjectPack(h) |
| 642 | if err != nil { |
| 643 | return nil, err |
| 644 | } |
| 645 | return newPackfileIter( |
| 646 | s.dir.Fs(), pack, t, seen, s.index[h], |
| 647 | s.objectCache, s.options.KeepDescriptors, |
| 648 | s.options.LargeObjectThreshold, |
| 649 | ) |
| 650 | }, |
| 651 | }, nil |
| 652 | } |
| 653 | |
| 654 | // Close closes all opened files. |
| 655 | func (s *ObjectStorage) Close() error { |
no test coverage detected