mir/ovs
2
0
Fork 0
mirror of https://github.com/openvswitch/ovs synced 2025-08-31 06:15:47 +00:00
Code Issues Releases Wiki Activity

reconnect: Track last-disconnected time.

Browse Source 
Commit a4613b01ab (ovsdb: Change the way connection duration time is reported
in Manager table.), pushed earlier today, requires this commit, so OVSDB has
been unbuildable from then to now.
This commit is contained in:
Andrew Evans
2011-03-09 18:36:26 -08:00
parent 926ea16ea3
commit eba18f0044
6 changed files with 104 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
python/ovs/reconnect.py
View File

@@ -146,6 +146,7 @@ class Reconnect(object):
self.backoff = 0
self.last_received = now
self.last_connected = now
self.last_disconnected = now
self.max_tries = None
self.creation_time = now
@@ -341,6 +342,9 @@ class Reconnect(object):
self.info_level("%s: %s attempt timed out"
% (self.name, type))
if (self.state in (Reconnect.Active, Reconnect.Idle)):
self.last_disconnected = now
# Back off
if (self.state in (Reconnect.Active, Reconnect.Idle) and
(self.last_received - self.last_connected >= self.backoff or
@@ -534,17 +538,28 @@ class Reconnect(object):
else:
return 0
def get_disconnect_duration(self, now):
"""Returns the number of milliseconds for which this FSM has been
continuously disconnected from its peer. (If this FSM is not currently
connected, this is 0.)"""
if not self.is_connected():
return now - self.last_disconnected
else:
return 0
def get_stats(self, now):
class Stats(object):
pass
stats = Stats()
stats.creation_time = self.creation_time
stats.last_connected = self.last_connected
stats.last_disconnected = self.last_disconnected
stats.last_received = self.last_received
stats.backoff = self.backoff
stats.seqno = self.seqno
stats.is_connected = self.is_connected()
stats.current_connection_duration = self.get_connection_duration(now)
stats.current_disconnect_duration = self.get_disconnect_duration(now)
stats.total_connected_duration = (stats.current_connection_duration +
self.total_connected_duration)
stats.n_attempted_connections = self.n_attempted_connections