summaryrefslogtreecommitdiff
path: root/distribution/xfer/transfer_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'distribution/xfer/transfer_test.go')
-rw-r--r--distribution/xfer/transfer_test.go12
1 files changed, 6 insertions, 6 deletions
diff --git a/distribution/xfer/transfer_test.go b/distribution/xfer/transfer_test.go
index 9faecb8766..305bb91662 100644
--- a/distribution/xfer/transfer_test.go
+++ b/distribution/xfer/transfer_test.go
@@ -9,7 +9,7 @@ import (
)
func TestTransfer(t *testing.T) {
- makeXferFunc := func(id string) DoFunc {
+ makeXferFunc := func(id string) doFunc {
return func(progressChan chan<- progress.Progress, start <-chan struct{}, _ chan<- struct{}) transfer {
select {
case <-start:
@@ -71,7 +71,7 @@ func TestConcurrencyLimit(t *testing.T) {
const concurrencyLimit = 3
var runningJobs int32
- makeXferFunc := func(id string) DoFunc {
+ makeXferFunc := func(id string) doFunc {
return func(progressChan chan<- progress.Progress, start <-chan struct{}, _ chan<- struct{}) transfer {
xfer := newTransfer()
go func() {
@@ -130,7 +130,7 @@ func TestInactiveJobs(t *testing.T) {
var runningJobs int32
testDone := make(chan struct{})
- makeXferFunc := func(id string) DoFunc {
+ makeXferFunc := func(id string) doFunc {
return func(progressChan chan<- progress.Progress, start <-chan struct{}, inactive chan<- struct{}) transfer {
xfer := newTransfer()
go func() {
@@ -190,7 +190,7 @@ func TestInactiveJobs(t *testing.T) {
func TestWatchRelease(t *testing.T) {
ready := make(chan struct{})
- makeXferFunc := func(id string) DoFunc {
+ makeXferFunc := func(id string) doFunc {
return func(progressChan chan<- progress.Progress, start <-chan struct{}, _ chan<- struct{}) transfer {
xfer := newTransfer()
go func() {
@@ -279,7 +279,7 @@ func TestWatchRelease(t *testing.T) {
}
func TestWatchFinishedTransfer(t *testing.T) {
- makeXferFunc := func(id string) DoFunc {
+ makeXferFunc := func(id string) doFunc {
return func(progressChan chan<- progress.Progress, _ <-chan struct{}, _ chan<- struct{}) transfer {
xfer := newTransfer()
go func() {
@@ -321,7 +321,7 @@ func TestDuplicateTransfer(t *testing.T) {
var xferFuncCalls int32
- makeXferFunc := func(id string) DoFunc {
+ makeXferFunc := func(id string) doFunc {
return func(progressChan chan<- progress.Progress, _ <-chan struct{}, _ chan<- struct{}) transfer {
atomic.AddInt32(&xferFuncCalls, 1)
xfer := newTransfer()