octoleo/restic
2
2
Fork 0
mirror of https://github.com/octoleo/restic.git synced 2024-11-25 22:27:35 +00:00
Code Issues Releases Wiki Activity

restorer: unexport archive pipe

Browse Source
This commit is contained in:
Alexander Neumann 2015-05-02 15:31:31 +02:00
parent b335de6b81
commit 819b6da762
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
archiver.go
View File

@ -459,7 +459,7 @@ func (arch *Archiver) dirWorker(wg *sync.WaitGroup, p *Progress, done <-chan str
} }
} }
type ArchivePipe struct { type archivePipe struct {
Old <-chan WalkTreeJob Old <-chan WalkTreeJob
New <-chan pipe.Job New <-chan pipe.Job
} }
@ -499,7 +499,7 @@ type archiveJob struct {
new pipe.Job new pipe.Job
} }
func (a *ArchivePipe) compare(done <-chan struct{}, out chan<- pipe.Job) { func (a *archivePipe) compare(done <-chan struct{}, out chan<- pipe.Job) {
defer func() { defer func() {
close(out) close(out)
debug.Log("ArchivePipe.compare", "done") debug.Log("ArchivePipe.compare", "done")
@ -638,7 +638,7 @@ func (arch *Archiver) Snapshot(p *Progress, paths []string, pid backend.ID) (*Sn
return nil, nil, err return nil, nil, err
} }
jobs := ArchivePipe{} jobs := archivePipe{}
// use parent snapshot (if some was given) // use parent snapshot (if some was given)
if pid != nil { if pid != nil {

2
archiver_int_test.go
View File

@ -115,7 +115,7 @@ func TestArchivePipe(t *testing.T) {
go testTreeWalker(done, treeCh) go testTreeWalker(done, treeCh)
go testPipeWalker(done, pipeCh) go testPipeWalker(done, pipeCh)
p := ArchivePipe{Old: treeCh, New: pipeCh} p := archivePipe{Old: treeCh, New: pipeCh}
ch := make(chan pipe.Job) ch := make(chan pipe.Job)