mirror of
https://github.com/openvswitch/ovs
synced 2025-10-29 15:28:56 +00:00
62c87d4aed
The formatting of OVSDB syntax errors differed between big-endian and little-endian systems, which caused the "database multiplexing implementation" test to fail on SPARC. This commit fixes the problem by always outputting JSON in syntax errors in deterministic (sorted) order.
338 lines
14 KiB
Plaintext
338 lines
14 KiB
Plaintext
AT_BANNER([OVSDB -- ovsdb-server transactions (Unix sockets)])
|
||
|
||
m4_define([OVSDB_SERVER_SHUTDOWN],
|
||
[cp pid savepid
|
||
AT_CHECK([ovs-appctl -t $PWD/unixctl -e exit], [0], [ignore], [ignore])
|
||
OVS_WAIT_WHILE([kill -0 `cat savepid`], [kill `cat savepid`])])
|
||
|
||
# OVSDB_CHECK_EXECUTION(TITLE, SCHEMA, TRANSACTIONS, OUTPUT, [KEYWORDS])
|
||
#
|
||
# Creates a database with the given SCHEMA, starts an ovsdb-server on
|
||
# that database, and runs each of the TRANSACTIONS (which should be a
|
||
# quoted list of quoted strings) against it with ovsdb-client one at a
|
||
# time.
|
||
#
|
||
# Checks that the overall output is OUTPUT, but UUIDs in the output
|
||
# are replaced by markers of the form <N> where N is a number. The
|
||
# first unique UUID is replaced by <0>, the next by <1>, and so on.
|
||
# If a given UUID appears more than once it is always replaced by the
|
||
# same marker.
|
||
#
|
||
# TITLE is provided to AT_SETUP and KEYWORDS to AT_KEYWORDS.
|
||
m4_define([OVSDB_CHECK_EXECUTION],
|
||
[AT_SETUP([$1])
|
||
AT_KEYWORDS([ovsdb server positive unix $5])
|
||
AT_DATA([schema], [$2
|
||
])
|
||
AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
|
||
AT_CHECK([ovsdb-server --detach --pidfile=$PWD/pid --remote=punix:socket --unixctl=$PWD/unixctl db], [0], [ignore], [ignore])
|
||
m4_foreach([txn], [$3],
|
||
[AT_CHECK([ovsdb-client transact unix:socket 'txn'], [0], [stdout], [ignore],
|
||
[test ! -e pid || kill `cat pid`])
|
||
cat stdout >> output
|
||
])
|
||
AT_CHECK([perl $srcdir/uuidfilt.pl output], [0], [$4], [ignore],
|
||
[test ! -e pid || kill `cat pid`])
|
||
OVSDB_SERVER_SHUTDOWN
|
||
AT_CLEANUP])
|
||
|
||
EXECUTION_EXAMPLES
|
||
|
||
AT_SETUP([database multiplexing implementation])
|
||
AT_KEYWORDS([ovsdb server positive])
|
||
AT_DATA([schema], [ORDINAL_SCHEMA
|
||
])
|
||
AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
|
||
AT_CHECK([ovsdb-server --detach --pidfile=$PWD/pid --unixctl=$PWD/unixctl --remote=punix:socket db], [0], [ignore], [ignore])
|
||
AT_CHECK(
|
||
[[ovsdb-client list-dbs unix:socket]],
|
||
[0], [ordinals
|
||
], [ignore], [test ! -e pid || kill `cat pid`])
|
||
AT_CHECK(
|
||
[[ovsdb-client get-schema unix:socket nonexistent]],
|
||
[1], [], [[ovsdb-client: syntax "{"details":"get_schema request specifies unknown database nonexistent","error":"unknown database","syntax":"[\"nonexistent\"]"}": syntax error: Parsing database schema failed: Required 'name' member is missing.
|
||
]], [test ! -e pid || kill `cat pid`])
|
||
OVSDB_SERVER_SHUTDOWN
|
||
AT_CLEANUP
|
||
|
||
AT_SETUP([--remote=db: implementation])
|
||
AT_KEYWORDS([ovsdb server positive])
|
||
AT_DATA([schema],
|
||
[[{"name": "mydb",
|
||
"tables": {
|
||
"Manager": {
|
||
"columns": {
|
||
"manager": {"type": "string"}}}}}
|
||
]])
|
||
AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
|
||
AT_CHECK(
|
||
[[ovsdb-tool transact db \
|
||
'["mydb",
|
||
{"op": "insert",
|
||
"table": "Manager",
|
||
"row": {"manager": "punix:socket"}}]']], [0], [ignore], [ignore])
|
||
AT_CHECK([ovsdb-server --detach --pidfile=$PWD/pid --remote=db:Manager,manager --unixctl=$PWD/unixctl db], [0], [ignore], [ignore])
|
||
AT_CHECK(
|
||
[[ovsdb-client transact unix:socket \
|
||
'["mydb",
|
||
{"op": "select",
|
||
"table": "Manager",
|
||
"where": [],
|
||
"columns": ["manager"]}]']],
|
||
[0], [stdout], [ignore], [test ! -e pid || kill `cat pid`])
|
||
AT_CHECK(
|
||
[perl $srcdir/uuidfilt.pl stdout],
|
||
[0],
|
||
[[[{"rows":[{"manager":"punix:socket"}]}]
|
||
]],
|
||
[ignore],
|
||
[test ! -e pid || kill `cat pid`])
|
||
OVSDB_SERVER_SHUTDOWN
|
||
AT_CLEANUP
|
||
|
||
AT_SETUP([SSL db: implementation])
|
||
AT_KEYWORDS([ovsdb server positive ssl $5])
|
||
AT_SKIP_IF([test "$HAVE_OPENSSL" = no])
|
||
AT_SKIP_IF([test "x$RANDOM" = x])
|
||
SSL_PORT=`expr 32767 + \( $RANDOM % 32767 \)`
|
||
PKIDIR=$abs_top_srcdir/tests
|
||
AT_SKIP_IF([expr "$PKIDIR" : ".*[ '\"
|
||
|
||
\\]"])
|
||
AT_DATA([schema],
|
||
[[{"name": "mydb",
|
||
"tables": {
|
||
"SSL": {
|
||
"columns": {
|
||
"private_key": {"type": "string"},
|
||
"certificate": {"type": "string"},
|
||
"ca_cert": {"type": "string"}}}}}
|
||
]])
|
||
AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
|
||
AT_CHECK(
|
||
[[ovsdb-tool transact db \
|
||
'["mydb",
|
||
{"op": "insert",
|
||
"table": "SSL",
|
||
"row": {"private_key": "'"$PKIDIR/testpki-privkey2.pem"'",
|
||
"certificate": "'"$PKIDIR/testpki-cert2.pem"'",
|
||
"ca_cert": "'"$PKIDIR/testpki-cacert.pem"'"}}]']],
|
||
[0], [ignore], [ignore])
|
||
AT_CHECK(
|
||
[ovsdb-server --detach --pidfile=$PWD/pid \
|
||
--private-key=db:SSL,private_key \
|
||
--certificate=db:SSL,certificate \
|
||
--ca-cert=db:SSL,ca_cert \
|
||
--remote=pssl:$SSL_PORT:127.0.0.1 --unixctl=$PWD/unixctl db],
|
||
[0], [ignore], [ignore])
|
||
AT_CHECK(
|
||
[[ovsdb-client \
|
||
--private-key=$PKIDIR/testpki-privkey.pem \
|
||
--certificate=$PKIDIR/testpki-cert.pem \
|
||
--ca-cert=$PKIDIR/testpki-cacert.pem \
|
||
transact ssl:127.0.0.1:$SSL_PORT \
|
||
'["mydb",
|
||
{"op": "select",
|
||
"table": "SSL",
|
||
"where": [],
|
||
"columns": ["private_key"]}]']],
|
||
[0], [stdout], [ignore], [test ! -e pid || kill `cat pid`])
|
||
cat stdout >> output
|
||
AT_CHECK_UNQUOTED(
|
||
[perl $srcdir/uuidfilt.pl output], [0],
|
||
[[[{"rows":[{"private_key":"$PKIDIR/testpki-privkey2.pem"}]}]
|
||
]], [ignore], [test ! -e pid || kill `cat pid`])
|
||
OVSDB_SERVER_SHUTDOWN
|
||
AT_CLEANUP
|
||
|
||
AT_SETUP([compacting online])
|
||
AT_KEYWORDS([ovsdb server compact])
|
||
AT_DATA([schema], [ORDINAL_SCHEMA
|
||
])
|
||
touch .db.~lock~
|
||
AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
|
||
AT_CHECK([ovsdb-server --detach --pidfile=$PWD/pid --unixctl=$PWD/unixctl --remote=punix:socket --log-file=$PWD/ovsdb-server.log db], [0], [ignore], [ignore])
|
||
AT_CAPTURE_FILE([ovsdb-server.log])
|
||
dnl Do a bunch of random transactions that put crap in the database log.
|
||
AT_CHECK(
|
||
[[for pair in 'zero 0' 'one 1' 'two 2' 'three 3' 'four 4' 'five 5'; do
|
||
set -- $pair
|
||
ovsdb-client transact unix:socket '
|
||
["ordinals",
|
||
{"op": "insert",
|
||
"table": "ordinals",
|
||
"row": {"name": "'$1'", "number": '$2'}},
|
||
{"op": "comment",
|
||
"comment": "add row for '"$pair"'"}]'
|
||
ovsdb-client transact unix:socket '
|
||
["ordinals",
|
||
{"op": "delete",
|
||
"table": "ordinals",
|
||
"where": [["number", "==", '$2']]},
|
||
{"op": "comment",
|
||
"comment": "delete row for '"$2"'"}]'
|
||
ovsdb-client transact unix:socket '
|
||
["ordinals",
|
||
{"op": "insert",
|
||
"table": "ordinals",
|
||
"row": {"name": "'$1'", "number": '$2'}},
|
||
{"op": "comment",
|
||
"comment": "add back row for '"$pair"'"}]'
|
||
done]],
|
||
[0], [stdout], [ignore], [test ! -e pid || kill `cat pid`])
|
||
dnl Check that all the crap is in fact in the database log.
|
||
AT_CHECK([[perl $srcdir/uuidfilt.pl db | grep -v ^OVSDB | sed 's/"_date":[0-9]*/"_date":0/' | test-json --multiple -]], [0],
|
||
[[{"name":"ordinals","tables":{"ordinals":{"columns":{"name":{"type":"string"},"number":{"type":"integer"}}}}}
|
||
{"_comment":"add row for zero 0","_date":0,"ordinals":{"<0>":{"name":"zero"}}}
|
||
{"_comment":"delete row for 0","_date":0,"ordinals":{"<0>":null}}
|
||
{"_comment":"add back row for zero 0","_date":0,"ordinals":{"<1>":{"name":"zero"}}}
|
||
{"_comment":"add row for one 1","_date":0,"ordinals":{"<2>":{"name":"one","number":1}}}
|
||
{"_comment":"delete row for 1","_date":0,"ordinals":{"<2>":null}}
|
||
{"_comment":"add back row for one 1","_date":0,"ordinals":{"<3>":{"name":"one","number":1}}}
|
||
{"_comment":"add row for two 2","_date":0,"ordinals":{"<4>":{"name":"two","number":2}}}
|
||
{"_comment":"delete row for 2","_date":0,"ordinals":{"<4>":null}}
|
||
{"_comment":"add back row for two 2","_date":0,"ordinals":{"<5>":{"name":"two","number":2}}}
|
||
{"_comment":"add row for three 3","_date":0,"ordinals":{"<6>":{"name":"three","number":3}}}
|
||
{"_comment":"delete row for 3","_date":0,"ordinals":{"<6>":null}}
|
||
{"_comment":"add back row for three 3","_date":0,"ordinals":{"<7>":{"name":"three","number":3}}}
|
||
{"_comment":"add row for four 4","_date":0,"ordinals":{"<8>":{"name":"four","number":4}}}
|
||
{"_comment":"delete row for 4","_date":0,"ordinals":{"<8>":null}}
|
||
{"_comment":"add back row for four 4","_date":0,"ordinals":{"<9>":{"name":"four","number":4}}}
|
||
{"_comment":"add row for five 5","_date":0,"ordinals":{"<10>":{"name":"five","number":5}}}
|
||
{"_comment":"delete row for 5","_date":0,"ordinals":{"<10>":null}}
|
||
{"_comment":"add back row for five 5","_date":0,"ordinals":{"<11>":{"name":"five","number":5}}}
|
||
]], [], [test ! -e pid || kill `cat pid`])
|
||
dnl Dump out and check the actual database contents.
|
||
AT_CHECK([[ovsdb-client dump unix:socket ordinals]],
|
||
[0], [stdout], [ignore])
|
||
AT_CHECK([perl $srcdir/uuidfilt.pl stdout], [0],
|
||
[_uuid name number
|
||
------------------------------------ ----- ------
|
||
<0> five 5 @&t@
|
||
<1> four 4 @&t@
|
||
<2> one 1 @&t@
|
||
<3> three 3 @&t@
|
||
<4> two 2 @&t@
|
||
<5> zero 0 @&t@
|
||
], [], [test ! -e pid || kill `cat pid`])
|
||
dnl Now compact the database in-place.
|
||
AT_CHECK([[ovs-appctl -t $PWD/unixctl ovsdb-server/compact]],
|
||
[0], [], [ignore], [test ! -e pid || kill `cat pid`])
|
||
dnl We can't fully re-check the contents of the database log, because the
|
||
dnl order of the records is not predictable, but there should only be 4 lines
|
||
dnl in it now.
|
||
AT_CAPTURE_FILE([db])
|
||
AT_CHECK([wc -l < db], [0], [4
|
||
], [], [test ! -e pid || kill `cat pid`])
|
||
dnl And check that the dumped data is the same too:
|
||
AT_CHECK([ovsdb-client dump unix:socket ordinals], [0], [stdout], [ignore],
|
||
[test ! -e pid || kill `cat pid`])
|
||
AT_CHECK([perl $srcdir/uuidfilt.pl stdout], [0],
|
||
[_uuid name number
|
||
------------------------------------ ----- ------
|
||
<0> five 5 @&t@
|
||
<1> four 4 @&t@
|
||
<2> one 1 @&t@
|
||
<3> three 3 @&t@
|
||
<4> two 2 @&t@
|
||
<5> zero 0 @&t@
|
||
], [], [test ! -e pid || kill `cat pid`])
|
||
dnl Now do some more transactions.
|
||
AT_CHECK(
|
||
[[ovsdb-client transact unix:socket '
|
||
["ordinals",
|
||
{"op": "delete",
|
||
"table": "ordinals",
|
||
"where": [["number", "<", 3]]}]']],
|
||
[0], [[[{"count":3}]
|
||
]], [ignore], [test ! -e pid || kill `cat pid`])
|
||
dnl There should be 6 lines in the log now.
|
||
AT_CHECK([wc -l < db], [0], [6
|
||
], [], [test ! -e pid || kill `cat pid`])
|
||
dnl Then check that the dumped data is correct.
|
||
AT_CHECK([ovsdb-client dump unix:socket ordinals], [0], [stdout], [ignore],
|
||
[test ! -e pid || kill `cat pid`])
|
||
AT_CHECK([perl $srcdir/uuidfilt.pl stdout], [0],
|
||
[_uuid name number
|
||
------------------------------------ ----- ------
|
||
<0> five 5 @&t@
|
||
<1> four 4 @&t@
|
||
<2> three 3 @&t@
|
||
], [], [test ! -e pid || kill `cat pid`])
|
||
OVSDB_SERVER_SHUTDOWN
|
||
AT_CLEANUP
|
||
|
||
AT_BANNER([OVSDB -- ovsdb-server transactions (SSL sockets)])
|
||
|
||
# OVSDB_CHECK_EXECUTION(TITLE, SCHEMA, TRANSACTIONS, OUTPUT, [KEYWORDS])
|
||
#
|
||
# Creates a database with the given SCHEMA, starts an ovsdb-server on
|
||
# that database, and runs each of the TRANSACTIONS (which should be a
|
||
# quoted list of quoted strings) against it with ovsdb-client one at a
|
||
# time.
|
||
#
|
||
# Checks that the overall output is OUTPUT, but UUIDs in the output
|
||
# are replaced by markers of the form <N> where N is a number. The
|
||
# first unique UUID is replaced by <0>, the next by <1>, and so on.
|
||
# If a given UUID appears more than once it is always replaced by the
|
||
# same marker.
|
||
#
|
||
# TITLE is provided to AT_SETUP and KEYWORDS to AT_KEYWORDS.
|
||
m4_define([OVSDB_CHECK_EXECUTION],
|
||
[AT_SETUP([$1])
|
||
AT_KEYWORDS([ovsdb server positive ssl $5])
|
||
AT_SKIP_IF([test "$HAVE_OPENSSL" = no])
|
||
AT_SKIP_IF([test "x$RANDOM" = x])
|
||
AT_DATA([schema], [$2
|
||
])
|
||
SSL_PORT=`expr 32767 + \( $RANDOM % 32767 \)`
|
||
PKIDIR=$abs_top_srcdir/tests
|
||
AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
|
||
AT_CHECK([ovsdb-server --detach --pidfile=$PWD/pid --private-key=$PKIDIR/testpki-privkey2.pem --certificate=$PKIDIR/testpki-cert2.pem --ca-cert=$PKIDIR/testpki-cacert.pem --remote=pssl:$SSL_PORT:127.0.0.1 --unixctl=$PWD/unixctl db], [0], [ignore], [ignore])
|
||
m4_foreach([txn], [$3],
|
||
[AT_CHECK([ovsdb-client --private-key=$PKIDIR/testpki-privkey.pem --certificate=$PKIDIR/testpki-cert.pem --ca-cert=$PKIDIR/testpki-cacert.pem transact ssl:127.0.0.1:$SSL_PORT 'txn'], [0], [stdout], [ignore],
|
||
[test ! -e pid || kill `cat pid`])
|
||
cat stdout >> output
|
||
])
|
||
AT_CHECK([perl $srcdir/uuidfilt.pl output], [0], [$4], [ignore],
|
||
[test ! -e pid || kill `cat pid`])
|
||
OVSDB_SERVER_SHUTDOWN
|
||
AT_CLEANUP])
|
||
|
||
EXECUTION_EXAMPLES
|
||
|
||
AT_BANNER([OVSDB -- transactions on transient ovsdb-server])
|
||
|
||
# OVSDB_CHECK_EXECUTION(TITLE, SCHEMA, TRANSACTIONS, OUTPUT, [KEYWORDS])
|
||
#
|
||
# Creates a database with the given SCHEMA and runs each of the
|
||
# TRANSACTIONS (which should be a quoted list of quoted strings)
|
||
# against it with ovsdb-client one at a time. Each ovsdb-client
|
||
# is run against a separately started ovsdb-server that executes
|
||
# only that single transaction. (The idea is that this should
|
||
# help to ferret out any differences between what ovsdb-server has
|
||
# in memory and what actually gets committed to disk.)
|
||
#
|
||
# Checks that the overall output is OUTPUT, but UUIDs in the output
|
||
# are replaced by markers of the form <N> where N is a number. The
|
||
# first unique UUID is replaced by <0>, the next by <1>, and so on.
|
||
# If a given UUID appears more than once it is always replaced by the
|
||
# same marker.
|
||
#
|
||
# TITLE is provided to AT_SETUP and KEYWORDS to AT_KEYWORDS.
|
||
m4_define([OVSDB_CHECK_EXECUTION],
|
||
[AT_SETUP([$1])
|
||
AT_KEYWORDS([ovsdb server positive transient $5])
|
||
AT_DATA([schema], [$2
|
||
])
|
||
AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
|
||
m4_foreach([txn], [$3],
|
||
[AT_DATA([txnfile], [ovsdb-client transact unix:socket 'txn'
|
||
])
|
||
AT_CHECK([ovsdb-server --remote=punix:socket --unixctl=$PWD/unixctl db --run="sh txnfile"], [0], [stdout], [ignore])
|
||
cat stdout >> output
|
||
])
|
||
AT_CHECK([perl $srcdir/uuidfilt.pl output], [0], [$4], [ignore])
|
||
AT_CLEANUP])
|
||
|
||
EXECUTION_EXAMPLES
|