Changeset 58d7ea0fe4491225ad5856a49b1a965f2e5ee40c

Timestamp:

06/18/08 14:39:27 (7 months ago)

Author:

dmitry kim <jason@nichego.net>

git-committer:

dmitry kim <jason@nichego.net> 1213785567 +0400

git-parent:

[b74f6944594ec5e998bb023a4bb6184794d02298]

git-author:

dmitry kim <jason@nichego.net> 1213781088 +0400

Message:

+ core/irclog: dedicated loggers thread

Files:

• lib/rbot/core/irclog.rb (modified) (3 diffs)

lib/rbot/core/irclog.rb

@@ -25 +25 @@
-  def initialize
-    super
+    @queue = Queue.new
+    @thread = Thread.new { loggers_thread }
-    @logs = Hash.new
-    Dir.mkdir("#{@bot.botclass}/logs") unless File.exist?("#{@bot.botclass}/logs")
@@ -57 +59 @@
-  # +where+ can be a channel name, or a nick for private message logging
-  def irclog(message, where="server")
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
-  end
-
-  def cleanup
-
+
+
+
-  end
-
@@ -252 +232 @@
-    irclog m.logmessage, ".unknown"
-  end
+
+  protected
+  def loggers_thread
+    ls = nil
+    debug 'loggers_thread starting'
+    while ls = @queue.pop
+      message, where = ls
+      message = message.chomp
+      now = Time.now
+      stamp = now.strftime("%Y/%m/%d %H:%M:%S")
+      if where.class <= Server
+        where_str = "server"
+      else
+        where_str = where.downcase.gsub(/[:!?$*()\/\\<>|"']/, "_")
+      end
+      return unless can_log_on(where_str)
+      unless @logs.has_key? where_str
+        if @logs.size > @bot.config['irclog.max_open_files']
+          @logs.keys.sort do |a, b|
+            @logs[a][0] <=> @logs[b][0]
+          end.slice(0, @logs.size - @bot.config['irclog.max_open_files']).each do |w|
+            logfile_close w, "idle since #{@logs[w][0]}"
+          end
+        end
+        f = File.new("#{@bot.botclass}/logs/#{where_str}", "a")
+        f.sync = true
+        f.puts "[#{stamp}] @ Log started by #{@bot.myself.nick}"
+        @logs[where_str] = [now, f]
+      end
+      @logs[where_str][1].puts "[#{stamp}] #{message}"
+      @logs[where_str][0] = now
+      #debug "[#{stamp}] <#{where}> #{message}"
+    end
+    @logs.keys.each { |w| logfile_close(w, 'rescan or shutdown') }
+    debug 'loggers_thread terminating'
+  end
-end
-