#999 Get adhocReqChan buffer from config (#1005)

config/config.go

@@ -72,6 +72,7 @@ type Config struct {
 		EnableMultiThreading   bool          `mapstructure:"enablemultithreading"`
 		StoreMapInitSize       int           `mapstructure:"storemapinitsize"`
 		WatchChanBufSize       int           `mapstructure:"watchchanbufsize"`
+		AdhocReqChanBufSize    int           `mapstructure:"adhocreqchanbufsize"`
 	} `mapstructure:"server"`
 	Auth struct {
 		UserName string `mapstructure:"username"`
@@ -106,6 +107,7 @@ var baseConfig = Config{
 		EnableMultiThreading   bool          `mapstructure:"enablemultithreading"`
 		StoreMapInitSize       int           `mapstructure:"storemapinitsize"`
 		WatchChanBufSize       int           `mapstructure:"watchchanbufsize"`
+		AdhocReqChanBufSize    int           `mapstructure:"adhocreqchanbufsize"`
 	}{
 		Addr:                   DefaultHost,
 		Port:                   DefaultPort,
@@ -127,6 +129,7 @@ var baseConfig = Config{
 		EnableMultiThreading:   false,
 		StoreMapInitSize:       1024000,
 		WatchChanBufSize:       20000,
+		AdhocReqChanBufSize:    20, // assuming we wouldn't have more than 20 adhoc requests being sent at a time.
 	},
 	Auth: struct {
 		UserName string `mapstructure:"username"`

dice.toml

@@ -21,6 +21,7 @@ PrettyPrintLogs = false
 EnableMultiThreading = false
 StoreMapInitSize = 10240
 WatchChanBufSize = 20000
+AdhocReqChanBufSize = 20
 
 [Auth]
 UserName = 'dice'

internal/worker/worker.go

@@ -55,7 +55,7 @@ func NewWorker(wid string, respChan chan *ops.StoreResponse,
 		respChan:        respChan,
 		logger:          logger,
 		Session:         auth.NewSession(),
-		adhocReqChan:    make(chan *cmd.DiceDBCmd, 20), // assuming we wouldn't have more than 20 adhoc requests being sent at a time.
+		adhocReqChan:    make(chan *cmd.DiceDBCmd, config.DiceConfig.Server.AdhocReqChanBufSize),
 	}
 }