From 3fa2d991c29a4487d825336e8c8ff8b050b4fb9a Mon Sep 17 00:00:00 2001
From: Mike Dirolf <mike@10gen.com>
Date: Wed, 14 Jan 2009 09:33:47 -0500
Subject: [PATCH] refactor a bit

---
 mongo.py | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git a/mongo.py b/mongo.py
index 9a6f339a4..cab4d8a1a 100644
--- a/mongo.py
+++ b/mongo.py
@@ -121,16 +121,19 @@ class Mongo(object):
 
         return receive(length - 16)
 
+    def _kill_cursors(self):
+        message = _ZERO
+        message += struct.pack("<i", len(self.__dying_cursors))
+        for cursor_id in self.__dying_cursors:
+            message += struct.pack("<q", cursor_id)
+        self._send_message(2007, message)
+        self.__dying_cursors = []
+
     def _kill_cursor(self, cursor_id):
         self.__dying_cursors.append(cursor_id)
 
         if len(self.__dying_cursors) > _MAX_DYING_CURSORS:
-            message = _ZERO
-            message += struct.pack("<i", len(self.__dying_cursors))
-            for cursor_id in self.__dying_cursors:
-                message += struct.pack("<q", cursor_id)
-            self._send_message(2007, message)
-            self.__dying_cursors = []
+            self._kill_cursors()
 
     def __cmp__(self, other):
         if isinstance(other, Mongo):