projects
/
openvswitch
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
meta-flow: Accept NXM and OXM field names, support NXM and OXM for output.
[openvswitch]
/
debian
/
ovs-monitor-ipsec
diff --git
a/debian/ovs-monitor-ipsec
b/debian/ovs-monitor-ipsec
index a4a4575491b31028ae1ba7e71027245cbad8446e..ffaa979d4b0ead1bb906189208c9c5491a0aff26 100755
(executable)
--- a/
debian/ovs-monitor-ipsec
+++ b/
debian/ovs-monitor-ipsec
@@
-1,5
+1,5
@@
#!/usr/bin/python
#!/usr/bin/python
-# Copyright (c) 2009, 2010, 2011
Nicira Networks
+# Copyright (c) 2009, 2010, 2011
, 2012 Nicira, Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
@@
-38,6
+38,7
@@
import ovs.util
import ovs.daemon
import ovs.db.idl
import ovs.unixctl
import ovs.daemon
import ovs.db.idl
import ovs.unixctl
+import ovs.unixctl.server
import ovs.vlog
vlog = ovs.vlog.Vlog("ovs-monitor-ipsec")
import ovs.vlog
vlog = ovs.vlog.Vlog("ovs-monitor-ipsec")
@@
-414,24
+415,27
@@
def main():
ovs.daemon.daemonize()
ovs.unixctl.command_register("exit", "", 0, 0, unixctl_exit, None)
ovs.daemon.daemonize()
ovs.unixctl.command_register("exit", "", 0, 0, unixctl_exit, None)
- error, unixctl_server = ovs.unixctl.UnixctlServer.create(None)
+ error, unixctl_server = ovs.unixctl.
server.
UnixctlServer.create(None)
if error:
ovs.util.ovs_fatal(error, "could not create unixctl server", vlog)
ipsec = IPsec()
interfaces = {}
if error:
ovs.util.ovs_fatal(error, "could not create unixctl server", vlog)
ipsec = IPsec()
interfaces = {}
+ seqno = idl.change_seqno # Sequence number when we last processed the db
while True:
unixctl_server.run()
if exiting:
break
while True:
unixctl_server.run()
if exiting:
break
- if not idl.run():
+ idl.run()
+ if seqno == idl.change_seqno:
poller = ovs.poller.Poller()
unixctl_server.wait(poller)
idl.wait(poller)
poller.block()
continue
poller = ovs.poller.Poller()
unixctl_server.wait(poller)
idl.wait(poller)
poller.block()
continue
+ seqno = idl.change_seqno
ssl_cert = get_ssl_cert(idl.tables)
ssl_cert = get_ssl_cert(idl.tables)