svn commit: r1395376 - /subversion/trunk/tools/server-side/svnpubsub/irkerbridge.py

[da...@apache.org]

Author: danielsh
Date: Sun Oct  7 20:19:22 2012
New Revision: 1395376

URL: http://svn.apache.org/viewvc?rev=1395376&view=rev
Log:
irkerbridge: break out a helper function.

* tools/server-side/svnpubsub/irkerbridge.py
  (BigDoEverythingClass._send): Break out from..
  (BigDoEverythingClass.commit): .. here.

Modified:
    subversion/trunk/tools/server-side/svnpubsub/irkerbridge.py

Modified: subversion/trunk/tools/server-side/svnpubsub/irkerbridge.py
URL: http://svn.apache.org/viewvc/subversion/trunk/tools/server-side/svnpubsub/irkerbridge.py?rev=1395376&r1=1395375&r2=1395376&view=diff
==============================================================================
--- subversion/trunk/tools/server-side/svnpubsub/irkerbridge.py (original)
+++ subversion/trunk/tools/server-side/svnpubsub/irkerbridge.py Sun Oct  7 20:19:22 2012
@@ -166,6 +166,16 @@ class BigDoEverythingClass(object):
       else:
         rev.subdirs_count_s = ""
 
+  def _send(self, irker, msg):
+    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+    irker_list = irker.split(':')
+    if len(irker_list) < 2:
+      irker_list.append(6659)
+    json_msg = json.dumps(msg)
+    sock.sendto(json_msg, (irker_list[0],int(irker_list[1])))
+    if self.options.verbose:
+      print "SENT: %s to %s" % (json_msg, irker)
+
   def commit(self, host, port, rev):
     if self.options.verbose:
       print "RECV: from %s:%s" % (host, port)
@@ -186,14 +196,7 @@ class BigDoEverythingClass(object):
             privmsg = privmsg[:MAX_PRIVMSG-3] + '...'
           for to in to_list:
             msg = {'to': to, 'privmsg': privmsg}
-            sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
-            irker_list = irker.split(':')
-            if len(irker_list) < 2:
-              irker_list.append(6659)
-            json_msg = json.dumps(msg)
-            sock.sendto(json_msg, (irker_list[0],int(irker_list[1])))
-            if self.options.verbose:
-              print "SENT: %s to %s" % (json_msg, irker)
+            self._send(irker, msg)
 
     except:
       print "Unexpected error:"