uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-17 06:09:53 +05:00
Code Issues Packages Projects Releases Wiki Activity

Fix compilation errors after adding filterSChan to SessionService struct

Browse Source
This commit is contained in:
ionutboangiu
2021-10-25 16:35:38 +03:00
committed by Dan Christian Bogos
parent 82edb970ba
commit 1865d91738
10 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
services/asteriskagent_it_test.go
View File

@@ -55,7 +55,7 @@ func TestAsteriskAgentReload(t *testing.T) {
srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)}
db := NewDataDBService(cfg, nil, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
sS := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1),
sS := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1),
nil, anz, srvDep)
srv := NewAsteriskAgent(cfg, nil, srvDep)
engine.NewConnManager(cfg)
@@ -115,7 +115,7 @@ func TestAsteriskAgentReload2(t *testing.T) {
srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)}
db := NewDataDBService(cfg, nil, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
sS := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1),
sS := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1),
nil, anz, srvDep)
srv := NewAsteriskAgent(cfg, nil, srvDep)
engine.NewConnManager(cfg)

2
services/diameteragent_it_test.go
View File

@@ -49,7 +49,7 @@ func TestDiameterAgentReload1(t *testing.T) {
srvMngr := servmanager.NewServiceManager(shdWg, nil, cfg.GetReloadChan())
db := NewDataDBService(cfg, nil, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
sS := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1),
sS := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1),
nil, anz, srvDep)
srv := NewDiameterAgent(cfg, filterSChan, nil, srvDep)
engine.NewConnManager(cfg)

2
services/dnsagent_it_test.go
View File

@@ -57,7 +57,7 @@ func TestDNSAgentReload(t *testing.T) {
srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)}
db := NewDataDBService(cfg, nil, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
sS := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1),
sS := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1),
nil, anz, srvDep)
srv := NewDNSAgent(cfg, filterSChan, nil, srvDep)
engine.NewConnManager(cfg)

2
services/ers_it_test.go
View File

@@ -66,7 +66,7 @@ func TestEventReaderSReload(t *testing.T) {
srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)}
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
db := NewDataDBService(cfg, nil, srvDep)
sS := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1), nil, anz, srvDep)
sS := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1), nil, anz, srvDep)
erS := NewEventReaderService(cfg, filterSChan, nil, srvDep)
engine.NewConnManager(cfg)
srvMngr.AddServices(erS, sS,

2
services/freeswitchagent_it_test.go
View File

@@ -57,7 +57,7 @@ func TestFreeSwitchAgentReload(t *testing.T) {
srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)}
db := NewDataDBService(cfg, nil, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
sS := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1),
sS := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1),
nil, anz, srvDep)
srv := NewFreeswitchAgent(cfg, nil, srvDep)
engine.NewConnManager(cfg)

2
services/httpagent_it_test.go
View File

@@ -55,7 +55,7 @@ func TestHTTPAgentReload(t *testing.T) {
srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)}
db := NewDataDBService(cfg, nil, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
sS := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1),
sS := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1),
nil, anz, srvDep)
srv := NewHTTPAgent(cfg, filterSChan, server, nil, srvDep)
engine.NewConnManager(cfg)

2
services/kamailioagent_it_test.go
View File

@@ -54,7 +54,7 @@ func TestKamailioAgentReload(t *testing.T) {
srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)}
db := NewDataDBService(cfg, nil, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
sS := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1),
sS := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1),
nil, anz, srvDep)
srv := NewKamailioAgent(cfg, nil, srvDep)
engine.NewConnManager(cfg)

4
services/radiusagent_it_test.go
View File

@@ -58,7 +58,7 @@ func TestRadiusAgentReload(t *testing.T) {
srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)}
db := NewDataDBService(cfg, nil, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
sS := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1),
sS := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1),
nil, anz, srvDep)
srv := NewRadiusAgent(cfg, filterSChan, nil, srvDep)
engine.NewConnManager(cfg)
@@ -120,7 +120,7 @@ func TestRadiusAgentReload2(t *testing.T) {
srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)}
db := NewDataDBService(cfg, nil, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
sS := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1),
sS := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1),
nil, anz, srvDep)
srv := NewRadiusAgent(cfg, filterSChan, nil, srvDep)
engine.NewConnManager(cfg)

6
services/sessions_it_test.go
View File

@@ -92,7 +92,7 @@ func TestSessionSReload1(t *testing.T) {
conMng := engine.NewConnManager(cfg)
conMng.AddInternalConn(utils.ConcatenatedKey(utils.MetaInternal, utils.MetaChargers), utils.ChargerSv1, clientConect)
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
srv := NewSessionService(cfg, new(DataDBService), server, make(chan birpc.ClientConnector, 1), conMng, anz, srvDep)
srv := NewSessionService(cfg, new(DataDBService), filterSChan, server, make(chan birpc.ClientConnector, 1), conMng, anz, srvDep)
ctx, cancel := context.WithCancel(context.TODO())
err := srv.Start(ctx, cancel)
if err != nil {
@@ -156,7 +156,7 @@ func TestSessionSReload2(t *testing.T) {
db := NewDataDBService(cfg, nil, srvDep)
cfg.StorDbCfg().Type = utils.Internal
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
srv := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1), nil, anz, srvDep)
srv := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1), nil, anz, srvDep)
engine.NewConnManager(cfg)
srv.(*SessionService).sm = &sessions.SessionS{}
@@ -205,7 +205,7 @@ func TestSessionSReload3(t *testing.T) {
db := NewDataDBService(cfg, nil, srvDep)
cfg.StorDbCfg().Type = utils.Internal
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
srv := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1), nil, anz, srvDep)
srv := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1), nil, anz, srvDep)
engine.NewConnManager(cfg)
err2 := srv.(*SessionService).start(func() {})
if err2 != nil {

2
services/sipagent_it_test.go
View File

@@ -52,7 +52,7 @@ func TestSIPAgentReload(t *testing.T) {
srvDep := map[string]*sync.WaitGroup{utils.DataDB: new(sync.WaitGroup)}
db := NewDataDBService(cfg, nil, srvDep)
anz := NewAnalyzerService(cfg, server, filterSChan, make(chan birpc.ClientConnector, 1), srvDep)
sS := NewSessionService(cfg, db, server, make(chan birpc.ClientConnector, 1),
sS := NewSessionService(cfg, db, filterSChan, server, make(chan birpc.ClientConnector, 1),
nil, anz, srvDep)
srv := NewSIPAgent(cfg, filterSChan, nil, srvDep)
engine.NewConnManager(cfg)