Скрипт на lua за 12 часов работы отъел 1412KB оперативы.

#!/usr/local/bin/lua
require("ESL")

operator_prefix = {}
operator_prefix["AAAA"] = 0
operator_prefix["BBBB"] = 0

const_delay = {}
const_delay["AAAA-1"] = 170
const_delay["AAAA-2"] = 170
const_delay["BBBB-1"] = 170
const_delay["BBBB-2"] = 170

hangup_channel_counter = {}
hangup_channel_mduration = {}

for k,v in pairs(operator_prefix) do
    hangup_channel_counter[k] = 0
    hangup_channel_mduration[k] = 0
end
command = ''
args = ''
------------------------
function sleep(n)
  os.execute("sleep " .. tonumber(n))
end
------------------------
-- запихнем в функцию код который работает с freeswitch по ESL
------------------------
function ESL_read_write()

unixtime_start = os.time() -- сохраним время старта коннекта к fs esl
unixtime_start10 = unixtime_start

local con = ESL.ESLconnection("localhost", "8021", "ClueCon");
con:events("plain","CHANNEL_HANGUP_COMPLETE")
fscommand = "version"
e = con:api(fscommand, args);
if e == nil then
    print ("ESL соединение разорвано")
    con = nil
    return  -- покинем ESL_read_write()
else
    print ("ESL соединение установлено")
    event_counter = 0
    mduration_all_calls = 0
    average_mduration = 0
    while con:connected() do  --здесь все плохо, если fs остановить, то статус проверки  con:connected() не меняется
        local e = con:recvEventTimed(100)  -- 100 означает что ждем events указанное время и далее выполняем остальной алгоритм
        unixtime_current = os.time()
        unixtime_delta = unixtime_current - unixtime_start
        unixtime_delta10 = unixtime_current - unixtime_start10

        if unixtime_delta10 > 2 then   -- спецом дергаем fs раз в 2 сек, для определения статуса ESL c fs - отвечает/не отвечает
            unixtime_start10 = os.time()
            fscommand = "version"
            e = con:api(fscommand, args);
            if e == nil then
            print ("ESL соединение разорвано")
                con = nil
                return -- покинем ESL_read_write()
            end
        end
-- заходим в эту ветку через интервал времени
        if unixtime_delta > 10 then
            unixtime_start = os.time()
            print ("unixtime_delta:",unixtime_delta,"event_counter:",event_counter)
            for k,v in pairs(operator_prefix) do
--              print (k,v)
                average_mduration = hangup_channel_mduration[k]/hangup_channel_counter[k]
                average_mduration = math.floor (average_mduration)
                print (k,"hangup_channel_mduration", hangup_channel_mduration[k])
                print (k,"hangup_channel_counter", hangup_channel_counter[k])
                print (k,"average_mduration", average_mduration)
--              if average_mduration > 50 and average_mduration < 250 then
                if average_mduration > 10 then
                    fscommand = "hash insert/limit/" ..k .."-FAILURE/1"
                    print (fscommand)
                    e = con:api(fscommand, args);
                    print(e:getBody());
                    f = io.open("/tmp/email_body","w")
                    f:write (fscommand)
                    os.execute("/usr/local/freeswitch/scripts/email_monit_tdm_voip_trunks.sh noc@qwerty.ru /tmp/email_body")
                end
                hangup_channel_mduration[k] = 0
                hangup_channel_counter[k] = 0
            end
            event_counter = 0
        end

        if e ~= nil then  -- если получили event
            call_direction = e:getHeader("Call-Direction")
            if call_direction == "outbound" then
                variable_sip_gateway_name = e:getHeader("variable_sip_gateway_name")
                if variable_sip_gateway_name ~= nil then
                    uduration = e:getHeader("variable_uduration")
                    mduration = e:getHeader("variable_mduration")
                    channel_call_uuid = e:getHeader("Channel-Call-UUID")
                    caller_id_number = e:getHeader("Caller-Caller-ID-Number")
                    callee_id_number = e:getHeader("Caller-Callee-ID-Number")
                    caller_channel_name = e:getHeader("Caller-Channel-Name")
                    for k,v in pairs(operator_prefix) do
                        f,l = string.find(variable_sip_gateway_name, k,1,true)
                        if f ~= nil then
                        print (f,l)
                            mduration = mduration - tonumber(const_delay[variable_sip_gateway_name])
                            hangup_channel_counter[k] = hangup_channel_counter[k] + 1
                            hangup_channel_mduration[k] = hangup_channel_mduration[k] + mduration
                        end
                    end
                    event_counter = event_counter + 1
                    print(caller_channel_name," ",variable_sip_gateway_name," ",caller_id_number," ",callee_id_number," ms ",mduration)
                    print ("===============================================================================================")
