3 dnl CHECK_CPU_DISCOVERED([n_cpu])
5 dnl Waits until CPUs discovered and checks if number of discovered CPUs
6 dnl is greater or equal to 'n_cpu'. Without parameters checks that at
7 dnl least one CPU discovered.
8 m4_define([CHECK_CPU_DISCOVERED], [
9 PATTERN="Discovered [[0-9]]* NUMA nodes and [[0-9]]* CPU cores"
10 OVS_WAIT_UNTIL([grep "$PATTERN" stderr])
11 N_CPU=$(grep "$PATTERN" stderr | sed -e 's/.* \([[0-9]]*\) CPU cores/\1/')
13 then AT_CHECK([test "$N_CPU" -gt "0"])
14 else AT_SKIP_IF([test "$N_CPU" -lt "$1"])
18 dnl CHECK_PMD_THREADS_CREATED([n_threads], [numa_id], [+line])
20 dnl Whaits for creation of 'n_threads' or at least 1 thread if $1 not
21 dnl passed. Checking starts from line number 'line' in ovs-vswithd.log .
22 m4_define([CHECK_PMD_THREADS_CREATED], [
23 PATTERN="Created [[0-9]]* pmd threads on numa node $2"
25 if [[ -z "$line_st" ]]
29 OVS_WAIT_UNTIL([tail -n $line_st ovs-vswitchd.log | grep "$PATTERN"])
30 N_THREADS=$(tail -n $line_st ovs-vswitchd.log | grep "$PATTERN" | tail -1 | sed -e 's/.* \([[0-9]]*\) pmd .*/\1/')
32 then AT_CHECK([test "$N_THREADS" -gt 0])
33 else AT_CHECK([test "$N_THREADS" -eq "$1"])
37 m4_define([SED_NUMA_CORE_PATTERN], ["s/\(numa_id \)[[0-9]]*\( core_id \)[[0-9]]*:/\1<cleared>\2<cleared>:/"])
38 m4_define([DUMMY_NUMA], [--dummy-numa="0,0,0,0,1,1,1,1"])
40 AT_SETUP([PMD - creating a thread/add-port])
41 OVS_VSWITCHD_START([add-port br0 p0 -- set Interface p0 type=dummy-pmd], [], [], [DUMMY_NUMA])
43 CHECK_CPU_DISCOVERED()
44 CHECK_PMD_THREADS_CREATED()
46 AT_CHECK([ovs-appctl dpif-netdev/pmd-rxq-show | sed SED_NUMA_CORE_PATTERN], [0], [dnl
47 pmd thread numa_id <cleared> core_id <cleared>:
51 AT_CHECK([ovs-appctl dpif/show | sed 's/\(tx_queues=\)[[0-9]]*/\1<cleared>/g'], [0], [dnl
52 dummy@ovs-dummy: hit:0 missed:0
54 br0 65534/100: (dummy)
55 p0 1/1: (dummy-pmd: configured_rx_queues=1, configured_tx_queues=<cleared>, requested_rx_queues=1, requested_tx_queues=<cleared>)
61 AT_SETUP([PMD - multiqueue support])
62 OVS_VSWITCHD_START([add-port br0 p0 -- set Interface p0 type=dummy-pmd], [], [], [DUMMY_NUMA])
64 CHECK_CPU_DISCOVERED()
65 CHECK_PMD_THREADS_CREATED()
67 AT_CHECK([ovs-vsctl set interface p0 options:n_rxq=8])
69 AT_CHECK([ovs-appctl dpif/show | sed 's/\(tx_queues=\)[[0-9]]*/\1<cleared>/g'], [0], [dnl
70 dummy@ovs-dummy: hit:0 missed:0
72 br0 65534/100: (dummy)
73 p0 1/1: (dummy-pmd: configured_rx_queues=8, configured_tx_queues=<cleared>, requested_rx_queues=8, requested_tx_queues=<cleared>)
76 AT_CHECK([ovs-appctl dpif-netdev/pmd-rxq-show | sed SED_NUMA_CORE_PATTERN], [0], [dnl
77 pmd thread numa_id <cleared> core_id <cleared>:
78 port: p0 queue-id: 0 1 2 3 4 5 6 7
85 AT_SETUP([PMD - pmd-cpu-mask/distribution of rx queues])
86 OVS_VSWITCHD_START([add-port br0 p0 -- set Interface p0 type=dummy-pmd options:n_rxq=8],
89 CHECK_CPU_DISCOVERED(2)
90 CHECK_PMD_THREADS_CREATED()
92 AT_CHECK([ovs-appctl dpif/show | sed 's/\(tx_queues=\)[[0-9]]*/\1<cleared>/g'], [0], [dnl
93 dummy@ovs-dummy: hit:0 missed:0
95 br0 65534/100: (dummy)
96 p0 1/1: (dummy-pmd: configured_rx_queues=8, configured_tx_queues=<cleared>, requested_rx_queues=8, requested_tx_queues=<cleared>)
99 AT_CHECK([ovs-appctl dpif-netdev/pmd-rxq-show | sed SED_NUMA_CORE_PATTERN], [0], [dnl
100 pmd thread numa_id <cleared> core_id <cleared>:
101 port: p0 queue-id: 0 1 2 3 4 5 6 7
104 TMP=$(cat ovs-vswitchd.log | wc -l | tr -d [[:blank:]])
105 AT_CHECK([ovs-vsctl set Open_vSwitch . other_config:pmd-cpu-mask=3])
106 CHECK_PMD_THREADS_CREATED([2], [], [+$TMP])
108 AT_CHECK([ovs-appctl dpif-netdev/pmd-rxq-show | sed SED_NUMA_CORE_PATTERN], [0], [dnl
109 pmd thread numa_id <cleared> core_id <cleared>:
110 port: p0 queue-id: 0 2 4 6
111 pmd thread numa_id <cleared> core_id <cleared>:
112 port: p0 queue-id: 1 3 5 7
115 TMP=$(cat ovs-vswitchd.log | wc -l | tr -d [[:blank:]])
116 AT_CHECK([ovs-vsctl set Open_vSwitch . other_config:pmd-cpu-mask=1])
117 CHECK_PMD_THREADS_CREATED([1], [], [+$TMP])
119 AT_CHECK([ovs-appctl dpif-netdev/pmd-rxq-show | sed SED_NUMA_CORE_PATTERN], [0], [dnl
120 pmd thread numa_id <cleared> core_id <cleared>:
121 port: p0 queue-id: 0 1 2 3 4 5 6 7
128 AT_SETUP([PMD - stats])
129 OVS_VSWITCHD_START([add-port br0 p0 -- set Interface p0 ofport_request=7 type=dummy-pmd options:n_rxq=4],
130 [], [], [DUMMY_NUMA])
132 CHECK_CPU_DISCOVERED()
133 CHECK_PMD_THREADS_CREATED()
135 AT_CHECK([ovs-appctl vlog/set dpif_netdev:dbg])
136 AT_CHECK([ovs-ofctl add-flow br0 action=normal])
140 AT_CHECK([ovs-appctl dpif/show | sed 's/\(tx_queues=\)[[0-9]]*/\1<cleared>/g'], [0], [dnl
141 dummy@ovs-dummy: hit:0 missed:0
143 br0 65534/100: (dummy)
144 p0 7/1: (dummy-pmd: configured_rx_queues=4, configured_tx_queues=<cleared>, requested_rx_queues=4, requested_tx_queues=<cleared>)
147 AT_CHECK([ovs-appctl dpif-netdev/pmd-stats-show | sed SED_NUMA_CORE_PATTERN | sed '/cycles/d' | grep pmd -A 4], [0], [dnl
148 pmd thread numa_id <cleared> core_id <cleared>:
156 ovs-appctl time/warp 100
160 pkt="in_port(7),eth(src=50:54:00:00:00:77,dst=50:54:00:00:01:78),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)"
161 AT_CHECK([ovs-appctl netdev-dummy/receive p0 $pkt])
164 ovs-appctl time/warp 100
166 AT_CHECK([grep -A 1 'miss upcall' ovs-vswitchd.log | tail -n 1], [0], [dnl
167 skb_priority(0),skb_mark(0),recirc_id(0),dp_hash(0),in_port(1),eth(src=50:54:00:00:00:77,dst=50:54:00:00:01:78),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)
169 AT_CHECK([cat ovs-vswitchd.log | filter_flow_install | strip_xout], [0], [dnl
170 recirc_id=0,ip,in_port=1,vlan_tci=0x0000/0x1fff,dl_src=50:54:00:00:00:77,dl_dst=50:54:00:00:01:78,nw_frag=no, actions: <del>
173 AT_CHECK([ovs-appctl dpif-netdev/pmd-stats-show | sed SED_NUMA_CORE_PATTERN | sed '/cycles/d' | grep pmd -A 4], [0], [dnl
174 pmd thread numa_id <cleared> core_id <cleared>: