From dbb98dbb0233f8d9fd6a31849de4e297d838189a Mon Sep 17 00:00:00 2001 From: rebecca Date: Sun, 13 Sep 2026 14:55:10 +0100 Subject: add Log class --- pylon.lua | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'pylon.lua') diff --git a/pylon.lua b/pylon.lua index 7841f11..45aa8ab 100644 --- a/pylon.lua +++ b/pylon.lua @@ -3,8 +3,8 @@ local pprint = require 'pprint' local class = require 'r.class' local qw = require 'r.qw' -local bs = require'bs' local Queue = require 'queue' +local Log = require'log' local BasePylon = class() @@ -12,14 +12,13 @@ function BasePylon.make(cls, wilson, conf) local self = setmetatable(conf, cls) self.wilson = wilson self.inbox = Queue() + self.log = Log(self.name,self.loglevel) self:init() return self end function BasePylon._check_fields(self, fields) for k in qw.i(fields) do assert(self[k]~=nil, self.name..": missing field "..k) end end function BasePylon.post(self, dest_channel, message) self.inbox:enqueue(dest_channel, message) end -function BasePylon.log(self, ...) - if self.debug then print(self.name, ...) end end function BasePylon.run(self) self.cq = cqueues.new() self.cq:wrap(function() @@ -27,6 +26,6 @@ function BasePylon.run(self) self.cq:wrap(self.recving, self) self.cq:wrap(self.sending, self) end) - bs.loop_correctly(self.name, self.cq) + self.log:loop(self.cq) end return BasePylon -- cgit v1.2.3