Transmit count with delete request

Cleaner and faster than sending multiple requests.

rpyc/core/netref.py

@@ -124,14 +124,13 @@ def __init__(self, conn, oid):
         self.____refcount__ = 1
 
     def __del__(self):
-        for _ in xrange(self.____refcount__):
-            try:
-                asyncreq(self, consts.HANDLE_DEL)
-            except Exception:
-                # raised in a destructor, most likely on program termination,
-                # when the connection might have already been closed.
-                # it's safe to ignore all exceptions here
-                pass
+        try:
+            asyncreq(self, consts.HANDLE_DEL, self.____refcount__)
+        except Exception:
+            # raised in a destructor, most likely on program termination,
+            # when the connection might have already been closed.
+            # it's safe to ignore all exceptions here
+            pass
 
     def __getattribute__(self, name):
         if name in _local_netref_attrs:

rpyc/core/protocol.py

@@ -567,7 +567,7 @@ def _handle_close(self):
         self._cleanup()
     def _handle_getroot(self):
         return self._local_root
-    def _handle_del(self, oid):
+    def _handle_del(self, oid, count=1):
         self._local_objects.decref(oid)
     def _handle_repr(self, oid):
         return repr(self._local_objects[oid])

rpyc/lib/colls.py

@@ -73,13 +73,13 @@ def add(self, obj):
     def clear(self):
         with self._lock:
             self._dict.clear()
-    def decref(self, key):
+    def decref(self, key, count=1):
         with self._lock:
             slot = self._dict[key]
-            if slot[1] < 1:
+            if slot[1] < count:
                 del self._dict[key]
             else:
-                slot[1] -= 1
+                slot[1] -= count
                 self._dict[key] = slot
     def __getitem__(self, key):
         with self._lock: