1 # Copyright (c) 2009, 2010 Nicira Networks.
3 # Licensed under the Apache License, Version 2.0 (the "License");
4 # you may not use this file except in compliance with the License.
5 # You may obtain a copy of the License at:
7 # http://www.apache.org/licenses/LICENSE-2.0
9 # Unless required by applicable law or agreed to in writing, software
10 # distributed under the License is distributed on an "AS IS" BASIS,
11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 # See the License for the specific language governing permissions and
13 # limitations under the License.
33 def do_force_reconnect(_):
34 r.force_reconnect(now)
37 def error_from_string(s):
40 elif s == "ECONNREFUSED":
41 return errno.ECONNREFUSED
43 return ovs.reconnect.EOF
45 sys.stderr.write("unknown error '%s'\n" % s)
49 def do_disconnected(arg):
50 r.disconnected(now, error_from_string(arg))
57 def do_connect_failed(arg):
58 r.connect_failed(now, error_from_string(arg))
77 elif action == ovs.reconnect.CONNECT:
78 print " should connect"
79 elif action == ovs.reconnect.DISCONNECT:
80 print " should disconnect"
81 elif action == ovs.reconnect.PROBE:
82 print " should send probe"
94 timeout = r.timeout(now)
96 print " advance %d ms" % timeout
102 def do_set_max_tries(arg):
103 r.set_max_tries(int(arg))
106 def diff_stats(old, new, delta):
107 if (old.state != new.state or
108 old.state_elapsed != new.state_elapsed or
109 old.backoff != new.backoff):
110 print(" in %s for %d ms (%d ms backoff)"
111 % (new.state, new.state_elapsed, new.backoff))
113 if (old.creation_time != new.creation_time or
114 old.last_received != new.last_received or
115 old.last_connected != new.last_connected):
116 print(" created %d, last received %d, last connected %d"
117 % (new.creation_time, new.last_received, new.last_connected))
119 if (old.n_successful_connections != new.n_successful_connections or
120 old.n_attempted_connections != new.n_attempted_connections or
121 old.seqno != new.seqno):
122 print(" %d successful connections out of %d attempts, seqno %d"
123 % (new.n_successful_connections, new.n_attempted_connections,
126 if (old.is_connected != new.is_connected):
131 print(" %sconnected" % negate)
133 if (old.last_connected != new.last_connected or
134 (new.msec_since_connect != None and
135 old.msec_since_connect != new.msec_since_connect - delta) or
136 (old.total_connected_duration != new.total_connected_duration - delta
137 and not (old.total_connected_duration == 0 and
138 new.total_connected_duration == 0))):
139 print(" last connected %d ms ago, connected %d ms total"
140 % (new.msec_since_connect, new.total_connected_duration))
142 if (old.last_disconnected != new.last_disconnected or
143 (new.msec_since_disconnect != None and
144 old.msec_since_disconnect != new.msec_since_disconnect - delta)):
145 print(" disconnected at %d ms (%d ms ago)"
146 % (new.last_disconnected, new.msec_since_disconnect))
149 def do_set_passive(_):
150 r.set_passive(True, now)
157 def do_listen_error(arg):
158 r.listen_error(now, int(arg))
164 "disable": do_disable,
165 "force-reconnect": do_force_reconnect,
166 "disconnected": do_disconnected,
167 "connecting": do_connecting,
168 "connect-failed": do_connect_failed,
169 "connected": do_connected,
170 "received": do_received,
172 "advance": do_advance,
173 "timeout": do_timeout,
174 "set-max-tries": do_set_max_tries,
175 "passive": do_set_passive,
176 "listening": do_listening,
177 "listen-error": do_listen_error
180 logging.basicConfig(level=logging.CRITICAL)
186 r = ovs.reconnect.Reconnect(now)
188 prev = r.get_stats(now)
189 print "### t=%d ###" % now
191 old_max_tries = r.get_max_tries()
193 line = sys.stdin.readline()
210 commands[command](op)
214 print "### t=%d ###" % now
216 cur = r.get_stats(now)
217 diff_stats(prev, cur, now - old_time)
219 if r.get_max_tries() != old_max_tries:
220 old_max_tries = r.get_max_tries()
221 print " %d tries left" % old_max_tries
226 if __name__ == '__main__':