mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-16 05:39:54 +05:00
Fix for precaching RL rules
This commit is contained in:
@@ -183,6 +183,14 @@ func (rs *RedisStorage) PreloadCacheForPrefix(prefix string) error {
|
||||
return err
|
||||
}
|
||||
}
|
||||
case utils.ResourceLimitsPrefix:
|
||||
for _, key := range keyList {
|
||||
_, err = rs.GetResourceLimit(key[len(utils.ResourceLimitsPrefix):], true)
|
||||
if err != nil {
|
||||
cache2go.RollbackTransaction()
|
||||
return err
|
||||
}
|
||||
}
|
||||
default:
|
||||
return utils.ErrInvalidKey
|
||||
}
|
||||
|
||||
@@ -202,6 +202,18 @@ func TestRPCITDirectedRPC(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
func TestRPCITTimeout(t *testing.T) {
|
||||
if !*testIntegration {
|
||||
return
|
||||
}
|
||||
var status map[string]interface{}
|
||||
if err := rpcPoolFirst.Call("Responder.Status", "3s", &status); err == nil {
|
||||
t.Error("Expecting timeout")
|
||||
} else {
|
||||
t.Error(err)
|
||||
}
|
||||
}
|
||||
|
||||
// Special tests involving remote server (manually set)
|
||||
// The server network will be manually disconnected without TCP close
|
||||
func TestRPCITRmtRpcConnPool(t *testing.T) {
|
||||
|
||||
Reference in New Issue
Block a user