From: Antoine Beaupré <anarcat@koumbit.org>
Date: Sun, 1 Dec 2013 06:07:19 +0000 (-0500)
Subject: fix crash after introduction of immediate mode
X-Git-Tag: 2.4~6
X-Git-Url: http://git.tremily.us/?a=commitdiff_plain;h=fc36200ee4cbdb7fe6dc74e119262047bb240a05;p=irker.git

fix crash after introduction of immediate mode

this fixes the following backtrace:

Exception happened during processing of request from ('127.0.0.1', 41192)
Traceback (most recent call last):
  File /usr/lib/python2.7/SocketServer.py, line 295, in _handle_request_noblock
    self.process_request(request, client_address)
  File /usr/lib/python2.7/SocketServer.py, line 321, in process_request
    self.finish_request(request, client_address)
  File /usr/lib/python2.7/SocketServer.py, line 334, in finish_request
    self.RequestHandlerClass(request, client_address, self)
  File /usr/lib/python2.7/SocketServer.py, line 649, in __init__
    self.handle()
  File ./irkerd, line 820, in handle
    irker.handle(line.strip())
  File ./irkerd, line 786, in handle
    self.servers[target.server()].dispatch(target.channel, message, target.key, quit_after=quit_after)
  File ./irkerd, line 641, in dispatch
    eligibles[0].enqueue(channel, message, key)
TypeError: enqueue() takes exactly 5 arguments (4 given)

when running: ./irk irker-test test
---

diff --git a/irkerd b/irkerd
index 8dedeba..a107c5e 100755
--- a/irkerd
+++ b/irkerd
@@ -428,7 +428,7 @@ class Connection:
         for (channel, message, key) in qcopy:
             self.queue.put((channel, message, key))
         self.status = "ready"
-    def enqueue(self, channel, message, key, quit_after):
+    def enqueue(self, channel, message, key, quit_after=False):
         "Enque a message for transmission."
         if self.thread is None or not self.thread.is_alive():
             self.status = "unseen"