diff --git a/fronted.go b/fronted.go index 9407585..9ec9ca9 100644 --- a/fronted.go +++ b/fronted.go @@ -156,7 +156,7 @@ func (f *fronted) vetBatch(start, batchSize int, successful *atomic.Uint32, list log.Debugf("Vetting masquerade batch %d-%d", start, start+batchSize) var wg sync.WaitGroup masqueradeSize := len(f.masquerades) - for j := start; j < start+batchSize && j < masqueradeSize; j++ { + for i := start; i < start+batchSize && i < masqueradeSize; i++ { wg.Add(1) go func(m MasqueradeInterface) { defer wg.Done() @@ -166,7 +166,7 @@ func (f *fronted) vetBatch(start, batchSize int, successful *atomic.Uint32, list go listener(f) } } - }(f.masquerades[j]) + }(f.masquerades[i]) } wg.Wait() } diff --git a/fronted_test.go b/fronted_test.go index f80cdf6..910a5ee 100644 --- a/fronted_test.go +++ b/fronted_test.go @@ -56,7 +56,7 @@ func TestDirectDomainFrontingWithSNIConfig(t *testing.T) { ArbitrarySNIs: []string{"mercadopago.com", "amazon.com.br", "facebook.com", "google.com", "twitter.com", "youtube.com", "instagram.com", "linkedin.com", "whatsapp.com", "netflix.com", "microsoft.com", "yahoo.com", "bing.com", "wikipedia.org", "github.com"}, }) testContext := NewFrontingContext("TestDirectDomainFrontingWithSNIConfig") - testContext.Configure(certs, p, testProviderID, cacheFile) + testContext.Configure(certs, p, "akamai", cacheFile) transport, ok := testContext.NewFronted(30 * time.Second) require.True(t, ok) diff --git a/test_support.go b/test_support.go index 54da8a7..a3fc561 100644 --- a/test_support.go +++ b/test_support.go @@ -58,6 +58,6 @@ func testProvidersWithHosts(hosts map[string]string) map[string]*Provider { } func testAkamaiProvidersWithHosts(hosts map[string]string, sniConfig *SNIConfig) map[string]*Provider { return map[string]*Provider{ - testProviderID: NewProvider(hosts, pingTestURL, DefaultAkamaiMasquerades, nil, nil, sniConfig, nil), + "akamai": NewProvider(hosts, pingTestURL, DefaultAkamaiMasquerades, nil, nil, sniConfig, nil), } }