From 52ce8eae0cd848aac123e1d322662250f746da7d Mon Sep 17 00:00:00 2001 From: nickolasdaniel Date: Thu, 29 Jul 2021 17:12:25 +0300 Subject: [PATCH] Updated filefw_test.go --- ees/filefwv_test.go | 123 -------------------------------------------- 1 file changed, 123 deletions(-) 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 - } -}