diff --git a/data/tutorials/osips_native/opensips/etc/opensips/opensips.cfg b/data/tutorials/osips_native/opensips/etc/opensips/opensips.cfg index 81fe8a80c..739c88055 100644 --- a/data/tutorials/osips_native/opensips/etc/opensips/opensips.cfg +++ b/data/tutorials/osips_native/opensips/etc/opensips/opensips.cfg @@ -23,10 +23,10 @@ children=4 auto_aliases=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 diff --git a/sessions/sessions.go b/sessions/sessions.go index cc03cb5fc..7701a155c 100644 --- a/sessions/sessions.go +++ b/sessions/sessions.go @@ -2393,13 +2393,25 @@ func (smg *SMGeneric) syncSessions() { rpcClnts = append(rpcClnts, conn) } queriedCGRIDs := make(utils.StringMap) + var err error for _, conn := range rpcClnts { var queriedSessionIDs []*SessionID if conn != nil { - if err := conn.Call(utils.SessionSv1GetActiveSessionIDs, - "", &queriedSessionIDs); err != nil { + errChan := make(chan error) + go func() { + errChan <- conn.Call(utils.SessionSv1GetActiveSessionIDs, + "", &queriedSessionIDs) + }() + select { + case err = <-errChan: + if err != nil { + utils.Logger.Warning( + fmt.Sprintf("<%s> error quering session ids : %+v", utils.SessionS, err)) + continue + } + case <-time.After(5 * time.Second): utils.Logger.Warning( - fmt.Sprintf("<%s> error quering session ids : %+v", utils.SessionS, err)) + fmt.Sprintf("<%s> timeout quering session ids ", utils.SessionS)) continue } for _, sessionID := range queriedSessionIDs {