diff --git a/ees/filefwv_test.go b/ees/filefwv_test.go index b22091278..321eb300d 100644 --- a/ees/filefwv_test.go +++ b/ees/filefwv_test.go @@ -23,9 +23,7 @@ import ( "encoding/csv" "io" "reflect" - "sync" "testing" - "time" "github.com/cgrates/cgrates/config" "github.com/cgrates/cgrates/engine" @@ -457,124 +455,3 @@ func TestFileFwvOnEvictedClose(t *testing.T) { cgrCfg.EEsCfg().Exporters[fFwv.cfgIdx].ComputeFields() fFwv.OnEvicted("test", "test") } - -func TestFileFWVSync(t *testing.T) { - //Create new exporter - cgrCfg := config.NewDefaultCGRConfig() - var cfgIdx int - cfgIdx = 0 - - cgrCfg.EEsCfg().Exporters[cfgIdx].Type = "*file_fwv" - dc, err := newEEMetrics(utils.FirstNonEmpty( - cgrCfg.EEsCfg().Exporters[cfgIdx].Timezone, - cgrCfg.GeneralCfg().DefaultTimezone)) - if err != nil { - t.Error(err) - } - - //Create an event - cgrEvent := &utils.CGREvent{ - Tenant: "cgrates.org", - Event: map[string]interface{}{ - "Account": "1001", - "Destination": "1002", - }, - } - - var wg1 = &sync.WaitGroup{} - - wg1.Add(3) - - test := make(chan struct{}) - go func() { - wg1.Wait() - close(test) - }() - mckCsv := &mockCsv{ - wg: wg1, - } - exp := &FileFWVee{ - id: cgrCfg.EEsCfg().Exporters[cfgIdx].ID, - cgrCfg: cgrCfg, - cfgIdx: cfgIdx, - filterS: new(engine.FilterS), - file: mckCsv, - dc: dc, - reqs: newConcReq(cgrCfg.EEsCfg().Exporters[cfgIdx].ConcurrentRequests), - } - - for i := 0; i < 3; i++ { - go func() { - exp.ExportEvent(cgrEvent) - }() - } - // exp.ExportEvent(cgrEvent) - - select { - case <-test: - return - case <-time.After(4 * time.Second): - t.Error("Can't asynchronously export events") - } -} - -func TestFileFWVSyncLimit(t *testing.T) { - //Create new exporter - cgrCfg := config.NewDefaultCGRConfig() - var cfgIdx int - cfgIdx = 0 - - cgrCfg.EEsCfg().Exporters[cfgIdx].Type = "*file_fwv" - cgrCfg.EEsCfg().Exporters[cfgIdx].ConcurrentRequests = 1 - dc, err := newEEMetrics(utils.FirstNonEmpty( - cgrCfg.EEsCfg().Exporters[cfgIdx].Timezone, - cgrCfg.GeneralCfg().DefaultTimezone)) - if err != nil { - t.Error(err) - } - - //Create an event - cgrEvent := &utils.CGREvent{ - Tenant: "cgrates.org", - Event: map[string]interface{}{ - "Account": "1001", - "Destination": "1002", - }, - } - - var wg1 = &sync.WaitGroup{} - - wg1.Add(3) - - test := make(chan struct{}) - go func() { - wg1.Wait() - close(test) - }() - mckCsv := &mockCsv{ - wg: wg1, - } - exp := &FileFWVee{ - id: cgrCfg.EEsCfg().Exporters[cfgIdx].ID, - cgrCfg: cgrCfg, - cfgIdx: cfgIdx, - filterS: new(engine.FilterS), - file: mckCsv, - dc: dc, - reqs: newConcReq(cgrCfg.EEsCfg().Exporters[cfgIdx].ConcurrentRequests), - } - - for i := 0; i < 3; i++ { - go func() { - exp.ExportEvent(cgrEvent) - }() - } - // exp.ExportEvent(cgrEvent) - - select { - case <-test: - t.Error("Should not have been possible to asynchronously export events") - case <-time.After(4 * time.Second): - return - } -}