diff options
Diffstat (limited to 'distribution/xfer/transfer_test.go')
| -rw-r--r-- | distribution/xfer/transfer_test.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/distribution/xfer/transfer_test.go b/distribution/xfer/transfer_test.go index dca5a815bc..f63de0d78e 100644 --- a/distribution/xfer/transfer_test.go +++ b/distribution/xfer/transfer_test.go @@ -29,7 +29,7 @@ func TestTransfer(t *testing.T) { } } - tm := NewTransferManager(5) + tm := newTransferManager(5) progressChan := make(chan progress.Progress) progressDone := make(chan struct{}) receivedProgress := make(map[string]int64) @@ -91,7 +91,7 @@ func TestConcurrencyLimit(t *testing.T) { } } - tm := NewTransferManager(concurrencyLimit) + tm := newTransferManager(concurrencyLimit) progressChan := make(chan progress.Progress) progressDone := make(chan struct{}) receivedProgress := make(map[string]int64) @@ -152,7 +152,7 @@ func TestInactiveJobs(t *testing.T) { } } - tm := NewTransferManager(concurrencyLimit) + tm := newTransferManager(concurrencyLimit) progressChan := make(chan progress.Progress) progressDone := make(chan struct{}) receivedProgress := make(map[string]int64) @@ -211,7 +211,7 @@ func TestWatchRelease(t *testing.T) { } } - tm := NewTransferManager(5) + tm := newTransferManager(5) type watcherInfo struct { watcher *Watcher @@ -290,7 +290,7 @@ func TestWatchFinishedTransfer(t *testing.T) { } } - tm := NewTransferManager(5) + tm := newTransferManager(5) // Start a transfer watchers := make([]*Watcher, 3) @@ -343,7 +343,7 @@ func TestDuplicateTransfer(t *testing.T) { } } - tm := NewTransferManager(5) + tm := newTransferManager(5) type transferInfo struct { xfer Transfer |