Blame view

src/shared/logproxy.lua 450 Bytes
3f604f2e   zhouhaihai   扩容 redis 和 log服务
1
2
  
  local skynet = require "skynet"
c06bf6ed   zhouhaihai   增加log 服务数量
3
  local logd_count = tonumber(skynet.getenv("thread")) * 2
3f604f2e   zhouhaihai   扩容 redis 和 log服务
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
  local use_logd = tonumber(skynet.getenv("logd"))
  
  
  local logd
  skynet.init(function()
  	if use_logd then
  		local idx = math.randomInt(1, logd_count)
  		logd = skynet.localname(".logd" .. idx)
  	end
  end)
  
  local logproxy = {}
  
  function logproxy:log(doc, logTo)
  	if use_logd and logd then
  		pcall(skynet.send, logd, "lua", "log", doc, logTo)
  	end
  end
  
  return logproxy