Skip to content
This repository was archived by the owner on Sep 9, 2020. It is now read-only.

Commit 12e6393

Browse files
committed
absorb setUpSourceGateway method into caller
1 parent a529c8c commit 12e6393

File tree

1 file changed

+0
-5
lines changed

1 file changed

+0
-5
lines changed

internal/gps/source.go

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -82,11 +82,6 @@ func (sc *sourceCoordinator) getSourceGatewayFor(ctx context.Context, id Project
8282

8383
// No gateway exists for this path yet; set up a proto, being careful to fold
8484
// together simultaneous attempts on the same path.
85-
return sc.setUpSourceGateway(ctx, normalizedName)
86-
}
87-
88-
// Not intended to be called externally - call getSourceGatewayFor instead.
89-
func (sc *sourceCoordinator) setUpSourceGateway(ctx context.Context, normalizedName string) (*sourceGateway, error) {
9085
sc.psrcmut.Lock()
9186
if chans, has := sc.protoSrcs[normalizedName]; has {
9287
// Another goroutine is already working on this normalizedName. Fold

0 commit comments

Comments
 (0)