updates

galen0624 · Oct 23, 2018 · 2bbc5d0 · 2bbc5d0
1 parent c0fe13b
commit 2bbc5d0
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/registry/consul/backend.go b/registry/consul/backend.go
@@ -22,7 +22,7 @@ type be struct {
 func NewBackend(cfg *config.Consul) (registry.Backend, error) {
 	// create a reusable client
 	// Updated default Idle Connections setting to avoid TIME_WAIT issues
-	var httpTrans = &http.Transport{MaxIdleConnsPerHost: cfg.ConcurrentConsulRequests *2, MaxIdleConns: cfg.ConcurrentConsulRequests *2}
+	var httpTrans = &http.Transport{MaxIdleConnsPerHost: cfg.ConcurrentConsulRequests * 2, MaxIdleConns: cfg.ConcurrentConsulRequests * 2}
 	var httpClient = &http.Client{Transport: httpTrans}
 
 	c, err := api.NewClient(&api.Config{Address: cfg.Addr, Scheme: cfg.Scheme, Token: cfg.Token, HttpClient: httpClient})

diff --git a/registry/consul/service.go b/registry/consul/service.go
@@ -77,10 +77,13 @@ func servicesConfig(client *api.Client, checks []*api.HealthCheck, tagPrefix str
 	//Call serviceConfig Go Routines for every service
 	for name, passing := range m {
 		serviceChan <- ServiceChannel{Client: client, Name: name, Passing: passing, TagPrefix: tagPrefix}
+		log.Printf("BEFORE LOOP IS DONE %v", len(serviceChan))
 	}
-
+	log.Printf("AFTER LOOP IS DONE %v", len(serviceChan))
 	close(serviceChan)
+	log.Printf("AFTER CHAN CLOSE IS DONE %v", len(serviceChan))
 	wg.Wait()
+	log.Printf("AFTER WAIT IS DONE %v", len(serviceChan))
 
 	// sort config in reverse order to sort most specific config to the top
 	sort.Sort(sort.Reverse(sort.StringSlice(config)))