rename IdleTasklistCheckInterval

cadence-workflow · Jan 26, 2018 · d341e9d · d341e9d
1 parent 6927ba9
commit d341e9d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/service/matching/service.go b/service/matching/service.go
@@ -38,7 +38,7 @@ type Config struct {
 	RangeSize                  int64
 	GetTasksBatchSize          int
 	UpdateAckInterval          time.Duration
-	CheckPollerInterval        time.Duration
+	IdleTasklistCheckInterval  time.Duration
 	MinTaskThrottlingBurstSize int
 
 	// taskWriter configuration
@@ -54,7 +54,7 @@ func NewConfig() *Config {
 		RangeSize:                       100000,
 		GetTasksBatchSize:               1000,
 		UpdateAckInterval:               10 * time.Second,
-		CheckPollerInterval:             5 * time.Minute,
+		IdleTasklistCheckInterval:       5 * time.Minute,
 		OutstandingTaskAppendsThreshold: 250,
 		MaxTaskBatchSize:                100,
 		MinTaskThrottlingBurstSize:      10000,

diff --git a/service/matching/taskListManager.go b/service/matching/taskListManager.go
@@ -663,7 +663,7 @@ func (c *taskListManagerImpl) getTasksPump() {
 
 	go c.deliverBufferTasksForPoll()
 	updateAckTimer := time.NewTimer(c.config.UpdateAckInterval)
-	checkPollerTimer := time.NewTimer(c.config.CheckPollerInterval)
+	checkPollerTimer := time.NewTimer(c.config.IdleTasklistCheckInterval)
 getTasksPumpLoop:
 	for {
 		select {
@@ -723,7 +723,7 @@ getTasksPumpLoop:
 				if len(pollers) == 0 {
 					c.Stop()
 				}
-				checkPollerTimer = time.NewTimer(c.config.CheckPollerInterval)
+				checkPollerTimer = time.NewTimer(c.config.IdleTasklistCheckInterval)
 			}
 		}
 	}