--local socket = require("socket")
local sleep_secs=15

local args = table.pack(...)
if args[1] ~= nil then sleep_secs = args[1] end

function create_state()
  local try = 0
  local lastconns = 0

  while true do
    if lastconns == core.get_info()["CumConns"] then
      try = try+1
    end

    local a = io.popen('echo "show servers state" | socat tcp-connect:127.0.0.1:9990 -')
    local content = a:read("*a")

    if content ~= nil then
      if #content>0 then
        local f = io.open("/var/run/haproxy.state","w")
        f:write(content)
        io.close(f)
      end
    end

    lastconns = core.get_info()["CumConns"]

    if try == 10 then
      local msg = "Worker with pid ".. core.get_info()["Pid"] .. " exited for create_state task"
      print(msg)
      core.done(msg)
    end

    core.sleep(sleep_secs)
  end
end

core.register_task(create_state)