mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-11 18:16:24 +05:00
Update config for debian stretch interfaces
This commit is contained in:
committed by
Dan Christian Bogos
parent
679ca320d2
commit
0dfd635349
@@ -258,22 +258,12 @@ func (ka *KamailioAgent) V1DisconnectSession(args utils.AttrDisconnectSession, r
|
||||
|
||||
func (ka *KamailioAgent) V1GetActiveSessionIDs(ignParam string, sessionIDs *[]*sessions.SessionID) (err error) {
|
||||
for _, evapi := range ka.conns {
|
||||
errChan := make(chan error)
|
||||
go func() {
|
||||
kamEv, _ := json.Marshal(map[string]string{utils.Event: CGR_DLG_LIST})
|
||||
errChan <- evapi.Send(string(kamEv))
|
||||
}()
|
||||
select {
|
||||
case err = <-errChan:
|
||||
if err != nil {
|
||||
utils.Logger.Err(fmt.Sprintf("<%s> failed sending event, error %s",
|
||||
utils.KamailioAgent, err.Error()))
|
||||
return
|
||||
}
|
||||
case <-time.After(5 * time.Second):
|
||||
return errors.New("timeout sending dialog list")
|
||||
kamEv, _ := json.Marshal(map[string]string{utils.Event: CGR_DLG_LIST})
|
||||
if err = evapi.Send(string(kamEv)); err != nil {
|
||||
utils.Logger.Err(fmt.Sprintf("<%s> failed sending event, error %s",
|
||||
utils.KamailioAgent, err.Error()))
|
||||
return
|
||||
}
|
||||
|
||||
}
|
||||
select {
|
||||
case *sessionIDs = <-ka.activeSessionIDs:
|
||||
|
||||
@@ -6,6 +6,7 @@
|
||||
"general": {
|
||||
"log_level": 7,
|
||||
"node_id":"CGRAsterisk",
|
||||
"reply_timeout": "5s",
|
||||
},
|
||||
|
||||
|
||||
|
||||
@@ -6,6 +6,7 @@
|
||||
"general": {
|
||||
"log_level": 7,
|
||||
"node_id":"CGRKamailio",
|
||||
"reply_timeout": "5s",
|
||||
},
|
||||
|
||||
|
||||
|
||||
@@ -15,10 +15,10 @@
|
||||
debug=2
|
||||
log_stderror=no
|
||||
|
||||
listen=udp:eth0:5060
|
||||
listen=udp:enp0s3:5060
|
||||
listen=udp:127.0.0.1:5080
|
||||
listen=udp:127.0.0.1:5060
|
||||
listen=udp:eth0:5080
|
||||
listen=udp:enp0s3:5080
|
||||
|
||||
memdbg=5
|
||||
memlog=5
|
||||
|
||||
@@ -2409,7 +2409,7 @@ func (smg *SMGeneric) syncSessions() {
|
||||
fmt.Sprintf("<%s> error quering session ids : %+v", utils.SessionS, err))
|
||||
continue
|
||||
}
|
||||
case <-time.After(5 * time.Second):
|
||||
case <-time.After(smg.cgrCfg.GeneralCfg().ReplyTimeout):
|
||||
utils.Logger.Warning(
|
||||
fmt.Sprintf("<%s> timeout quering session ids ", utils.SessionS))
|
||||
continue
|
||||
|
||||
Reference in New Issue
Block a user