--              print (os.time())
                end
            end
        end --if e ~= nil then  -- если получили event
    end --while con:connected() do

end --if e  == nil then

end --function
------------------------
while 1 do
    status, err = pcall(ESL_read_write) -- вызовем функцию в обертке для обработки exeption в случае аварии ESL соединения
    if not status then
        print("Функция ESL_read_write() вылетела с ошибкой:", err)
    end
    print ("Connection to freeswitch ESL failed. Slipping and try again.")
    sleep(5)
end --while 1 do

[root@freeswitch1 lua]# diff /tmp/lua2 /tmp/lua3
5c5
< 000000001ef86000   14720 rw--- 000000001ef86000 000:00000   [ anon ]
---
> 000000001ef86000   13976 rw--- 000000001ef86000 000:00000   [ anon ]
60c60
< mapped: 56260K    writeable/private: 21496K    shared: 0K
---
> mapped: 55516K    writeable/private: 20752K    shared: 0K

[root@freeswitch1 lua]# diff /tmp/lua3 /tmp/lua4
5c5
< 000000001ef86000   13976 rw--- 000000001ef86000 000:00000   [ anon ]
---
[quote] 000000001ef86000   13636 rw--- 000000001ef86000 000:00000   [ anon ][br][/quote]60c60
< mapped: 55516K    writeable/private: 20752K    shared: 0K
---
[quote] mapped: 55176K    writeable/private: 20412K    shared: 0K[/quote]

mapped: 41936K    writeable/private: 7172K    shared: 0K

mapped: 43872K    writeable/private: 9108K    shared: 0K

local counter = 1

local function sleep_1s()
  print(counter)
  os.execute("sleep 1")
  counter = counter + 1
end

local mt = {
  __gc = function()
    print("Me clean")
  end
}

local o = setmetatable({}, mt)
o = {}

for _ = 1, 1000 do sleep_1s() end

local mt = {
  __gc = function()
    print("Me clean")
  end
}

local o = setmetatable({}, mt)
o = {}

ESLconnection   function: 0x13442950
ESLevent        function: 0x134447c0
eslSetLogLevel  function: 0x134428f0

local con = ESL.ESLconnection("localhost", "8021", "ClueCon");

lua_gc (L, LUAGC_COLLECT, 0);

SIGPIPE	13	Завершение	Запись в разорванное соединение (пайп, сокет)	Уведомление

while 1 do
    status, err = pcall(ESL_read_write) -- вызовем функцию в обертке для обработки exeption в случае аварии ESL соединения
    if not status then
        print("Функция ESL_read_write() вылетела с ошибкой:", err)
    end
    print ("Connection to freeswitch ESL failed. Slipping and try again.")
    sleep(5)
end --while 1 do

status, err = pcall(ESL_read_write) -- вызовем функцию в обертке для обработки exeption в случае аварии ESL соединения
    if not status then
        print("Функция ESL_read_write() вылетела с ошибкой:", err)
    end
    print ("Connection to freeswitch ESL failed. Slipping and try again.")