[tor-commits] [pytorctl/master] Fix some issues with SmartSocket.

[mikeperry@xxxxxxxxxxxxxx]

commit b99ecc1de55cdefbcd803e267d2635534ff9e511
Author: Mike Perry <mikeperry-git@xxxxxxxxxx>
Date:   Mon Mar 7 18:10:41 2011 -0800

    Fix some issues with SmartSocket.
    
    Also remove some traceback debugging statements.
---
 PathSupport.py |   19 ++++++++++++-------
 1 files changed, 12 insertions(+), 7 deletions(-)

diff --git a/PathSupport.py b/PathSupport.py
index e3ddfd1..4e9ad6d 100644
--- a/PathSupport.py
+++ b/PathSupport.py
@@ -1318,6 +1318,12 @@ class SmartSocket(_SocketWrapper):
   port_table = set()
   _table_lock = threading.Lock()
 
+  def __init__(self, family=2, type=1, proto=0, _sock=None):
+    ret = super(SmartSocket, self).__init__(family, type, proto, _sock)
+    self.__local_addr = None
+    plog("DEBUG", "New socket constructor")
+    return ret
+
   def connect(self, args):
     ret = super(SmartSocket, self).connect(args)
     myaddr = self.getsockname()
@@ -1341,14 +1347,13 @@ class SmartSocket(_SocketWrapper):
     return ret
 
   def __del__(self):
-    SmartSocket._table_lock.acquire()
-    try:
+    if self.__local_addr:
+      SmartSocket._table_lock.acquire()
       SmartSocket.port_table.remove(self.__local_addr)
-    except AttributeError,e:
-      traceback.print_exc()
-      plog("WARN", "Hrm. Socket instance without local_addr attribute?")
-    SmartSocket._table_lock.release()
-    plog("DEBUG", "Removed "+self.__local_addr+" from our local port list")
+      plog("DEBUG", "Removed "+self.__local_addr+" from our local port list")
+      SmartSocket._table_lock.release()
+    else:
+      plog("DEBUG", "Got a socket deletion with no address")
 
   def table_size():
     SmartSocket._table_lock.acquire()

_______________________________________________
tor-commits mailing list
tor-commits@xxxxxxxxxxxxxxxxxxxx
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits