use int64

Signed-off-by: Tim Vaillancourt <[email protected]>

go/vt/discovery/topology_watcher.go

@@ -70,7 +70,7 @@ type TopologyWatcher struct {
 	cell                string
 	refreshInterval     time.Duration
 	refreshKnownTablets bool
-	concurrency         int
+	concurrency         int64
 	ctx                 context.Context
 	cancelFunc          context.CancelFunc
 	// wg keeps track of all launched Go routines.
@@ -92,7 +92,7 @@ type TopologyWatcher struct {
 
 // NewTopologyWatcher returns a TopologyWatcher that monitors all
 // the tablets in a cell, and reloads them as needed.
-func NewTopologyWatcher(ctx context.Context, topoServer *topo.Server, hc HealthCheck, f TabletFilter, cell string, refreshInterval time.Duration, refreshKnownTablets bool, topoReadConcurrency int) *TopologyWatcher {
+func NewTopologyWatcher(ctx context.Context, topoServer *topo.Server, hc HealthCheck, f TabletFilter, cell string, refreshInterval time.Duration, refreshKnownTablets bool, topoReadConcurrency int64) *TopologyWatcher {
 	tw := &TopologyWatcher{
 		topoServer:          topoServer,
 		healthcheck:         hc,

go/vt/topo/server.go

@@ -183,7 +183,7 @@ var (
 		"vtorc", "vtbackup"}
 
 	// Default read concurrency to use in order to avoid overhwelming the topo server.
-	DefaultReadConcurrency = 32
+	DefaultReadConcurrency int64 = 32
 )
 
 func init() {
@@ -196,7 +196,7 @@ func registerTopoFlags(fs *pflag.FlagSet) {
 	fs.StringVar(&topoImplementation, "topo_implementation", topoImplementation, "the topology implementation to use")
 	fs.StringVar(&topoGlobalServerAddress, "topo_global_server_address", topoGlobalServerAddress, "the address of the global topology server")
 	fs.StringVar(&topoGlobalRoot, "topo_global_root", topoGlobalRoot, "the path of the global topology data in the global topology server")
-	fs.IntVar(&DefaultReadConcurrency, "topo_read_concurrency", DefaultReadConcurrency, "Maximum concurrency of topo reads.")
+	fs.Int64Var(&DefaultReadConcurrency, "topo_read_concurrency", DefaultReadConcurrency, "Maximum concurrency of topo reads.")
 }
 
 // RegisterFactory registers a Factory for an implementation for a Server.

go/vt/topo/stats_conn.go

@@ -62,7 +62,7 @@ func NewStatsConn(cell string, conn Conn) *StatsConn {
 		cell:     cell,
 		conn:     conn,
 		readOnly: false,
-		readSem:  semaphore.NewWeighted(int64(DefaultReadConcurrency)),
+		readSem:  semaphore.NewWeighted(DefaultReadConcurrency),
 	}
 }