pintos-os.org Git - openvswitch/blob - tests/ovsdb-server.at

   1 AT_BANNER([OVSDB -- ovsdb-server transactions (Unix sockets)])
   2
   3 m4_define([OVSDB_SERVER_SHUTDOWN],
   4   [cp pid savepid
   5    AT_CHECK([ovs-appctl -t $PWD/unixctl -e exit], [0], [ignore], [ignore])
   6    OVS_WAIT_WHILE([kill -0 `cat savepid`], [kill `cat savepid`])])
   7
   8 # OVSDB_CHECK_EXECUTION(TITLE, SCHEMA, TRANSACTIONS, OUTPUT, [KEYWORDS])
   9 #
  10 # Creates a database with the given SCHEMA, starts an ovsdb-server on
  11 # that database, and runs each of the TRANSACTIONS (which should be a
  12 # quoted list of quoted strings) against it with ovsdb-client one at a
  13 # time.
  14 #
  15 # Checks that the overall output is OUTPUT, but UUIDs in the output
  16 # are replaced by markers of the form <N> where N is a number.  The
  17 # first unique UUID is replaced by <0>, the next by <1>, and so on.
  18 # If a given UUID appears more than once it is always replaced by the
  19 # same marker.
  20 #
  21 # TITLE is provided to AT_SETUP and KEYWORDS to AT_KEYWORDS.
  22 m4_define([OVSDB_CHECK_EXECUTION],
  23   [AT_SETUP([$1])
  24    AT_KEYWORDS([ovsdb server positive unix $5])
  25    AT_DATA([schema], [$2
  26 ])
  27    AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
  28    AT_CHECK([ovsdb-server --detach --pidfile=$PWD/pid --remote=punix:socket --unixctl=$PWD/unixctl db], [0], [ignore], [ignore])
  29    m4_foreach([txn], [$3],
  30      [AT_CHECK([ovsdb-client transact unix:socket 'txn'], [0], [stdout], [ignore],
  31      [test ! -e pid || kill `cat pid`])
  32 cat stdout >> output
  33 ])
  34    AT_CHECK([perl $srcdir/uuidfilt.pl output], [0], [$4], [ignore],
  35             [test ! -e pid || kill `cat pid`])
  36    OVSDB_SERVER_SHUTDOWN
  37    AT_CLEANUP])
  38
  39 EXECUTION_EXAMPLES
  40 \f
  41 AT_SETUP([ovsdb-client get-schema-version])
  42 AT_KEYWORDS([ovsdb server positive])
  43 AT_DATA([schema], [ORDINAL_SCHEMA
  44 ])
  45 AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
  46 AT_CHECK([ovsdb-server --detach --pidfile=$PWD/pid --unixctl=$PWD/unixctl --remote=punix:socket db], [0], [ignore], [ignore])
  47 AT_CHECK([ovsdb-client get-schema-version unix:socket ordinals], [0], [5.1.3
  48 ])
  49 OVSDB_SERVER_SHUTDOWN
  50 AT_CLEANUP
  51
  52 AT_SETUP([database multiplexing implementation])
  53 AT_KEYWORDS([ovsdb server positive])
  54 AT_DATA([schema], [ORDINAL_SCHEMA
  55 ])
  56 AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
  57 AT_CHECK([ovsdb-server --detach --pidfile=$PWD/pid --unixctl=$PWD/unixctl --remote=punix:socket db], [0], [ignore], [ignore])
  58 AT_CHECK(
  59   [[ovsdb-client list-dbs unix:socket]],
  60   [0], [ordinals
  61 ], [ignore], [test ! -e pid || kill `cat pid`])
  62 AT_CHECK(
  63   [[ovsdb-client get-schema unix:socket nonexistent]],
  64   [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.
  65 ]], [test ! -e pid || kill `cat pid`])
  66 OVSDB_SERVER_SHUTDOWN
  67 AT_CLEANUP
  68
  69 AT_SETUP([--remote=db: implementation])
  70 AT_KEYWORDS([ovsdb server positive])
  71 AT_DATA([schema],
  72   [[{"name": "mydb",
  73      "tables": {
  74        "Manager": {
  75          "columns": {
  76            "manager": {"type": "string"}}}}}
  77 ]])
  78 AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
  79 AT_CHECK(
  80   [[ovsdb-tool transact db \
  81      '["mydb",
  82        {"op": "insert",
  83         "table": "Manager",
  84         "row": {"manager": "punix:socket"}}]']], [0], [ignore], [ignore])
  85 AT_CHECK([ovsdb-server --detach --pidfile=$PWD/pid --remote=db:Manager,manager --unixctl=$PWD/unixctl db], [0], [ignore], [ignore])
  86 AT_CHECK(
  87   [[ovsdb-client transact unix:socket \
  88      '["mydb",
  89        {"op": "select",
  90         "table": "Manager",
  91         "where": [],
  92         "columns": ["manager"]}]']],
  93   [0], [stdout], [ignore], [test ! -e pid || kill `cat pid`])
  94 AT_CHECK(
  95   [perl $srcdir/uuidfilt.pl stdout],
  96   [0],
  97   [[[{"rows":[{"manager":"punix:socket"}]}]
  98 ]],
  99   [ignore],
 100   [test ! -e pid || kill `cat pid`])
 101 OVSDB_SERVER_SHUTDOWN
 102 AT_CLEANUP
 103
 104 AT_SETUP([SSL db: implementation])
 105 AT_KEYWORDS([ovsdb server positive ssl $5])
 106 AT_SKIP_IF([test "$HAVE_OPENSSL" = no])
 107 AT_SKIP_IF([test "x$RANDOM" = x])
 108 SSL_PORT=`expr 32767 + \( $RANDOM % 32767 \)`
 109 PKIDIR=$abs_top_builddir/tests
 110 AT_SKIP_IF([expr "$PKIDIR" : ".*[       '\"
 111 \r\\]"])
 112 AT_DATA([schema],
 113   [[{"name": "mydb",
 114      "tables": {
 115        "SSL": {
 116          "columns": {
 117            "private_key": {"type": "string"},
 118            "certificate": {"type": "string"},
 119            "ca_cert": {"type": "string"}}}}}
 120 ]])
 121 AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
 122 AT_CHECK(
 123   [[ovsdb-tool transact db \
 124      '["mydb",
 125        {"op": "insert",
 126         "table": "SSL",
 127         "row": {"private_key": "'"$PKIDIR/testpki-privkey2.pem"'",
 128                 "certificate": "'"$PKIDIR/testpki-cert2.pem"'",
 129                 "ca_cert": "'"$PKIDIR/testpki-cacert.pem"'"}}]']],
 130   [0], [ignore], [ignore])
 131 AT_CHECK(
 132   [ovsdb-server --detach --pidfile=$PWD/pid \
 133         --private-key=db:SSL,private_key \
 134         --certificate=db:SSL,certificate \
 135         --ca-cert=db:SSL,ca_cert \
 136          --remote=pssl:$SSL_PORT:127.0.0.1 --unixctl=$PWD/unixctl db],
 137   [0], [ignore], [ignore])
 138 AT_CHECK(
 139   [[ovsdb-client \
 140         --private-key=$PKIDIR/testpki-privkey.pem \
 141         --certificate=$PKIDIR/testpki-cert.pem \
 142         --ca-cert=$PKIDIR/testpki-cacert.pem \
 143         transact ssl:127.0.0.1:$SSL_PORT \
 144         '["mydb",
 145           {"op": "select",
 146            "table": "SSL",
 147            "where": [],
 148            "columns": ["private_key"]}]']],
 149   [0], [stdout], [ignore], [test ! -e pid || kill `cat pid`])
 150 cat stdout >> output
 151 AT_CHECK_UNQUOTED(
 152   [perl $srcdir/uuidfilt.pl output], [0],
 153   [[[{"rows":[{"private_key":"$PKIDIR/testpki-privkey2.pem"}]}]
 154 ]], [ignore], [test ! -e pid || kill `cat pid`])
 155 OVSDB_SERVER_SHUTDOWN
 156 AT_CLEANUP
 157
 158 AT_SETUP([compacting online])
 159 AT_KEYWORDS([ovsdb server compact])
 160 AT_DATA([schema], [ORDINAL_SCHEMA
 161 ])
 162 touch .db.~lock~
 163 AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
 164 AT_CHECK([ovsdb-server --detach --pidfile=$PWD/pid --unixctl=$PWD/unixctl --remote=punix:socket --log-file=$PWD/ovsdb-server.log db], [0], [ignore], [ignore])
 165 AT_CAPTURE_FILE([ovsdb-server.log])
 166 dnl Do a bunch of random transactions that put crap in the database log.
 167 AT_CHECK(
 168   [[for pair in 'zero 0' 'one 1' 'two 2' 'three 3' 'four 4' 'five 5'; do
 169       set -- $pair
 170       ovsdb-client transact unix:socket '
 171         ["ordinals",
 172          {"op": "insert",
 173           "table": "ordinals",
 174           "row": {"name": "'$1'", "number": '$2'}},
 175          {"op": "comment",
 176           "comment": "add row for '"$pair"'"}]'
 177       ovsdb-client transact unix:socket '
 178         ["ordinals",
 179          {"op": "delete",
 180           "table": "ordinals",
 181           "where": [["number", "==", '$2']]},
 182          {"op": "comment",
 183           "comment": "delete row for '"$2"'"}]'
 184       ovsdb-client transact unix:socket '
 185         ["ordinals",
 186          {"op": "insert",
 187           "table": "ordinals",
 188           "row": {"name": "'$1'", "number": '$2'}},
 189          {"op": "comment",
 190           "comment": "add back row for '"$pair"'"}]'
 191     done]],
 192   [0], [stdout], [ignore], [test ! -e pid || kill `cat pid`])
 193 dnl Check that all the crap is in fact in the database log.
 194 AT_CHECK([[perl $srcdir/uuidfilt.pl db | grep -v ^OVSDB | sed 's/"_date":[0-9]*/"_date":0/' | test-json --multiple -]], [0],
 195   [[{"cksum":"12345678 9","name":"ordinals","tables":{"ordinals":{"columns":{"name":{"type":"string"},"number":{"type":"integer"}}}},"version":"5.1.3"}
 196 {"_comment":"add row for zero 0","_date":0,"ordinals":{"<0>":{"name":"zero"}}}
 197 {"_comment":"delete row for 0","_date":0,"ordinals":{"<0>":null}}
 198 {"_comment":"add back row for zero 0","_date":0,"ordinals":{"<1>":{"name":"zero"}}}
 199 {"_comment":"add row for one 1","_date":0,"ordinals":{"<2>":{"name":"one","number":1}}}
 200 {"_comment":"delete row for 1","_date":0,"ordinals":{"<2>":null}}
 201 {"_comment":"add back row for one 1","_date":0,"ordinals":{"<3>":{"name":"one","number":1}}}
 202 {"_comment":"add row for two 2","_date":0,"ordinals":{"<4>":{"name":"two","number":2}}}
 203 {"_comment":"delete row for 2","_date":0,"ordinals":{"<4>":null}}
 204 {"_comment":"add back row for two 2","_date":0,"ordinals":{"<5>":{"name":"two","number":2}}}
 205 {"_comment":"add row for three 3","_date":0,"ordinals":{"<6>":{"name":"three","number":3}}}
 206 {"_comment":"delete row for 3","_date":0,"ordinals":{"<6>":null}}
 207 {"_comment":"add back row for three 3","_date":0,"ordinals":{"<7>":{"name":"three","number":3}}}
 208 {"_comment":"add row for four 4","_date":0,"ordinals":{"<8>":{"name":"four","number":4}}}
 209 {"_comment":"delete row for 4","_date":0,"ordinals":{"<8>":null}}
 210 {"_comment":"add back row for four 4","_date":0,"ordinals":{"<9>":{"name":"four","number":4}}}
 211 {"_comment":"add row for five 5","_date":0,"ordinals":{"<10>":{"name":"five","number":5}}}
 212 {"_comment":"delete row for 5","_date":0,"ordinals":{"<10>":null}}
 213 {"_comment":"add back row for five 5","_date":0,"ordinals":{"<11>":{"name":"five","number":5}}}
 214 ]], [], [test ! -e pid || kill `cat pid`])
 215 dnl Dump out and check the actual database contents.
 216 AT_CHECK([[ovsdb-client dump unix:socket ordinals]],
 217   [0], [stdout], [ignore])
 218 AT_CHECK([perl $srcdir/uuidfilt.pl stdout], [0], [dnl
 219 ordinals table
 220 _uuid                                name  number
 221 ------------------------------------ ----- ------
 222 <0> five  5     @&t@
 223 <1> four  4     @&t@
 224 <2> one   1     @&t@
 225 <3> three 3     @&t@
 226 <4> two   2     @&t@
 227 <5> zero  0     @&t@
 228 ], [], [test ! -e pid || kill `cat pid`])
 229 dnl Now compact the database in-place.
 230 AT_CHECK([[ovs-appctl -t $PWD/unixctl ovsdb-server/compact]],
 231   [0], [], [ignore], [test ! -e pid || kill `cat pid`])
 232 dnl We can't fully re-check the contents of the database log, because the
 233 dnl order of the records is not predictable, but there should only be 4 lines
 234 dnl in it now.
 235 AT_CAPTURE_FILE([db])
 236 AT_CHECK([wc -l < db], [0], [4
 237 ], [], [test ! -e pid || kill `cat pid`])
 238 dnl And check that the dumped data is the same too:
 239 AT_CHECK([ovsdb-client dump unix:socket ordinals], [0], [stdout], [ignore],
 240   [test ! -e pid || kill `cat pid`])
 241 AT_CHECK([perl $srcdir/uuidfilt.pl stdout], [0], [dnl
 242 ordinals table
 243 _uuid                                name  number
 244 ------------------------------------ ----- ------
 245 <0> five  5     @&t@
 246 <1> four  4     @&t@
 247 <2> one   1     @&t@
 248 <3> three 3     @&t@
 249 <4> two   2     @&t@
 250 <5> zero  0     @&t@
 251 ], [], [test ! -e pid || kill `cat pid`])
 252 dnl Now do some more transactions.
 253 AT_CHECK(
 254   [[ovsdb-client transact unix:socket '
 255      ["ordinals",
 256       {"op": "delete",
 257        "table": "ordinals",
 258        "where": [["number", "<", 3]]}]']],
 259   [0], [[[{"count":3}]
 260 ]], [ignore], [test ! -e pid || kill `cat pid`])
 261 dnl There should be 6 lines in the log now.
 262 AT_CHECK([wc -l < db], [0], [6
 263 ], [], [test ! -e pid || kill `cat pid`])
 264 dnl Then check that the dumped data is correct.
 265 AT_CHECK([ovsdb-client dump unix:socket ordinals], [0], [stdout], [ignore],
 266   [test ! -e pid || kill `cat pid`])
 267 AT_CHECK([perl $srcdir/uuidfilt.pl stdout], [0], [dnl
 268 ordinals table
 269 _uuid                                name  number
 270 ------------------------------------ ----- ------
 271 <0> five  5     @&t@
 272 <1> four  4     @&t@
 273 <2> three 3     @&t@
 274 ], [], [test ! -e pid || kill `cat pid`])
 275 OVSDB_SERVER_SHUTDOWN
 276 AT_CLEANUP
 277 \f
 278 AT_BANNER([OVSDB -- ovsdb-server transactions (SSL sockets)])
 279
 280 # OVSDB_CHECK_EXECUTION(TITLE, SCHEMA, TRANSACTIONS, OUTPUT, [KEYWORDS])
 281 #
 282 # Creates a database with the given SCHEMA, starts an ovsdb-server on
 283 # that database, and runs each of the TRANSACTIONS (which should be a
 284 # quoted list of quoted strings) against it with ovsdb-client one at a
 285 # time.
 286 #
 287 # Checks that the overall output is OUTPUT, but UUIDs in the output
 288 # are replaced by markers of the form <N> where N is a number.  The
 289 # first unique UUID is replaced by <0>, the next by <1>, and so on.
 290 # If a given UUID appears more than once it is always replaced by the
 291 # same marker.
 292 #
 293 # TITLE is provided to AT_SETUP and KEYWORDS to AT_KEYWORDS.
 294 m4_define([OVSDB_CHECK_EXECUTION],
 295   [AT_SETUP([$1])
 296    AT_KEYWORDS([ovsdb server positive ssl $5])
 297    AT_SKIP_IF([test "$HAVE_OPENSSL" = no])
 298    AT_SKIP_IF([test "x$RANDOM" = x])
 299    AT_DATA([schema], [$2
 300 ])
 301    SSL_PORT=`expr 32767 + \( $RANDOM % 32767 \)`
 302    PKIDIR=$abs_top_builddir/tests
 303    AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
 304    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])
 305    m4_foreach([txn], [$3],
 306      [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],
 307      [test ! -e pid || kill `cat pid`])
 308 cat stdout >> output
 309 ])
 310    AT_CHECK([perl $srcdir/uuidfilt.pl output], [0], [$4], [ignore],
 311             [test ! -e pid || kill `cat pid`])
 312    OVSDB_SERVER_SHUTDOWN
 313    AT_CLEANUP])
 314
 315 EXECUTION_EXAMPLES
 316 \f
 317 AT_BANNER([OVSDB -- transactions on transient ovsdb-server])
 318
 319 # OVSDB_CHECK_EXECUTION(TITLE, SCHEMA, TRANSACTIONS, OUTPUT, [KEYWORDS])
 320 #
 321 # Creates a database with the given SCHEMA and runs each of the
 322 # TRANSACTIONS (which should be a quoted list of quoted strings)
 323 # against it with ovsdb-client one at a time.  Each ovsdb-client
 324 # is run against a separately started ovsdb-server that executes
 325 # only that single transaction.  (The idea is that this should
 326 # help to ferret out any differences between what ovsdb-server has
 327 # in memory and what actually gets committed to disk.)
 328 #
 329 # Checks that the overall output is OUTPUT, but UUIDs in the output
 330 # are replaced by markers of the form <N> where N is a number.  The
 331 # first unique UUID is replaced by <0>, the next by <1>, and so on.
 332 # If a given UUID appears more than once it is always replaced by the
 333 # same marker.
 334 #
 335 # TITLE is provided to AT_SETUP and KEYWORDS to AT_KEYWORDS.
 336 m4_define([OVSDB_CHECK_EXECUTION],
 337   [AT_SETUP([$1])
 338    AT_KEYWORDS([ovsdb server positive transient $5])
 339    AT_DATA([schema], [$2
 340 ])
 341    AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
 342    m4_foreach([txn], [$3],
 343      [AT_DATA([txnfile], [ovsdb-client transact unix:socket 'txn'
 344 ])
 345       AT_CHECK([ovsdb-server --remote=punix:socket --unixctl=$PWD/unixctl db --run="sh txnfile"], [0], [stdout], [ignore])
 346       cat stdout >> output
 347 ])
 348    AT_CHECK([perl $srcdir/uuidfilt.pl output], [0], [$4], [ignore])
 349    AT_CLEANUP])
 350
 351 EXECUTION_EXAMPLES