такой:
-- Get Campaign TIC
exports.make_campaign_tic = function(campaign_id, first_tic)
local campaign = campaigns:get{campaign_id }
if (campaign ~= nil) then
if (campaign[2] == true) then
return 'tic'
else
-- Set running (3) state for first tic and keep existed state for
-- all another tics
local campaign_state = campaign[3]
if (first_tic) then
campaign_state = 3
end
-- Imediatelly set "ticking" state, before agents counts starts
campaign = campaigns:update(campaign_id,
{{'=', 2, true}, {'=', 3, campaign_state}})
-- Count all agents states
local online = 0
local lazy = 0
local available = 0
local busy = 0
for _, rec in sip_users.index.campaign_id_index:pairs(campaign_id) do
if (rec[6] ~= 0) then
online = online + 1
if (rec[6] == 1) then
lazy = lazy + 1
elseif (rec[6] == 2 and rec[11] == false) then
available = available + 1
end
if (rec[11] == true) then
busy = busy + 1
end
end
end
campaign = campaigns:update(campaign_id,
{
{'=', 2, true},
{'=', 3, campaign_state},
{'=', 5, online},
{'=', 6, lazy},
{'=', 7, available},
{'=', 8, busy }
})
return campaign
end
else
return nil
end
end
Суть вопроса, когда я ее вызываю извне, transaction processor ее всю выполняет в одной транзакции или нет? То есть могут ли другие запросы выпоняться с ней параллельно, могут ли они читать данные?
Мой затык получается в атомарности, я хочу понять возможна ли ситуация, когда я что-то делаю в функции, а другой запрос процитает старые данные, которые эта функция должна обновить.
Memtx? Если да, то memtx переключает файберы только при записи, если запись идет несколько раз, то нужно использовать box.begin/box.commit
Обсуждают сегодня