add Log class

1 files changed, 3 insertions, 4 deletions

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