Skip to content
Browse files

rename reconnect to maybe_reconnect

  • Loading branch information...
1 parent fd19aab commit 882c5ecc5b21397f0184d35f706bfffbdd6b64f3 @klange klange committed with Oct 9, 2012
Showing with 2 additions and 2 deletions.
  1. +1 −1 gearman/connection.py
  2. +1 −1 gearman/connection_manager.py
View
2 gearman/connection.py
@@ -195,7 +195,7 @@ def send_commands_to_buffer(self):
self._outgoing_buffer = ''.join(packed_data)
- def reconnect(self):
+ def maybe_reconnect(self):
"""If we don't have outgoing data waiting after a length of time, close the current connection and open a new one."""
if self.connect_time < time.time() - self.reconnect_timeout:
if not self._outgoing_buffer:
View
2 gearman/connection_manager.py
@@ -92,7 +92,7 @@ def establish_connection(self, current_connection):
assert current_connection in self.connection_list, "Unknown connection - %r" % current_connection
if current_connection.connected:
- current_connection.reconnect()
+ current_connection.maybe_reconnect()
return current_connection
# !NOTE! May throw a ConnectionError

0 comments on commit 882c5ec

Please sign in to comment.
Something went wrong with that request. Please try again.