[ovs-dev] [PATCH] udpif: Add command to wait for revalidation.
Joe Stringer
joestringer at nicira.com
Wed Jun 25 06:02:45 UTC 2014
This allows us to remove some of the sleeps from the testsuite.
Signed-off-by: Joe Stringer <joestringer at nicira.com>
---
v2: Add udpif_run(), manage connection from main thread.
v1: First post.
---
ofproto/ofproto-dpif-upcall.c | 45 +++++++++++++++++++++++++++++++++++++++++
ofproto/ofproto-dpif-upcall.h | 1 +
ofproto/ofproto-dpif.c | 1 +
tests/ofproto-dpif.at | 34 ++++++++++++++++++-------------
4 files changed, 67 insertions(+), 14 deletions(-)
diff --git a/ofproto/ofproto-dpif-upcall.c b/ofproto/ofproto-dpif-upcall.c
index 4f214f7..87c2200 100644
--- a/ofproto/ofproto-dpif-upcall.c
+++ b/ofproto/ofproto-dpif-upcall.c
@@ -128,6 +128,12 @@ struct udpif {
atomic_ulong n_flows; /* Number of flows in the datapath. */
atomic_llong n_flows_timestamp; /* Last time n_flows was updated. */
struct ovs_mutex n_flows_mutex;
+
+ /* Following fields are accessed and modified only from the main thread. */
+ struct unixctl_conn **conns; /* Connections waiting on dump_seq. */
+ uint64_t conn_seq; /* Corresponds to 'dump_seq' when
+ conns[n_conns-1] was stored. */
+ size_t n_conns; /* Number of connections waiting. */
};
enum upcall_type {
@@ -212,6 +218,8 @@ static void upcall_unixctl_enable_megaflows(struct unixctl_conn *, int argc,
const char *argv[], void *aux);
static void upcall_unixctl_set_flow_limit(struct unixctl_conn *conn, int argc,
const char *argv[], void *aux);
+static void upcall_unixctl_dump_wait(struct unixctl_conn *conn, int argc,
+ const char *argv[], void *aux);
static struct udpif_key *ukey_create(const struct nlattr *key, size_t key_len,
long long int used);
@@ -240,6 +248,8 @@ udpif_create(struct dpif_backer *backer, struct dpif *dpif)
upcall_unixctl_enable_megaflows, NULL);
unixctl_command_register("upcall/set-flow-limit", "", 1, 1,
upcall_unixctl_set_flow_limit, NULL);
+ unixctl_command_register("revalidator/wait", "", 0, 0,
+ upcall_unixctl_dump_wait, NULL);
ovsthread_once_done(&once);
}
@@ -259,6 +269,21 @@ udpif_create(struct dpif_backer *backer, struct dpif *dpif)
}
void
+udpif_run(struct udpif *udpif)
+{
+ if (udpif->conns && udpif->conn_seq != seq_read(udpif->dump_seq)) {
+ int i;
+
+ for (i = 0; i < udpif->n_conns; i++) {
+ unixctl_command_reply(udpif->conns[i], NULL);
+ }
+ free(udpif->conns);
+ udpif->conns = NULL;
+ udpif->n_conns = 0;
+ }
+}
+
+void
udpif_destroy(struct udpif *udpif)
{
udpif_stop_threads(udpif);
@@ -1543,3 +1568,23 @@ upcall_unixctl_set_flow_limit(struct unixctl_conn *conn,
unixctl_command_reply(conn, ds_cstr(&ds));
ds_destroy(&ds);
}
+
+static void
+upcall_unixctl_dump_wait(struct unixctl_conn *conn,
+ int argc OVS_UNUSED,
+ const char *argv[] OVS_UNUSED,
+ void *aux OVS_UNUSED)
+{
+ if (list_is_singleton(&all_udpifs)) {
+ struct udpif *udpif;
+ size_t len;
+
+ udpif = OBJECT_CONTAINING(list_front(&all_udpifs), udpif, list_node);
+ len = (udpif->n_conns + 1) * sizeof *udpif->conns;
+ udpif->conn_seq = seq_read(udpif->dump_seq);
+ udpif->conns = xrealloc(udpif->conns, len);
+ udpif->conns[udpif->n_conns++] = conn;
+ } else {
+ unixctl_command_reply_error(conn, "can't wait on multiple udpifs.");
+ }
+}
diff --git a/ofproto/ofproto-dpif-upcall.h b/ofproto/ofproto-dpif-upcall.h
index 6846f87..8c4b655 100644
--- a/ofproto/ofproto-dpif-upcall.h
+++ b/ofproto/ofproto-dpif-upcall.h
@@ -27,6 +27,7 @@ struct simap;
* table. */
struct udpif *udpif_create(struct dpif_backer *, struct dpif *);
+void udpif_run(struct udpif *udpif);
void udpif_set_threads(struct udpif *, size_t n_handlers,
size_t n_revalidators);
void udpif_synchronize(struct udpif *);
diff --git a/ofproto/ofproto-dpif.c b/ofproto/ofproto-dpif.c
index 8c130e1..1fa6b0c 100644
--- a/ofproto/ofproto-dpif.c
+++ b/ofproto/ofproto-dpif.c
@@ -491,6 +491,7 @@ type_run(const char *type)
}
dpif_run(backer->dpif);
+ udpif_run(backer->udpif);
/* If vswitchd started with other_config:flow_restore_wait set as "true",
* and the configuration has now changed to "false", enable receiving
diff --git a/tests/ofproto-dpif.at b/tests/ofproto-dpif.at
index 3eaa01f..ef38ed5 100644
--- a/tests/ofproto-dpif.at
+++ b/tests/ofproto-dpif.at
@@ -1,5 +1,11 @@
AT_BANNER([ofproto-dpif])
+AT_SETUP([ofproto-dpif - revalidator/wait])
+OVS_VSWITCHD_START
+AT_CHECK([ovs-appctl revalidator/wait])
+OVS_VSWITCHD_STOP
+AT_CLEANUP
+
AT_SETUP([ofproto-dpif, active-backup bonding])
# Create br0 with interfaces p1, p2 and p7, creating bond0 with p1 and p2
# and br1 with interfaces p3, p4 and p8.
@@ -341,7 +347,7 @@ for i in `seq 0 2`;
done
)
ovs-appctl time/warp 100
-sleep 1 # wait for forwarders process packets
+ovs-appctl revalidator/wait
AT_CHECK([ovs-ofctl -O OpenFlow12 -vwarn dump-group-stats br0], [0], [stdout])
AT_CHECK([STRIP_XIDS stdout | sort], [0], [dnl
group_id=1234,ref_count=0,packet_count=3,byte_count=180,bucket0:packet_count=3,byte_count=180,bucket1:packet_count=0,byte_count=0
@@ -363,7 +369,7 @@ for i in `seq 0 2`;
done
)
ovs-appctl time/warp 100
-sleep 1 # wait for forwarders process packets
+ovs-appctl revalidator/wait
AT_CHECK([ovs-ofctl -O OpenFlow12 -vwarn dump-group-stats br0], [0], [stdout])
AT_CHECK([STRIP_XIDS stdout | sort], [0], [dnl
group_id=1234,ref_count=0,packet_count=3,byte_count=180,bucket0:packet_count=3,byte_count=180,bucket1:packet_count=3,byte_count=180
@@ -729,7 +735,7 @@ tcp,metadata=0,in_port=0,vlan_tci=0x0000,dl_src=50:54:00:00:00:05,dl_dst=50:54:0
])
AT_CHECK([ovs-appctl time/warp 5000], [0], [ignore])
-sleep 1 # wait for revalidator to update stats
+ovs-appctl revalidator/wait
AT_CHECK([ovs-ofctl -OOpenFlow12 dump-flows br0 | ofctl_strip | sort], [0], [dnl
n_packets=3, n_bytes=180, actions=goto_table:1
OFPST_FLOW reply (OF1.2):
@@ -758,7 +764,7 @@ AT_CHECK([cat ofctl_monitor.log], [0], [dnl
])
AT_CHECK([ovs-appctl time/warp 5000], [0], [ignore])
-sleep 1 # wait for revalidator to update stats
+ovs-appctl revalidator/wait
AT_CHECK([ovs-ofctl -OOpenFlow12 dump-flows br0 | ofctl_strip | sort], [0], [dnl
n_packets=3, n_bytes=180, actions=resubmit(1,1)
OFPST_FLOW reply (OF1.2):
@@ -818,7 +824,7 @@ tcp,metadata=0,in_port=0,vlan_tci=0x0000,dl_src=50:54:00:00:00:05,dl_dst=50:54:0
])
AT_CHECK([ovs-appctl time/warp 5000], [0], [ignore])
-sleep 1 # wait for revalidator to update stats
+ovs-appctl revalidator/wait
AT_CHECK([ovs-ofctl -OOpenFlow12 dump-flows br0 | ofctl_strip | sort], [0], [dnl
table=1, n_packets=3, n_bytes=180, dl_src=10:11:11:11:11:11 actions=CONTROLLER:65535
OFPST_FLOW reply (OF1.2):
@@ -882,7 +888,7 @@ tcp,metadata=0,in_port=0,vlan_tci=0x0000,dl_src=50:54:00:00:00:05,dl_dst=50:54:0
])
AT_CHECK([ovs-appctl time/warp 5000], [0], [ignore])
-sleep 1 # wait for revalidator to update stats
+ovs-appctl revalidator/wait
AT_CHECK([ovs-ofctl -OOpenFlow12 dump-flows br0 | ofctl_strip | sort], [0], [dnl
n_packets=6, n_bytes=360, actions=goto_table:1
table=2, n_packets=3, n_bytes=180, dl_src=10:11:11:11:11:11 actions=CONTROLLER:65535
@@ -929,7 +935,7 @@ AT_CHECK([cat ofctl_monitor.log], [0], [dnl
])
AT_CHECK([ovs-appctl time/warp 5000], [0], [ignore])
-sleep 1 # wait for revalidator to update stats
+ovs-appctl revalidator/wait
AT_CHECK([ovs-ofctl -OOpenFlow12 dump-flows br0 | ofctl_strip | sort], [0], [dnl
n_packets=6, n_bytes=360, actions=resubmit(1,1)
table=2, dl_src=10:11:11:11:11:11 actions=CONTROLLER:65535
@@ -990,7 +996,7 @@ AT_CHECK([cat ofctl_monitor.log], [0], [dnl
])
AT_CHECK([ovs-appctl time/warp 5000], [0], [ignore])
-sleep 1 # wait for revalidator to update stats
+ovs-appctl revalidator/wait
AT_CHECK([ovs-ofctl -OOpenFlow12 dump-flows br0 | ofctl_strip | sort], [0], [dnl
n_packets=3, n_bytes=180, actions=goto_table:1
OFPST_FLOW reply (OF1.2):
@@ -1022,7 +1028,7 @@ AT_CHECK([cat ofctl_monitor.log], [0], [dnl
])
AT_CHECK([ovs-appctl time/warp 5000], [0], [ignore])
-sleep 1 # wait for revalidator to update stats
+ovs-appctl revalidator/wait
AT_CHECK([ovs-ofctl -OOpenFlow12 dump-flows br0 | ofctl_strip | sort], [0], [dnl
n_packets=3, n_bytes=180, actions=resubmit(1,1)
OFPST_FLOW reply (OF1.2):
@@ -3379,7 +3385,7 @@ m4_define([CHECK_NETFLOW_EXPIRATION],
done
ovs-appctl time/warp 6000
- sleep 1
+ ovs-appctl revalidator/wait
OVS_VSWITCHD_STOP
ovs-appctl -t test-netflow exit
@@ -3430,7 +3436,7 @@ m4_define([CHECK_NETFLOW_ACTIVE_EXPIRATION],
ovs-appctl time/warp 10000
- sleep 1
+ ovs-appctl revalidator/wait
OVS_VSWITCHD_STOP
ovs-appctl -t test-netflow exit
@@ -3492,7 +3498,7 @@ for i in `seq 1 10`; do
done
ovs-appctl time/warp 1000
-sleep 1 # wait for revalidator to update stats
+ovs-appctl revalidator/wait
AT_CHECK([ovs-ofctl dump-flows br0], [0], [stdout])
AT_CHECK([STRIP_XIDS stdout | sed -n 's/duration=[[0-9]]*\.[[0-9]]*s/duration=0.0s/p' | sort], [0], [dnl
@@ -3634,7 +3640,7 @@ AT_CHECK([ovs-appctl netdev-dummy/receive br0 0021853763af0026b98cb0f90800450000
AT_CHECK([ovs-appctl time/warp 1000 && ovs-appctl time/warp 1000], [0], [warped
warped
])
-sleep 1
+ovs-appctl revalidator/wait
AT_CHECK([ovs-ofctl dump-flows br0 | ofctl_strip], [0],
[NXST_FLOW reply:
n_packets=1, n_bytes=74, idle_timeout=60, actions=fin_timeout(idle_timeout=5)
@@ -3692,7 +3698,7 @@ ADD_OF_PORTS([br1], [3])
AT_CHECK([ovs-appctl netdev-dummy/receive p1 'in_port(1),eth(src=50:54:00:00:00:05,dst=50:54:00:00:00:07),eth_type(0x0800),ipv4(src=192.168.0.1,dst=192.168.0.2,proto=1,tos=0,ttl=64,frag=no),icmp(type=8,code=0)'])
AT_CHECK([ovs-appctl netdev-dummy/receive p2 'in_port(2),eth(src=50:54:00:00:00:07,dst=50:54:00:00:00:05),eth_type(0x0800),ipv4(src=192.168.0.2,dst=192.168.0.1,proto=1,tos=0,ttl=64,frag=no),icmp(type=0,code=0)'])
AT_CHECK([ovs-appctl netdev-dummy/receive p3 'in_port(3),eth(src=50:54:00:00:00:09,dst=50:54:00:00:00:0a),eth_type(0x0800),ipv4(src=10.0.0.2,dst=10.0.0.1,proto=1,tos=0,ttl=64,frag=no),icmp(type=8,code=0)'])
-sleep 1 # wait for upcall handlers
+ovs-appctl revalidator/wait
AT_CHECK([ovs-appctl dpif/dump-flows br0 | sort | STRIP_USED], [0], [dnl
skb_priority(0),recirc_id(0),in_port(1),eth_type(0x0800),ipv4(src=192.168.0.1/0.0.0.0,dst=192.168.0.2/0.0.0.0,proto=1/0,tos=0/0,ttl=64/0,frag=no/0xff), packets:0, bytes:0, used:never, actions:drop
skb_priority(0),recirc_id(0),in_port(2),eth_type(0x0800),ipv4(src=192.168.0.2/0.0.0.0,dst=192.168.0.1/0.0.0.0,proto=1/0,tos=0/0,ttl=64/0,frag=no/0xff), packets:0, bytes:0, used:never, actions:drop
--
1.7.10.4
More information about the dev
mailing list