Старатель (Все сообщения пользователя)

local run = true
function OnStop()
  run = nil
end

function main()
  local function cb(index) end
  local ds

  while run do
    ds = CreateDataSource(class, sec_code, INTERVAL_M1)
    ds:SetUpdateCallback(cb)
    sleep(500)
    ds:Close()
    ds = nil
    collectgarbage("collect")
    sleep(500)
  end
  collectgarbage("collect")
  message(string.format("Memory: %.1f Mb", collectgarbage("count") / 1024))
end

require(mod1)
require(mod2)  -- Тут возникает ошибка загрузки модуля
               -- mod1 выгружен не будет.
function main()
  ...
end

class, sec_code = "SPBFUT", "SiH1"

local run = true
function OnStop()
  run = nil
  return 500
end

function main()
  local Volume  -- Дневной объём
  local ds_D1 = assert(CreateDataSource(class, sec_code, INTERVAL_D1))
  ds_D1:SetUpdateCallback(function (index)
    if not run then return end
    Volume = ds_D1:V(index)
  end)
  sleep(1000)

  local Day = os.date("*t").day
  local CreateDS = true
  local ds_M1, Index
  local function cb(index)
    if not run then return end
    if Index and index > Index then
      run = false return  -- Ждём закрытия свечи, на которой обнаружена ошибка
    end
    if math.floor(os.time() / 60) ~= math.floor(os.time(ds_M1:T(index)) / 60) then return end  -- Время свечи не совпадает с текущим
    local volume = 0  -- Суммарный объём за текущий день
    for i = index, 1, -1 do
      local day = ds_M1:T(i).day
      if day < Day then break
      elseif day == Day then
        volume = volume + ds_M1:V(i)
      end
    end
    if volume == Volume then
      CreateDS = true  -- Если ошибки нет, открываем новый DS
    elseif Index == nil then
      Index = index  -- Если есть ошибка, запомним номер последней свечи
      message(string.format("[ERROR] %s: index: %u: %s, %s", sec_code, Index, Volume, volume), 3)
    end
  end

  while run do
    if CreateDS then
      if ds_M1 then
        ds_M1:Close()
        sleep(2000)
      end
      if run then
        ds_M1 = assert(CreateDataSource(class, sec_code, INTERVAL_M1))
        ds_M1:SetUpdateCallback(cb)
        CreateDS = false
      end
    else sleep(1) end
  end
  ds_D1:Close()
  if Index then
    local function canle(ds, index)
      local t = ds:T(index)
      return string.format("%02u:%02u:%02u: %s; %s; %s; %s; %s", t.hour, t.min, t.sec, ds:O(index), ds:H(index), ds:L(index), ds:C(index), ds:V(index))
    end
    local s = string.format("%s: index: %u\n%s", sec_code, Index, canle(ds_M1, Index))  -- Выводим свечу, на которой обнаружена ошибка
    ds_M1:Close()
    sleep(100)
    ds_M1 = assert(CreateDataSource(class, sec_code, INTERVAL_M1))
    repeat sleep(1000) until ds_M1:Size() > Index
    message(s .. "\n" .. canle(ds_M1, Index), 2)  -- Сравниваем со свечой с тем же индексом из другого DS
  end
  ds_M1:Close()
end