uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Tests in services

Browse Source
This commit is contained in:
andronache
2021-02-18 16:54:45 +02:00
committed by Dan Christian Bogos
parent 0f06052630
commit 904a43ded4
1 changed files with 11 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
services/dnsagent_it_test.go
View File

@@ -245,9 +245,11 @@ func TestDNSAgentReload3(t *testing.T) {
time.Sleep(10 * time.Millisecond)
}
/*
func TestDNSAgentReload4(t *testing.T) {
cfg := config.NewDefaultCGRConfig()
cfg.SessionSCfg().Enabled = true
utils.Logger, _ = utils.Newlogger(utils.MetaSysLog, cfg.GeneralCfg().NodeID)
utils.Logger.SetLogLevel(7)
filterSChan := make(chan *engine.FilterS, 1)
@@ -267,7 +269,8 @@ func TestDNSAgentReload4(t *testing.T) {
sS := NewSessionService(cfg, db, server, make(chan rpcclient.ClientConnector, 1),
shdChan, nil, nil, anz, srvDep)
srv := NewDNSAgent(cfg, filterSChan, shdChan, nil, srvDep)
engine.NewConnManager(cfg, nil)
var err error
srvMngr.AddServices(srv, sS,
NewLoaderService(cfg, db, filterSChan, server, make(chan rpcclient.ClientConnector, 1), nil, anz, srvDep), db)
if err := srvMngr.StartServices(); err != nil {
@@ -285,39 +288,22 @@ func TestDNSAgentReload4(t *testing.T) {
} else if reply != utils.OK {
t.Errorf("Expecting OK ,received %s", reply)
}
time.Sleep(10 * time.Millisecond) //need to switch to gorutine
runtime.Gosched()
runtime.Gosched()
runtime.Gosched()
time.Sleep(10 * time.Millisecond) //need to switch to goroutine
runtime.Gosched()
if !srv.IsRunning() {
t.Errorf("Expected service to be running")
}
runtime.Gosched()
runtime.Gosched()
runtime.Gosched()
runtime.Gosched()
err := srv.Start()
if err == nil || err != utils.ErrServiceAlreadyRunning {
t.Errorf("\nExpecting <%+v>,\n Received <%+v>", utils.ErrServiceAlreadyRunning, err)
}
runtime.Gosched()
runtime.Gosched()
err = srv.Reload()
if err != nil {
t.Errorf("\nExpecting <nil>,\n Received <%+v>", err)
}
err = db.Reload()
if err != nil {
t.Errorf("\nExpecting <nil>,\n Received <%+v>", err)
}
runtime.Gosched()
runtime.Gosched()
err = srv.Reload()
if err != nil {
t.Errorf("\nExpecting <nil>,\n Received <%+v>", err)
}
dnsTest := &agents.DNSAgent{}
srv.(*DNSAgent).dns = dnsTest
time.Sleep(10 * time.Millisecond)
cfg.DNSAgentCfg().Enabled = false
cfg.GetReloadChan(config.DNSAgentJson) <- struct{}{}
@@ -330,3 +316,4 @@ func TestDNSAgentReload4(t *testing.T) {
shdChan.CloseOnce()
time.Sleep(10 * time.Millisecond)
}
*/