[Erp5-report] r29984 - /erp5/trunk/products/ERP5Type/Tool/MemcachedTool.py

[nobody at svn.erp5.org]

Author: nicolas
Date: Fri Oct 23 18:39:12 2009
New Revision: 29984

URL: http://svn.erp5.org?rev=29984&view=rev
Log:
LOG silent errors of memcached_client

Modified:
    erp5/trunk/products/ERP5Type/Tool/MemcachedTool.py

Modified: erp5/trunk/products/ERP5Type/Tool/MemcachedTool.py
URL: http://svn.erp5.org/erp5/trunk/products/ERP5Type/Tool/MemcachedTool.py?rev=29984&r1=29983&r2=29984&view=diff
==============================================================================
--- erp5/trunk/products/ERP5Type/Tool/MemcachedTool.py [utf8] (original)
+++ erp5/trunk/products/ERP5Type/Tool/MemcachedTool.py [utf8] Fri Oct 23 18:39:12 2009
@@ -95,6 +95,7 @@
       self.local_cache = {}
       self.scheduled_action_dict = {}
       init_dict = {}
+      self.server_list = server_list
       if server_max_key_length is not MARKER:
         init_dict['server_max_key_length'] = server_max_key_length
       if server_max_value_length is not MARKER:
@@ -121,9 +122,13 @@
             self.scheduled_action_dict[key] = UPDATE_ACTION
         for key, action in self.scheduled_action_dict.iteritems():
           if action is UPDATE_ACTION:
-            self.memcached_connection.set(encodeKey(key), self.local_cache[key], 0)
+            succeed = self.memcached_connection.set(encodeKey(key), self.local_cache[key], 0)
+            if not succeed:
+              LOG('MemcacheTool', 0, 'set command to memcached server (%r) failed' % (self.server_list))
           elif action is DELETE_ACTION:
-            self.memcached_connection.delete(encodeKey(key), 0)
+            succeed = self.memcached_connection.delete(encodeKey(key), 0)
+            if not succeed:
+              LOG('MemcacheTool', 0, 'delete command to memcached server (%r) failed' % (self.server_list))
       except:
         LOG('MemcachedDict', 0, 'An exception occured during _finish : %s' % (traceback.format_exc(), ))
       self.scheduled_action_dict.clear()