set replayer.executor default to 1

vinllen · vinllen · commit 924bf214e7f7 · 2019-09-30T15:17:45.000+08:00
diff --git a/src/mongoshake/collector/main/collector.go b/src/mongoshake/collector/main/collector.go
@@ -240,8 +240,9 @@ func sanitizeOptions() error {
 		if len(conf.Options.TunnelAddress) > conf.Options.WorkerNum {
 			return errors.New("then length of tunnel_address with type 'direct' shouldn't bigger than worker number")
 		}
-		if conf.Options.ReplayerExecutor < 1 {
-			return errors.New("executor number should be large than 1")
+		if conf.Options.ReplayerExecutor <= 0 {
+			conf.Options.ReplayerExecutor = 1
+			// return errors.New("executor number should be large than 1")
 		}
 		if conf.Options.ReplayerConflictWriteTo != executor.DumpConflictToDB &&
 			conf.Options.ReplayerConflictWriteTo != executor.DumpConflictToSDK &&

Original file line number	Diff line number	Diff line change
`@@ -240,8 +240,9 @@ func sanitizeOptions() error {`
`240`	`240`	`if len(conf.Options.TunnelAddress) > conf.Options.WorkerNum {`
`241`	`241`	`return errors.New("then length of tunnel_address with type 'direct' shouldn't bigger than worker number")`
`242`	`242`	`}`
`243`		`- if conf.Options.ReplayerExecutor < 1 {`
`244`		`- return errors.New("executor number should be large than 1")`
	`243`	`+ if conf.Options.ReplayerExecutor <= 0 {`
	`244`	`+ conf.Options.ReplayerExecutor = 1`
	`245`	`+ // return errors.New("executor number should be large than 1")`
`245`	`246`	`}`
`246`	`247`	`if conf.Options.ReplayerConflictWriteTo != executor.DumpConflictToDB &&`
`247`	`248`	`conf.Options.ReplayerConflictWriteTo != executor.DumpConflictToSDK &&`