mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-11 18:16:24 +05:00
Remove debugging logs
This commit is contained in:
committed by
Dan Christian Bogos
parent
5b94c21f73
commit
ba92a5ca4b
@@ -136,13 +136,9 @@ func (sq *StatQueue) TenantID() string {
|
||||
|
||||
// ProcessEvent processes a utils.CGREvent, returns true if processed
|
||||
func (sq *StatQueue) ProcessEvent(ev *utils.CGREvent) (err error) {
|
||||
fmt.Println("sq before ", utils.ToJSON(sq))
|
||||
sq.remExpired()
|
||||
fmt.Println("sq after rem expired ", utils.ToJSON(sq))
|
||||
sq.remOnQueueLength()
|
||||
fmt.Println("sq after rem queue lengt ", utils.ToJSON(sq))
|
||||
sq.addStatEvent(ev)
|
||||
fmt.Println("sq after radd event ", utils.ToJSON(sq))
|
||||
return
|
||||
}
|
||||
|
||||
@@ -189,11 +185,9 @@ func (sq *StatQueue) remOnQueueLength() {
|
||||
// addStatEvent computes metrics for an event
|
||||
func (sq *StatQueue) addStatEvent(ev *utils.CGREvent) {
|
||||
var expTime *time.Time
|
||||
fmt.Println("sq.ttl : ", sq.ttl)
|
||||
if sq.ttl != nil {
|
||||
expTime = utils.TimePointer(time.Now().Add(*sq.ttl))
|
||||
}
|
||||
fmt.Println("expTime : ", expTime)
|
||||
sq.SQItems = append(sq.SQItems,
|
||||
struct {
|
||||
EventID string
|
||||
|
||||
@@ -2322,7 +2322,6 @@ func (smg *SMGeneric) OnBiJSONDisconnect(c *rpc2.Client) {
|
||||
}
|
||||
|
||||
func (smg *SMGeneric) syncSessions() {
|
||||
utils.Logger.Debug("Enter in sync sessions ????")
|
||||
var rpcClnts []rpcclient.RpcClientConnection
|
||||
for _, conn := range smg.intBiJSONConns {
|
||||
rpcClnts = append(rpcClnts, conn)
|
||||
|
||||
Reference in New Issue
Block a user