diff --git a/console/active_sessions.go b/console/active_sessions.go index f3e12a176..2f5b7a205 100644 --- a/console/active_sessions.go +++ b/console/active_sessions.go @@ -51,7 +51,8 @@ func (self *CmdActiveSessions) RpcMethod() string { func (self *CmdActiveSessions) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &dispatchers.FilterSessionWithApiKey{} + self.rpcParams = &dispatchers.FilterSessionWithApiKey{ArgDispatcher: new(utils.ArgDispatcher)} + } return self.rpcParams } diff --git a/console/attributes_for_event.go b/console/attributes_for_event.go index 3f208a98c..d231c0c33 100644 --- a/console/attributes_for_event.go +++ b/console/attributes_for_event.go @@ -50,7 +50,7 @@ func (self *CmdGetAttributeForEvent) RpcMethod() string { func (self *CmdGetAttributeForEvent) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &engine.AttrArgsProcessEvent{} + self.rpcParams = &engine.AttrArgsProcessEvent{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/attributes_process_event.go b/console/attributes_process_event.go index b25bed320..ef359baa6 100644 --- a/console/attributes_process_event.go +++ b/console/attributes_process_event.go @@ -52,7 +52,7 @@ func (self *CmdAttributesProcessEvent) RpcMethod() string { func (self *CmdAttributesProcessEvent) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &engine.AttrArgsProcessEvent{} + self.rpcParams = &engine.AttrArgsProcessEvent{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/attributes_set.go b/console/attributes_set.go index c504dbccb..e1fe3da6e 100644 --- a/console/attributes_set.go +++ b/console/attributes_set.go @@ -20,6 +20,7 @@ package console import ( v2 "github.com/cgrates/cgrates/apier/v2" + "github.com/cgrates/cgrates/engine" "github.com/cgrates/cgrates/utils" ) @@ -50,7 +51,7 @@ func (self *CmdSetAttributes) RpcMethod() string { func (self *CmdSetAttributes) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &v2.AttributeWithCache{} + self.rpcParams = &v2.AttributeWithCache{ExternalAttributeProfile: new(engine.ExternalAttributeProfile)} } return self.rpcParams } diff --git a/console/chargers_for_event.go b/console/chargers_for_event.go index 213ac3b26..637d30e13 100644 --- a/console/chargers_for_event.go +++ b/console/chargers_for_event.go @@ -50,7 +50,10 @@ func (self *CmdGetChargersForEvent) RpcMethod() string { func (self *CmdGetChargersForEvent) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &utils.CGREventWithArgDispatcher{} + self.rpcParams = &utils.CGREventWithArgDispatcher{ + CGREvent: new(utils.CGREvent), + ArgDispatcher: new(utils.ArgDispatcher), + } } return self.rpcParams } diff --git a/console/chargers_process_event.go b/console/chargers_process_event.go index 252cc9f21..c6c22df7f 100644 --- a/console/chargers_process_event.go +++ b/console/chargers_process_event.go @@ -52,7 +52,10 @@ func (self *CmdChargersProcessEvent) RpcMethod() string { func (self *CmdChargersProcessEvent) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &utils.CGREventWithArgDispatcher{} + self.rpcParams = &utils.CGREventWithArgDispatcher{ + CGREvent: new(utils.CGREvent), + ArgDispatcher: new(utils.ArgDispatcher), + } } return self.rpcParams } diff --git a/console/chargers_set.go b/console/chargers_set.go index cd44aa41f..43208234e 100644 --- a/console/chargers_set.go +++ b/console/chargers_set.go @@ -20,6 +20,7 @@ package console import ( v1 "github.com/cgrates/cgrates/apier/v1" + "github.com/cgrates/cgrates/engine" "github.com/cgrates/cgrates/utils" ) @@ -50,7 +51,7 @@ func (self *CmdSetChargers) RpcMethod() string { func (self *CmdSetChargers) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &v1.ChargerWithCache{} + self.rpcParams = &v1.ChargerWithCache{ChargerProfile: new(engine.ChargerProfile)} } return self.rpcParams } diff --git a/console/cost.go b/console/cost.go index ab5753813..ed55754e8 100644 --- a/console/cost.go +++ b/console/cost.go @@ -19,8 +19,9 @@ along with this program. If not, see package console import ( - "github.com/cgrates/cgrates/apier/v1" + v1 "github.com/cgrates/cgrates/apier/v1" "github.com/cgrates/cgrates/engine" + "github.com/cgrates/cgrates/utils" ) func init() { @@ -53,7 +54,7 @@ func (self *CmdGetCost) RpcMethod() string { func (self *CmdGetCost) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &v1.AttrGetCost{} + self.rpcParams = &v1.AttrGetCost{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/datacost.go b/console/datacost.go index c70d755ca..1638b263b 100644 --- a/console/datacost.go +++ b/console/datacost.go @@ -19,8 +19,9 @@ along with this program. If not, see package console import ( - "github.com/cgrates/cgrates/apier/v1" + v1 "github.com/cgrates/cgrates/apier/v1" "github.com/cgrates/cgrates/engine" + "github.com/cgrates/cgrates/utils" ) func init() { @@ -52,7 +53,7 @@ func (self *CmdGetDataCost) RpcMethod() string { func (self *CmdGetDataCost) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = new(v1.AttrGetDataCost) + self.rpcParams = &v1.AttrGetDataCost{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/debit.go b/console/debit.go index e73b7735b..583002c5c 100644 --- a/console/debit.go +++ b/console/debit.go @@ -52,7 +52,10 @@ func (self *CmdDebit) RpcMethod() string { func (self *CmdDebit) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = new(engine.CallDescriptorWithArgDispatcher) + self.rpcParams = &engine.CallDescriptorWithArgDispatcher{ + CallDescriptor: new(engine.CallDescriptor), + ArgDispatcher: new(utils.ArgDispatcher), + } } return self.rpcParams } diff --git a/console/debit_max.go b/console/debit_max.go index a50f62569..fd9cbd4c9 100644 --- a/console/debit_max.go +++ b/console/debit_max.go @@ -18,7 +18,10 @@ along with this program. If not, see package console -import "github.com/cgrates/cgrates/engine" +import ( + "github.com/cgrates/cgrates/engine" + "github.com/cgrates/cgrates/utils" +) func init() { c := &CmdMaxDebit{ @@ -49,7 +52,10 @@ func (self *CmdMaxDebit) RpcMethod() string { func (self *CmdMaxDebit) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = new(engine.CallDescriptorWithArgDispatcher) + self.rpcParams = &engine.CallDescriptorWithArgDispatcher{ + CallDescriptor: new(engine.CallDescriptor), + ArgDispatcher: new(utils.ArgDispatcher), + } } return self.rpcParams } diff --git a/console/dispatcherprofile.go b/console/dispatcherprofile.go index b04554318..d88ff1342 100644 --- a/console/dispatcherprofile.go +++ b/console/dispatcherprofile.go @@ -51,7 +51,7 @@ func (self *CmdDispatcherProfile) RpcMethod() string { func (self *CmdDispatcherProfile) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = new(dispatchers.DispatcherEvent) + self.rpcParams = &dispatchers.DispatcherEvent{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/filter_set.go b/console/filter_set.go index c5a00b522..1609bd098 100644 --- a/console/filter_set.go +++ b/console/filter_set.go @@ -20,6 +20,7 @@ package console import ( v1 "github.com/cgrates/cgrates/apier/v1" + "github.com/cgrates/cgrates/engine" "github.com/cgrates/cgrates/utils" ) @@ -51,7 +52,7 @@ func (self *CmdSetFilter) RpcMethod() string { func (self *CmdSetFilter) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &v1.FilterWithCache{} + self.rpcParams = &v1.FilterWithCache{Filter: new(engine.Filter)} } return self.rpcParams } diff --git a/console/get_json_section.go b/console/get_json_section.go index 6d500efdb..1fbdd9f67 100644 --- a/console/get_json_section.go +++ b/console/get_json_section.go @@ -51,7 +51,7 @@ func (self *CmdGetJSONConfig) RpcMethod() string { func (self *CmdGetJSONConfig) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &config.StringWithArgDispatcher{} + self.rpcParams = &config.StringWithArgDispatcher{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/maxduration.go b/console/maxduration.go index a2f5e48a8..02069820b 100644 --- a/console/maxduration.go +++ b/console/maxduration.go @@ -54,7 +54,10 @@ func (self *CmdGetMaxDuration) RpcMethod() string { func (self *CmdGetMaxDuration) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = new(engine.CallDescriptorWithArgDispatcher) + self.rpcParams = &engine.CallDescriptorWithArgDispatcher{ + CallDescriptor: new(engine.CallDescriptor), + ArgDispatcher: new(utils.ArgDispatcher), + } } return self.rpcParams } diff --git a/console/passive_sessions.go b/console/passive_sessions.go index 7793f55a1..72cb70cdb 100644 --- a/console/passive_sessions.go +++ b/console/passive_sessions.go @@ -51,7 +51,7 @@ func (self *CmdPassiveSessions) RpcMethod() string { func (self *CmdPassiveSessions) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &dispatchers.FilterSessionWithApiKey{} + self.rpcParams = &dispatchers.FilterSessionWithApiKey{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/resources_for_event.go b/console/resources_for_event.go index ca187e502..4324306e5 100644 --- a/console/resources_for_event.go +++ b/console/resources_for_event.go @@ -53,7 +53,7 @@ func (self *CmdGetResourceForEvent) RpcMethod() string { func (self *CmdGetResourceForEvent) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &utils.ArgRSv1ResourceUsage{} + self.rpcParams = &utils.ArgRSv1ResourceUsage{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/session_authorize_event.go b/console/session_authorize_event.go index 422522b0f..5b4983397 100644 --- a/console/session_authorize_event.go +++ b/console/session_authorize_event.go @@ -52,7 +52,7 @@ func (self *CmdSessionsAuthorize) RpcMethod() string { func (self *CmdSessionsAuthorize) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &sessions.V1AuthorizeArgs{} + self.rpcParams = &sessions.V1AuthorizeArgs{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/session_initiate.go b/console/session_initiate.go index 44a3e5245..eba28d5a5 100644 --- a/console/session_initiate.go +++ b/console/session_initiate.go @@ -52,7 +52,7 @@ func (self *CmdSessionsInitiate) RpcMethod() string { func (self *CmdSessionsInitiate) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &sessions.V1InitSessionArgs{} + self.rpcParams = &sessions.V1InitSessionArgs{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/session_process_cdr.go b/console/session_process_cdr.go index 99a39eee7..dedc57269 100644 --- a/console/session_process_cdr.go +++ b/console/session_process_cdr.go @@ -51,7 +51,10 @@ func (self *CmdSessionsProcessCDR) RpcMethod() string { func (self *CmdSessionsProcessCDR) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &utils.CGREventWithArgDispatcher{} + self.rpcParams = &utils.CGREventWithArgDispatcher{ + CGREvent: new(utils.CGREvent), + ArgDispatcher: new(utils.ArgDispatcher), + } } return self.rpcParams } diff --git a/console/session_process_event.go b/console/session_process_event.go index 99bb4cf3d..3826d8678 100644 --- a/console/session_process_event.go +++ b/console/session_process_event.go @@ -52,7 +52,7 @@ func (self *CmdSessionsProcessEvent) RpcMethod() string { func (self *CmdSessionsProcessEvent) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &sessions.V1ProcessEventArgs{} + self.rpcParams = &sessions.V1ProcessEventArgs{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/session_terminate.go b/console/session_terminate.go index c6d3558fa..dfbaf6665 100644 --- a/console/session_terminate.go +++ b/console/session_terminate.go @@ -52,7 +52,7 @@ func (self *CmdSessionsTerminate) RpcMethod() string { func (self *CmdSessionsTerminate) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &sessions.V1TerminateSessionArgs{} + self.rpcParams = &sessions.V1TerminateSessionArgs{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/session_update.go b/console/session_update.go index d9659dd48..3548c7850 100644 --- a/console/session_update.go +++ b/console/session_update.go @@ -52,7 +52,7 @@ func (self *CmdSessionsUpdate) RpcMethod() string { func (self *CmdSessionsUpdate) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &sessions.V1UpdateSessionArgs{} + self.rpcParams = &sessions.V1UpdateSessionArgs{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/statqueue_set.go b/console/statqueue_set.go index 10954285b..1cbf1e78d 100644 --- a/console/statqueue_set.go +++ b/console/statqueue_set.go @@ -20,6 +20,7 @@ package console import ( v1 "github.com/cgrates/cgrates/apier/v1" + "github.com/cgrates/cgrates/engine" "github.com/cgrates/cgrates/utils" ) @@ -51,7 +52,7 @@ func (self *CmdSetStatQueue) RpcMethod() string { func (self *CmdSetStatQueue) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &v1.StatQueueWithCache{} + self.rpcParams = &v1.StatQueueWithCache{StatQueueProfile: new(engine.StatQueueProfile)} } return self.rpcParams } diff --git a/console/stats_for_event.go b/console/stats_for_event.go index 315c0873c..3e1fb471c 100644 --- a/console/stats_for_event.go +++ b/console/stats_for_event.go @@ -53,7 +53,7 @@ func (self *CmdStatsQueueForEvent) RpcMethod() string { func (self *CmdStatsQueueForEvent) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &engine.StatsArgsProcessEvent{} + self.rpcParams = &engine.StatsArgsProcessEvent{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/stats_metrics.go b/console/stats_metrics.go index 585709025..a29e93dc2 100644 --- a/console/stats_metrics.go +++ b/console/stats_metrics.go @@ -50,7 +50,10 @@ func (self *CmdGetStatQueueStringMetrics) RpcMethod() string { func (self *CmdGetStatQueueStringMetrics) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &utils.TenantIDWithArgDispatcher{} + self.rpcParams = &utils.TenantIDWithArgDispatcher{ + TenantID: new(utils.TenantID), + ArgDispatcher: new(utils.ArgDispatcher), + } } return self.rpcParams } diff --git a/console/stats_process_event.go b/console/stats_process_event.go index 63bbe2a5a..5343d8fed 100644 --- a/console/stats_process_event.go +++ b/console/stats_process_event.go @@ -53,7 +53,7 @@ func (self *CmdStatQueueProcessEvent) RpcMethod() string { func (self *CmdStatQueueProcessEvent) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &engine.StatsArgsProcessEvent{} + self.rpcParams = &engine.StatsArgsProcessEvent{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/status.go b/console/status.go index ffe2ed2e6..cbea58204 100644 --- a/console/status.go +++ b/console/status.go @@ -46,7 +46,10 @@ func (self *CmdStatus) RpcMethod() string { func (self *CmdStatus) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &utils.TenantWithArgDispatcher{} + self.rpcParams = &utils.TenantWithArgDispatcher{ + TenantArg: new(utils.TenantArg), + ArgDispatcher: new(utils.ArgDispatcher), + } } return self.rpcParams } diff --git a/console/supplier_profiles_for_event.go b/console/supplier_profiles_for_event.go index ee5a63240..6ae31bf01 100644 --- a/console/supplier_profiles_for_event.go +++ b/console/supplier_profiles_for_event.go @@ -50,7 +50,9 @@ func (self *CmdGetSupplierForEvent) RpcMethod() string { func (self *CmdGetSupplierForEvent) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &utils.CGREventWithArgDispatcher{} + self.rpcParams = &utils.CGREventWithArgDispatcher{ + CGREvent: new(utils.CGREvent), + ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/supplier_set.go b/console/supplier_set.go index 090e74a8d..9d24c85e7 100644 --- a/console/supplier_set.go +++ b/console/supplier_set.go @@ -20,6 +20,7 @@ package console import ( v1 "github.com/cgrates/cgrates/apier/v1" + "github.com/cgrates/cgrates/engine" "github.com/cgrates/cgrates/utils" ) @@ -50,7 +51,7 @@ func (self *CmdSetSupplier) RpcMethod() string { func (self *CmdSetSupplier) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &v1.SupplierWithCache{} + self.rpcParams = &v1.SupplierWithCache{SupplierProfile: new(engine.SupplierProfile)} } return self.rpcParams } diff --git a/console/suppliers.go b/console/suppliers.go index 66eb7e6e4..c99e2eaca 100644 --- a/console/suppliers.go +++ b/console/suppliers.go @@ -52,7 +52,7 @@ func (self *CmdSuppliersSort) RpcMethod() string { func (self *CmdSuppliersSort) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &engine.ArgsGetSuppliers{} + self.rpcParams = &engine.ArgsGetSuppliers{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/threshold.go b/console/threshold.go index 7192af77e..72ec1432d 100644 --- a/console/threshold.go +++ b/console/threshold.go @@ -50,7 +50,10 @@ func (self *CmdGetThreshold) RpcMethod() string { func (self *CmdGetThreshold) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &utils.TenantIDWithArgDispatcher{} + self.rpcParams = &utils.TenantIDWithArgDispatcher{ + TenantID: new(utils.TenantID), + ArgDispatcher: new(utils.ArgDispatcher), + } } return self.rpcParams } diff --git a/console/threshold_set.go b/console/threshold_set.go index e3f47c124..79ac8704e 100644 --- a/console/threshold_set.go +++ b/console/threshold_set.go @@ -20,6 +20,7 @@ package console import ( v1 "github.com/cgrates/cgrates/apier/v1" + "github.com/cgrates/cgrates/engine" "github.com/cgrates/cgrates/utils" ) @@ -51,7 +52,7 @@ func (self *CmdSetThreshold) RpcMethod() string { func (self *CmdSetThreshold) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &v1.ThresholdWithCache{} + self.rpcParams = &v1.ThresholdWithCache{ThresholdProfile: new(engine.ThresholdProfile)} } return self.rpcParams } diff --git a/console/thresholds_for_event.go b/console/thresholds_for_event.go index 93bf2e020..1d08ca88a 100755 --- a/console/thresholds_for_event.go +++ b/console/thresholds_for_event.go @@ -52,7 +52,7 @@ func (self *CmdThresholdsForEvent) RpcMethod() string { func (self *CmdThresholdsForEvent) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &engine.ArgsProcessEvent{} + self.rpcParams = &engine.ArgsProcessEvent{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/console/thresholds_process_event.go b/console/thresholds_process_event.go index 9473dc39d..13a288480 100644 --- a/console/thresholds_process_event.go +++ b/console/thresholds_process_event.go @@ -52,7 +52,7 @@ func (self *CmdThresholdProcessEvent) RpcMethod() string { func (self *CmdThresholdProcessEvent) RpcParams(reset bool) interface{} { if reset || self.rpcParams == nil { - self.rpcParams = &engine.ArgsProcessEvent{} + self.rpcParams = &engine.ArgsProcessEvent{ArgDispatcher: new(utils.ArgDispatcher)} } return self.rpcParams } diff --git a/sessions/sessions_bench_test.go b/sessions/sessions_bench_test.go index e491ac5af..abf78106e 100644 --- a/sessions/sessions_bench_test.go +++ b/sessions/sessions_bench_test.go @@ -38,7 +38,7 @@ var ( sBenchCfg *config.CGRConfig sBenchRPC *rpc.Client connOnce sync.Once - initRuns = flag.Int("init_runs", 25000, "number of loops to run in init") + initRuns = flag.Int("runs", 25000, "number of loops to run in init") cps = flag.Int("cps", 2000, "number of loops to run in init") maxCps = make(chan struct{}, *cps) ) @@ -127,7 +127,7 @@ func sendInit() { initArgs.ID = utils.UUIDSha1Prefix() initArgs.Event[utils.OriginID] = utils.UUIDSha1Prefix() initArgs.Event[utils.Account] = fmt.Sprintf("1001%v", i) - initArgs.Event[utils.Subject] = initArgs.Event[utils.Account] + initArgs.Event[utils.Subject] = "1001" //initArgs.Event[utils.Account] initArgs.Event[utils.Destination] = fmt.Sprintf("1002%v", i) var initRpl *V1InitSessionReply @@ -143,8 +143,9 @@ func sendInit() { func getCount() int { var count int - if err := sBenchRPC.Call(utils.SessionSv1GetActiveSessionsCount, - map[string]string{}, &count); err != nil { + if err := sBenchRPC.Call(utils.SessionSv1GetActiveSessionsCount, map[string]interface{}{ + "Filters": map[string]string{utils.ToR: utils.VOICE}, + }, &count); err != nil { log.Fatal(err) } return count