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   OVS_RUNDIR=`pwd`; export OVS_RUNDIR
  25    AT_KEYWORDS([ovsdb server positive unix $5])
  26    $2 > schema
  27    AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
  28    AT_CHECK([ovsdb-server --detach --no-chdir --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_BANNER([ovsdb-server miscellaneous features])
  42
  43 AT_SETUP([truncating corrupted database log])
  44 AT_KEYWORDS([ovsdb server positive unix])
  45 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
  46 ordinal_schema > schema
  47 AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
  48 dnl Do one transaction and save the output.
  49 AT_DATA([txnfile], [[ovsdb-client transact unix:socket \
  50 '["ordinals",
  51   {"op": "insert",
  52    "table": "ordinals",
  53    "row": {"number": 0, "name": "zero"}}]'
  54 ]])
  55 AT_CHECK([ovsdb-server --remote=punix:socket --unixctl="`pwd`"/unixctl db --run="sh txnfile"], [0], [stdout], [])
  56 cat stdout >> output
  57 dnl Add some crap to the database log and run another transaction, which should
  58 dnl ignore the crap and truncate it out of the log.
  59 echo 'xxx' >> db
  60 AT_DATA([txnfile], [[ovsdb-client transact unix:socket \
  61 '["ordinals",
  62   {"op": "insert",
  63    "table": "ordinals",
  64    "row": {"number": 1, "name": "one"}}]'
  65 ]])
  66 AT_CHECK([ovsdb-server --remote=punix:socket --unixctl="`pwd`"/unixctl db --run="sh txnfile"], [0], [stdout], [stderr])
  67 AT_CHECK([grep 'syntax error: db: parse error.* in header line "xxx"' stderr],
  68   [0], [ignore])
  69 cat stdout >> output
  70 dnl Run a final transaction to verify that both transactions succeeeded.
  71 dnl The crap that we added should have been truncated by the previous run,
  72 dnl so ovsdb-server shouldn't log a warning this time.
  73 AT_DATA([txnfile], [[ovsdb-client transact unix:socket \
  74 '["ordinals",
  75   {"op": "select",
  76    "table": "ordinals",
  77    "where": [],
  78    "sort": ["number"]}]'
  79 ]])
  80 AT_CHECK([ovsdb-server --remote=punix:socket --unixctl="`pwd`"/unixctl db --run="sh txnfile"], [0], [stdout], [])
  81 cat stdout >> output
  82 AT_CHECK([${PERL} $srcdir/uuidfilt.pl output], [0],
  83   [[[{"uuid":["uuid","<0>"]}]
  84 [{"uuid":["uuid","<1>"]}]
  85 [{"rows":[{"_uuid":["uuid","<0>"],"_version":["uuid","<2>"],"name":"zero","number":0},{"_uuid":["uuid","<1>"],"_version":["uuid","<3>"],"name":"one","number":1}]}]
  86 ]], [],
  87          [test ! -e pid || kill `cat pid`])
  88 AT_CLEANUP
  89
  90 AT_SETUP([truncating database log with bad transaction])
  91 AT_KEYWORDS([ovsdb server positive unix])
  92 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
  93 ordinal_schema > schema
  94 AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
  95 dnl Do one transaction and save the output.
  96 AT_DATA([txnfile], [[ovsdb-client transact unix:socket \
  97 '["ordinals",
  98   {"op": "insert",
  99    "table": "ordinals",
 100    "row": {"number": 0, "name": "zero"}}]'
 101 ]])
 102 AT_CHECK([ovsdb-server --remote=punix:socket --unixctl="`pwd`"/unixctl db --run="sh txnfile"], [0], [stdout], [])
 103 cat stdout >> output
 104 dnl Add some crap to the database log and run another transaction, which should
 105 dnl ignore the crap and truncate it out of the log.
 106 echo 'OVSDB JSON 15 ffbcdae4b0386265f9ea3280dd7c8f0b72a20e56
 107 {"invalid":{}}' >> db
 108 AT_DATA([txnfile], [[ovsdb-client transact unix:socket \
 109 '["ordinals",
 110   {"op": "insert",
 111    "table": "ordinals",
 112    "row": {"number": 1, "name": "one"}}]'
 113 ]])
 114 AT_CHECK([ovsdb-server --remote=punix:socket --unixctl="`pwd`"/unixctl db --run="sh txnfile"], [0], [stdout], [stderr])
 115 AT_CHECK([grep 'syntax "{"invalid":{}}": unknown table: No table named invalid.' stderr],
 116   [0], [ignore])
 117 cat stdout >> output
 118 dnl Run a final transaction to verify that both transactions succeeeded.
 119 dnl The crap that we added should have been truncated by the previous run,
 120 dnl so ovsdb-server shouldn't log a warning this time.
 121 AT_DATA([txnfile], [[ovsdb-client transact unix:socket \
 122 '["ordinals",
 123   {"op": "select",
 124    "table": "ordinals",
 125    "where": [],
 126    "sort": ["number"]}]'
 127 ]])
 128 AT_CHECK([ovsdb-server --remote=punix:socket --unixctl="`pwd`"/unixctl db --run="sh txnfile"], [0], [stdout], [])
 129 cat stdout >> output
 130 AT_CHECK([${PERL} $srcdir/uuidfilt.pl output], [0],
 131   [[[{"uuid":["uuid","<0>"]}]
 132 [{"uuid":["uuid","<1>"]}]
 133 [{"rows":[{"_uuid":["uuid","<0>"],"_version":["uuid","<2>"],"name":"zero","number":0},{"_uuid":["uuid","<1>"],"_version":["uuid","<3>"],"name":"one","number":1}]}]
 134 ]], [],
 135          [test ! -e pid || kill `cat pid`])
 136 AT_CLEANUP
 137
 138 AT_SETUP([ovsdb-client get-schema-version])
 139 AT_KEYWORDS([ovsdb server positive])
 140 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 141 ordinal_schema > schema
 142 AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
 143 AT_CHECK([ovsdb-server --detach --no-chdir --pidfile="`pwd`"/pid --unixctl="`pwd`"/unixctl --remote=punix:socket db], [0], [ignore], [ignore])
 144 AT_CHECK([ovsdb-client get-schema-version unix:socket ordinals], [0], [5.1.3
 145 ])
 146 OVSDB_SERVER_SHUTDOWN
 147 AT_CLEANUP
 148
 149 AT_SETUP([database multiplexing implementation])
 150 AT_KEYWORDS([ovsdb server positive])
 151 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 152 ordinal_schema > schema1
 153 constraint_schema > schema2
 154 AT_CHECK([ovsdb-tool create db1 schema1], [0], [ignore], [ignore])
 155 AT_CHECK([ovsdb-tool create db2 schema2], [0], [ignore], [ignore])
 156 AT_CHECK([ovsdb-server --detach --no-chdir --pidfile="`pwd`"/pid --unixctl="`pwd`"/unixctl --remote=punix:socket db1 db2], [0], [ignore], [ignore])
 157 AT_CHECK(
 158   [[ovsdb-client list-dbs unix:socket]],
 159   [0], [constraints
 160 ordinals
 161 ], [ignore], [test ! -e pid || kill `cat pid`])
 162 AT_CHECK(
 163   [[ovstest test-jsonrpc request unix:socket get_schema [\"nonexistent\"]]], [0],
 164   [[{"error":null,"id":0,"result":{"details":"get_schema request specifies unknown database nonexistent","error":"unknown database","syntax":"[\"nonexistent\"]"}}
 165 ]], [], [test ! -e pid || kill `cat pid`])
 166 OVSDB_SERVER_SHUTDOWN
 167 AT_CLEANUP
 168
 169 AT_SETUP([ovsdb-server/add-db and remove-db])
 170 AT_KEYWORDS([ovsdb server positive])
 171 ON_EXIT([kill `cat ovsdb-server.pid`])
 172 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 173 OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 174 ordinal_schema > schema1
 175 constraint_schema > schema2
 176 AT_CHECK([ovsdb-tool create db1 schema1], [0], [ignore], [ignore])
 177 AT_CHECK([ovsdb-tool create db2 schema2], [0], [ignore], [ignore])
 178
 179 # Start ovsdb-server with just a single database - db1.
 180 AT_CHECK([ovsdb-server --detach --no-chdir --pidfile --remote=punix:socket db1], [0])
 181 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-dbs],
 182   [0], [ordinals
 183 ])
 184
 185 # Add the second database.
 186 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/add-db db2], [0])
 187 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-dbs],
 188   [0], [constraints
 189 ordinals
 190 ])
 191
 192 # The databases are responsive.
 193 AT_CHECK([ovsdb-client list-tables unix:socket constraints], [0], [ignore], [ignore])
 194 AT_CHECK([ovsdb-client list-tables unix:socket ordinals], [0], [ignore], [ignore])
 195
 196 # Add an already added database.
 197 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/add-db db2], 2, [],
 198   [db2: already open
 199 ovs-appctl: ovsdb-server: server returned an error
 200 ])
 201
 202 # Add a non-existing database.
 203 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/add-db db3], 2, [], [stderr])
 204 AT_CHECK([sed 's/(.*)/(...)/' stderr], [0],
 205   [I/O error: open: db3 failed (...)
 206 ovs-appctl: ovsdb-server: server returned an error
 207 ])
 208
 209 # Add a remote through a db path in db1.
 210 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/add-remote db:ordinals,ordinals,name], [0])
 211 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-remotes],
 212   [0], [db:ordinals,ordinals,name
 213 punix:socket
 214 ])
 215
 216 # Removing db1 has no effect on its remote.
 217 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/remove-db ordinals], [0])
 218 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-dbs],
 219   [0], [constraints
 220 ])
 221 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-remotes],
 222   [0], [db:ordinals,ordinals,name
 223 punix:socket
 224 ])
 225 AT_CHECK([ovsdb-client list-tables unix:socket ordinals], [1], [ignore], [ignore])
 226
 227 # Remove db2.
 228 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/remove-db constraints], [0])
 229 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-dbs],
 230   [0], [])
 231 AT_CHECK([ovsdb-client list-tables unix:socket constraints], [1], [ignore], [ignore])
 232
 233 # Remove a non-existent database.
 234 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/remove-db ordinals], [2],
 235   [], [Failed to find the database.
 236 ovs-appctl: ovsdb-server: server returned an error
 237 ])
 238
 239 # Add a removed database.
 240 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/add-db db2], [0])
 241 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-dbs],
 242   [0], [constraints
 243 ])
 244 AT_CHECK([ovsdb-client list-tables unix:socket constraints], [0], [ignore], [ignore])
 245 AT_CLEANUP
 246
 247 AT_SETUP([ovsdb-server/add-db with --monitor])
 248 AT_KEYWORDS([ovsdb server positive])
 249 # Start ovsdb-server, initially with one db.
 250 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 251 OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 252 ordinal_schema > schema
 253 AT_CHECK([ovsdb-tool create db1 schema], [0], [ignore], [ignore])
 254 ON_EXIT([kill `cat *.pid`])
 255 AT_CHECK([ovsdb-server -v -vvlog:off --monitor --detach --no-chdir --pidfile --log-file db1])
 256
 257 # Add the second database.
 258 constraint_schema > schema2
 259 AT_CHECK([ovsdb-tool create db2 schema2], [0], [ignore], [ignore])
 260 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/add-db db2], [0])
 261 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-dbs],
 262   [0], [constraints
 263 ordinals
 264 ])
 265
 266 # Kill the daemon process, making it look like a segfault,
 267 # and wait for a new daemon process to get spawned.
 268 cp ovsdb-server.pid old.pid
 269 AT_CHECK([kill -SEGV `cat ovsdb-server.pid`])
 270 OVS_WAIT_WHILE([kill -0 `cat old.pid`])
 271 OVS_WAIT_UNTIL(
 272   [test -s ovsdb-server.pid && test `cat ovsdb-server.pid` != `cat old.pid`])
 273 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-dbs],
 274   [0], [constraints
 275 ordinals
 276 ])
 277 AT_CLEANUP
 278
 279 AT_SETUP([ovsdb-server/add-db and remove-db with --monitor])
 280 AT_KEYWORDS([ovsdb server positive])
 281 # Start ovsdb-server, initially with one db.
 282 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 283 OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 284 ordinal_schema > schema
 285 AT_CHECK([ovsdb-tool create db1 schema], [0], [ignore], [ignore])
 286 constraint_schema > schema2
 287 AT_CHECK([ovsdb-tool create db2 schema2], [0], [ignore], [ignore])
 288 ON_EXIT([kill `cat *.pid`])
 289 AT_CHECK([ovsdb-server -v -vvlog:off --monitor --detach --no-chdir --pidfile --log-file db1 db2])
 290
 291 # Remove the second database.
 292 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/remove-db constraints])
 293 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-dbs],
 294   [0], [ordinals
 295 ])
 296
 297 # Kill the daemon process, making it look like a segfault,
 298 # and wait for a new daemon process to get spawned.
 299 cp ovsdb-server.pid old.pid
 300 AT_CHECK([kill -SEGV `cat ovsdb-server.pid`])
 301 OVS_WAIT_WHILE([kill -0 `cat old.pid`])
 302 OVS_WAIT_UNTIL(
 303   [test -s ovsdb-server.pid && test `cat ovsdb-server.pid` != `cat old.pid`])
 304 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-dbs],
 305   [0], [ordinals
 306 ])
 307 AT_CLEANUP
 308
 309 AT_SETUP([--remote=db: implementation])
 310 AT_KEYWORDS([ovsdb server positive])
 311 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 312 OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 313 AT_DATA([schema],
 314   [[{"name": "mydb",
 315      "tables": {
 316        "Root": {
 317          "columns": {
 318            "managers": {
 319              "type": {
 320                "key": "string",
 321                "min": 0,
 322                "max": "unlimited"}},
 323            "manager_options": {
 324              "type": {
 325                "key": {"type": "uuid", "refTable": "Manager"},
 326                "min": 0,
 327                "max": "unlimited"}}}},
 328        "Manager": {
 329          "columns": {
 330            "target": {
 331              "type": "string"},
 332            "is_connected": {
 333              "type": {
 334                "key": "boolean",
 335                "min": 0,
 336                "max": 1}}}}}}
 337 ]])
 338 AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
 339 AT_CHECK(
 340   [[ovsdb-tool transact db \
 341      '["mydb",
 342        {"op": "insert",
 343         "table": "Root",
 344         "row": {
 345           "managers": "punix:socket1",
 346           "manager_options": ["set", [["named-uuid", "x"]]]}},
 347        {"op": "insert",
 348         "table": "Manager",
 349         "uuid-name": "x",
 350         "row": {"target": "punix:socket2"}}]']], [0], [ignore], [ignore])
 351 ON_EXIT([kill `cat ovsdb-server.pid`])
 352 AT_CHECK([ovsdb-server --enable-dummy --detach --no-chdir --pidfile --remote=db:mydb,Root,managers --remote=db:mydb,Root,manager_options --log-file db], [0], [ignore], [ignore])
 353 for i in 1 2 3 4 5 6; do ovs-appctl -t ovsdb-server time/warp 1000; done
 354 AT_CHECK(
 355   [[ovsdb-client transact unix:socket1 \
 356      '["mydb",
 357        {"op": "select",
 358         "table": "Root",
 359         "where": [],
 360         "columns": ["managers"]},
 361        {"op": "select",
 362         "table": "Manager",
 363         "where": [],
 364         "columns": ["target", "is_connected"]}]']],
 365   [0], [stdout], [ignore])
 366 AT_CHECK(
 367   [${PERL} $srcdir/uuidfilt.pl stdout],
 368   [0],
 369   [[[{"rows":[{"managers":"punix:socket1"}]},{"rows":[{"is_connected":false,"target":"punix:socket2"}]}]
 370 ]],
 371   [ignore])
 372 AT_CLEANUP
 373
 374 AT_SETUP([ovsdb-server/add-remote and remove-remote])
 375 AT_KEYWORDS([ovsdb server positive])
 376 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 377 OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 378 ordinal_schema > schema
 379 AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
 380 ON_EXIT([kill `cat *.pid`])
 381 AT_CHECK([ovsdb-server --detach --no-chdir --pidfile db])
 382
 383 AT_CHECK([test ! -e socket1])
 384 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/add-remote punix:socket1])
 385 OVS_WAIT_UNTIL([test -S socket1])
 386 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-remotes],
 387   [0], [punix:socket1
 388 ])
 389
 390 AT_CHECK([test ! -e socket2])
 391 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/add-remote punix:socket2])
 392 OVS_WAIT_UNTIL([test -S socket2])
 393 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-remotes],
 394   [0], [punix:socket1
 395 punix:socket2
 396 ])
 397
 398 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/add-remote db:x,y,z], [2],
 399   [], ["db:x,y,z": no database named x
 400 ovs-appctl: ovsdb-server: server returned an error
 401 ])
 402
 403 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/remove-remote punix:socket1])
 404 OVS_WAIT_UNTIL([test ! -e socket1])
 405 AT_CHECK([test -S socket2])
 406 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-remotes],
 407   [0], [punix:socket2
 408 ])
 409
 410 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/remove-remote punix:socket2])
 411 OVS_WAIT_UNTIL([test ! -e socket2])
 412 AT_CHECK([test ! -e socket1])
 413 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-remotes])
 414 AT_CLEANUP
 415
 416 AT_SETUP([ovsdb-server/add-remote with --monitor])
 417 AT_KEYWORDS([ovsdb server positive])
 418 # Start ovsdb-server, initially with no remotes.
 419 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 420 OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 421 ordinal_schema > schema
 422 AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
 423 ON_EXIT([kill `cat *.pid`])
 424 AT_CHECK([ovsdb-server -v -vvlog:off --monitor --detach --no-chdir --pidfile --log-file db])
 425
 426 # Add a remote.
 427 AT_CHECK([test ! -e socket1])
 428 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/add-remote punix:socket1])
 429 OVS_WAIT_UNTIL([test -S socket1])
 430 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-remotes],
 431   [0], [punix:socket1
 432 ])
 433
 434 # Kill the daemon process, making it look like a segfault,
 435 # and wait for a new daemon process to get spawned and for it to
 436 # start listening on 'socket1'.
 437 cp ovsdb-server.pid old.pid
 438 rm socket1
 439 AT_CHECK([kill -SEGV `cat ovsdb-server.pid`])
 440 OVS_WAIT_WHILE([kill -0 `cat old.pid`])
 441 OVS_WAIT_UNTIL(
 442   [test -s ovsdb-server.pid && test `cat ovsdb-server.pid` != `cat old.pid`])
 443 OVS_WAIT_UNTIL([test -S socket1])
 444 AT_CLEANUP
 445
 446 AT_SETUP([ovsdb-server/add-remote and remove-remote with --monitor])
 447 AT_KEYWORDS([ovsdb server positive])
 448 # Start ovsdb-server, initially with no remotes.
 449 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 450 OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 451 ordinal_schema > schema
 452 AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
 453 ON_EXIT([kill `cat *.pid`])
 454 AT_CHECK([ovsdb-server -v -vvlog:off --monitor --detach --no-chdir --pidfile --log-file db])
 455
 456 # Add a remote.
 457 AT_CHECK([test ! -e socket1])
 458 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/add-remote punix:socket1])
 459 OVS_WAIT_UNTIL([test -S socket1])
 460 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-remotes],
 461   [0], [punix:socket1
 462 ])
 463
 464 # Remove the remote.
 465 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/remove-remote punix:socket1])
 466 OVS_WAIT_UNTIL([test ! -e socket1])
 467 AT_CHECK([ovs-appctl -t ovsdb-server ovsdb-server/list-remotes])
 468
 469 # Kill the daemon process, making it look like a segfault,
 470 # and wait for a new daemon process to get spawned and make sure that it
 471 # does not listen on 'socket1'.
 472 cp ovsdb-server.pid old.pid
 473 AT_CHECK([kill -SEGV `cat ovsdb-server.pid`])
 474 OVS_WAIT_WHILE([kill -0 `cat old.pid`])
 475 OVS_WAIT_UNTIL(
 476   [test -s ovsdb-server.pid && test `cat ovsdb-server.pid` != `cat old.pid`])
 477 AT_CHECK([test ! -e socket1])
 478 AT_CLEANUP
 479
 480 AT_SETUP([SSL db: implementation])
 481 AT_KEYWORDS([ovsdb server positive ssl $5])
 482 AT_SKIP_IF([test "$HAVE_OPENSSL" = no])
 483 PKIDIR=$abs_top_builddir/tests
 484 AT_SKIP_IF([expr "$PKIDIR" : ".*[       '\"
 485 \\]"])
 486 AT_DATA([schema],
 487   [[{"name": "mydb",
 488      "tables": {
 489        "SSL": {
 490          "columns": {
 491            "private_key": {"type": "string"},
 492            "certificate": {"type": "string"},
 493            "ca_cert": {"type": "string"}}}}}
 494 ]])
 495 AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
 496 AT_CHECK(
 497   [[ovsdb-tool transact db \
 498      '["mydb",
 499        {"op": "insert",
 500         "table": "SSL",
 501         "row": {"private_key": "'"$PKIDIR/testpki-privkey2.pem"'",
 502                 "certificate": "'"$PKIDIR/testpki-cert2.pem"'",
 503                 "ca_cert": "'"$PKIDIR/testpki-cacert.pem"'"}}]']],
 504   [0], [ignore], [ignore])
 505 OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 506 AT_CHECK(
 507   [ovsdb-server --log-file --detach --no-chdir --pidfile="`pwd`"/pid \
 508         --private-key=db:mydb,SSL,private_key \
 509         --certificate=db:mydb,SSL,certificate \
 510         --ca-cert=db:mydb,SSL,ca_cert \
 511         --remote=pssl:0:127.0.0.1 --unixctl="`pwd`"/unixctl db],
 512   [0], [ignore], [ignore])
 513 SSL_PORT=`parse_listening_port < ovsdb-server.log`
 514 AT_CHECK(
 515   [[ovsdb-client \
 516         --private-key=$PKIDIR/testpki-privkey.pem \
 517         --certificate=$PKIDIR/testpki-cert.pem \
 518         --ca-cert=$PKIDIR/testpki-cacert.pem \
 519         transact ssl:127.0.0.1:$SSL_PORT \
 520         '["mydb",
 521           {"op": "select",
 522            "table": "SSL",
 523            "where": [],
 524            "columns": ["private_key"]}]']],
 525   [0], [stdout], [ignore], [test ! -e pid || kill `cat pid`])
 526 cat stdout >> output
 527 AT_CHECK_UNQUOTED(
 528   [cat output], [0],
 529   [[[{"rows":[{"private_key":"$PKIDIR/testpki-privkey2.pem"}]}]
 530 ]], [ignore], [test ! -e pid || kill `cat pid`])
 531 OVSDB_SERVER_SHUTDOWN
 532 AT_CLEANUP
 533
 534 AT_SETUP([compacting online])
 535 AT_KEYWORDS([ovsdb server compact])
 536 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 537 ordinal_schema > schema
 538 dnl Make sure that "ovsdb-tool create" works with a dangling symlink for
 539 dnl the database and the lockfile, creating the target of each symlink rather
 540 dnl than replacing the symlinks with regular files.
 541 mkdir dir
 542 ln -s dir/db db
 543 ln -s dir/.db.~lock~ .db.~lock~
 544 AT_SKIP_IF([test ! -h db || test ! -h .db.~lock~])
 545 AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
 546 dnl Start ovsdb-server.
 547 AT_CHECK([ovsdb-server --detach --no-chdir --pidfile="`pwd`"/pid --unixctl="`pwd`"/unixctl --remote=punix:socket --log-file="`pwd`"/ovsdb-server.log db], [0], [ignore], [ignore])
 548 AT_CAPTURE_FILE([ovsdb-server.log])
 549 dnl Do a bunch of random transactions that put crap in the database log.
 550 AT_CHECK(
 551   [[for pair in 'zero 0' 'one 1' 'two 2' 'three 3' 'four 4' 'five 5'; do
 552       set -- $pair
 553       ovsdb-client transact unix:socket '
 554         ["ordinals",
 555          {"op": "insert",
 556           "table": "ordinals",
 557           "row": {"name": "'$1'", "number": '$2'}},
 558          {"op": "comment",
 559           "comment": "add row for '"$pair"'"}]'
 560       ovsdb-client transact unix:socket '
 561         ["ordinals",
 562          {"op": "delete",
 563           "table": "ordinals",
 564           "where": [["number", "==", '$2']]},
 565          {"op": "comment",
 566           "comment": "delete row for '"$2"'"}]'
 567       ovsdb-client transact unix:socket '
 568         ["ordinals",
 569          {"op": "insert",
 570           "table": "ordinals",
 571           "row": {"name": "'$1'", "number": '$2'}},
 572          {"op": "comment",
 573           "comment": "add back row for '"$pair"'"}]'
 574     done]],
 575   [0], [stdout], [ignore], [test ! -e pid || kill `cat pid`])
 576 dnl Check that all the crap is in fact in the database log.
 577 AT_CHECK([[${PERL} $srcdir/uuidfilt.pl db | grep -v ^OVSDB | sed 's/"_date":[0-9]*/"_date":0/' | ovstest test-json --multiple -]], [0],
 578   [[{"cksum":"12345678 9","name":"ordinals","tables":{"ordinals":{"columns":{"name":{"type":"string"},"number":{"type":"integer"}},"indexes":[["number"]]}},"version":"5.1.3"}
 579 {"_comment":"add row for zero 0","_date":0,"ordinals":{"<0>":{"name":"zero"}}}
 580 {"_comment":"delete row for 0","_date":0,"ordinals":{"<0>":null}}
 581 {"_comment":"add back row for zero 0","_date":0,"ordinals":{"<1>":{"name":"zero"}}}
 582 {"_comment":"add row for one 1","_date":0,"ordinals":{"<2>":{"name":"one","number":1}}}
 583 {"_comment":"delete row for 1","_date":0,"ordinals":{"<2>":null}}
 584 {"_comment":"add back row for one 1","_date":0,"ordinals":{"<3>":{"name":"one","number":1}}}
 585 {"_comment":"add row for two 2","_date":0,"ordinals":{"<4>":{"name":"two","number":2}}}
 586 {"_comment":"delete row for 2","_date":0,"ordinals":{"<4>":null}}
 587 {"_comment":"add back row for two 2","_date":0,"ordinals":{"<5>":{"name":"two","number":2}}}
 588 {"_comment":"add row for three 3","_date":0,"ordinals":{"<6>":{"name":"three","number":3}}}
 589 {"_comment":"delete row for 3","_date":0,"ordinals":{"<6>":null}}
 590 {"_comment":"add back row for three 3","_date":0,"ordinals":{"<7>":{"name":"three","number":3}}}
 591 {"_comment":"add row for four 4","_date":0,"ordinals":{"<8>":{"name":"four","number":4}}}
 592 {"_comment":"delete row for 4","_date":0,"ordinals":{"<8>":null}}
 593 {"_comment":"add back row for four 4","_date":0,"ordinals":{"<9>":{"name":"four","number":4}}}
 594 {"_comment":"add row for five 5","_date":0,"ordinals":{"<10>":{"name":"five","number":5}}}
 595 {"_comment":"delete row for 5","_date":0,"ordinals":{"<10>":null}}
 596 {"_comment":"add back row for five 5","_date":0,"ordinals":{"<11>":{"name":"five","number":5}}}
 597 ]], [], [test ! -e pid || kill `cat pid`])
 598 dnl Dump out and check the actual database contents.
 599 AT_CHECK([[ovsdb-client dump unix:socket ordinals]],
 600   [0], [stdout], [ignore])
 601 AT_CHECK([${PERL} $srcdir/uuidfilt.pl stdout], [0], [dnl
 602 ordinals table
 603 _uuid                                name  number
 604 ------------------------------------ ----- ------
 605 <0> five  5     @&t@
 606 <1> four  4     @&t@
 607 <2> one   1     @&t@
 608 <3> three 3     @&t@
 609 <4> two   2     @&t@
 610 <5> zero  0     @&t@
 611 ], [], [test ! -e pid || kill `cat pid`])
 612 dnl Now compact the database in-place.
 613 AT_CHECK([[ovs-appctl -t "`pwd`"/unixctl ovsdb-server/compact]],
 614   [0], [], [ignore], [test ! -e pid || kill `cat pid`])
 615 dnl Make sure that "db" is still a symlink to dir/db instead of getting
 616 dnl replaced by a regular file, ditto for .db.~lock~.
 617 AT_CHECK([test -h db])
 618 AT_CHECK([test -h .db.~lock~])
 619 AT_CHECK([test -f dir/db])
 620 AT_CHECK([test -f dir/.db.~lock~])
 621 dnl We can't fully re-check the contents of the database log, because the
 622 dnl order of the records is not predictable, but there should only be 4 lines
 623 dnl in it now.
 624 AT_CAPTURE_FILE([db])
 625 AT_CHECK([test `wc -l < db` -eq 4], [0], [], [],
 626   [test ! -e pid || kill `cat pid`])
 627 dnl And check that the dumped data is the same too:
 628 AT_CHECK([ovsdb-client dump unix:socket ordinals], [0], [stdout], [ignore],
 629   [test ! -e pid || kill `cat pid`])
 630 AT_CHECK([${PERL} $srcdir/uuidfilt.pl stdout], [0], [dnl
 631 ordinals table
 632 _uuid                                name  number
 633 ------------------------------------ ----- ------
 634 <0> five  5     @&t@
 635 <1> four  4     @&t@
 636 <2> one   1     @&t@
 637 <3> three 3     @&t@
 638 <4> two   2     @&t@
 639 <5> zero  0     @&t@
 640 ], [], [test ! -e pid || kill `cat pid`])
 641 dnl Now do some more transactions.
 642 AT_CHECK(
 643   [[ovsdb-client transact unix:socket '
 644      ["ordinals",
 645       {"op": "delete",
 646        "table": "ordinals",
 647        "where": [["number", "<", 3]]}]']],
 648   [0], [[[{"count":3}]
 649 ]], [ignore], [test ! -e pid || kill `cat pid`])
 650 dnl There should be 6 lines in the log now.
 651 AT_CHECK([test `wc -l < db` -eq 6], [0], [], [],
 652   [test ! -e pid || kill `cat pid`])
 653 dnl Then check that the dumped data is correct.
 654 AT_CHECK([ovsdb-client dump unix:socket ordinals], [0], [stdout], [ignore],
 655   [test ! -e pid || kill `cat pid`])
 656 AT_CHECK([${PERL} $srcdir/uuidfilt.pl stdout], [0], [dnl
 657 ordinals table
 658 _uuid                                name  number
 659 ------------------------------------ ----- ------
 660 <0> five  5     @&t@
 661 <1> four  4     @&t@
 662 <2> three 3     @&t@
 663 ], [], [test ! -e pid || kill `cat pid`])
 664 OVSDB_SERVER_SHUTDOWN
 665 AT_CLEANUP
 666
 667 AT_SETUP([ovsdb-server combines updates on backlogged connections])
 668 OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 669 OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 670 ON_EXIT([kill `cat *.pid`])
 671
 672 # The maximum socket receive buffer size is important for this test, which
 673 # tests behavior when the receive buffer overflows.
 674 if test -e /proc/sys/net/core/rmem_max; then
 675     # Linux
 676     rmem_max=`cat /proc/sys/net/core/rmem_max`
 677 elif rmem_max=`sysctl -n net.inet.tcp.recvbuf_max 2>/dev/null`; then
 678     : # FreeBSD, NetBSD
 679 else
 680     # Don't know how to get maximum socket receive buffer on this OS
 681     AT_SKIP_IF([:])
 682 fi
 683
 684 # Calculate the number of iterations we need to queue.  Each of the
 685 # iterations we execute, by itself, yields a monitor update of about
 686 # 25 kB, so fill up that much space plus a few for luck.
 687 n_iterations=`expr $rmem_max / 25000 + 5`
 688 echo rmem_max=$rmem_max n_iterations=$n_iterations
 689
 690 # Calculate the exact number of monitor updates expected for $n_iterations,
 691 # assuming no updates are combined.  The "extra" update is for the initial
 692 # contents of the database.
 693 n_updates=`expr $n_iterations \* 3 + 1`
 694
 695 # Start an ovsdb-server with the vswitchd schema.
 696 OVSDB_INIT([db])
 697 AT_CHECK([ovsdb-server --detach --no-chdir --pidfile --log-file --remote=punix:db.sock db],
 698   [0], [ignore], [ignore])
 699
 700 # Executes a set of transactions that add a bridge with 100 ports, and
 701 # then deletes that bridge.  This yields three monitor updates that
 702 # add up to about 25 kB in size.
 703 #
 704 # The update also increments a counter held in the database so that we can
 705 # verify that the overall effect of the transactions took effect (e.g.
 706 # monitor updates at the end weren't just dropped).  We add an arbitrary
 707 # string to the counter to make grepping for it more reliable.
 708 counter=0
 709 trigger_big_update () {
 710     counter=`expr $counter + 1`
 711     ovs-vsctl --no-wait -- set open_vswitch . system_version=xyzzy$counter
 712     ovs-vsctl --no-wait -- add-br br0 $add
 713     ovs-vsctl --no-wait -- del-br br0
 714 }
 715 add_ports () {
 716     for j in `seq 1 100`; do
 717         printf " -- add-port br0 p%d" $j
 718     done
 719 }
 720 add=`add_ports`
 721
 722 AT_CAPTURE_FILE([ovsdb-client.err])
 723
 724 # Start an ovsdb-client monitoring all changes to the database,
 725 # make it block to force the buffers to fill up, and then execute
 726 # enough iterations that ovsdb-server starts combining updates.
 727 AT_CHECK([ovsdb-client --detach --no-chdir --pidfile monitor ALL >ovsdb-client.out 2>ovsdb-client.err])
 728 AT_CHECK([ovs-appctl -t ovsdb-client ovsdb-client/block])
 729 for i in `seq 1 $n_iterations`; do
 730     echo "blocked update ($i of $n_iterations)"
 731     trigger_big_update $i
 732 done
 733 AT_CHECK([ovs-appctl -t ovsdb-client ovsdb-client/unblock])
 734 OVS_WAIT_UNTIL([grep "\"xyzzy$counter\"" ovsdb-client.out])
 735 AT_CHECK([ovs-appctl -t ovsdb-client exit])
 736 OVS_WAIT_WHILE([test -e ovsdb-client.pid])
 737
 738 # Count the number of updates in the ovsdb-client output, by counting
 739 # the number of changes to the Open_vSwitch table.  (All of our
 740 # transactions modify the Open_vSwitch table.)  It should be less than
 741 # $n_updates updates.
 742 #
 743 # Check that the counter is what we expect.
 744 logged_updates=`grep -c '^Open_vSwitch' ovsdb-client.out`
 745 echo "logged_updates=$logged_updates (expected less than $n_updates)"
 746 AT_CHECK([test $logged_updates -lt $n_updates])
 747 AT_CHECK_UNQUOTED([ovs-vsctl get open_vswitch . system_version], [0],
 748   ["xyzzy$counter"
 749 ])
 750 AT_CLEANUP
 751 \f
 752 AT_BANNER([OVSDB -- ovsdb-server transactions (SSL IPv4 sockets)])
 753
 754 # OVSDB_CHECK_EXECUTION(TITLE, SCHEMA, TRANSACTIONS, OUTPUT, [KEYWORDS])
 755 #
 756 # Creates a database with the given SCHEMA, starts an ovsdb-server on
 757 # that database, and runs each of the TRANSACTIONS (which should be a
 758 # quoted list of quoted strings) against it with ovsdb-client one at a
 759 # time.
 760 #
 761 # Checks that the overall output is OUTPUT, but UUIDs in the output
 762 # are replaced by markers of the form <N> where N is a number.  The
 763 # first unique UUID is replaced by <0>, the next by <1>, and so on.
 764 # If a given UUID appears more than once it is always replaced by the
 765 # same marker.
 766 #
 767 # TITLE is provided to AT_SETUP and KEYWORDS to AT_KEYWORDS.
 768 m4_define([OVSDB_CHECK_EXECUTION],
 769   [AT_SETUP([$1])
 770    AT_KEYWORDS([ovsdb server positive ssl $5])
 771    AT_SKIP_IF([test "$HAVE_OPENSSL" = no])
 772    OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 773    OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 774    $2 > schema
 775    PKIDIR=$abs_top_builddir/tests
 776    AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
 777    AT_CHECK([ovsdb-server --log-file --detach --no-chdir --pidfile="`pwd`"/pid --private-key=$PKIDIR/testpki-privkey2.pem --certificate=$PKIDIR/testpki-cert2.pem --ca-cert=$PKIDIR/testpki-cacert.pem --remote=pssl:0:127.0.0.1 --unixctl="`pwd`"/unixctl db], [0], [ignore], [ignore])
 778    SSL_PORT=`parse_listening_port < ovsdb-server.log`
 779    m4_foreach([txn], [$3],
 780      [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],
 781      [test ! -e pid || kill `cat pid`])
 782 cat stdout >> output
 783 ])
 784    AT_CHECK([${PERL} $srcdir/uuidfilt.pl output], [0], [$4], [ignore],
 785             [test ! -e pid || kill `cat pid`])
 786    OVSDB_SERVER_SHUTDOWN
 787    AT_CLEANUP])
 788
 789 EXECUTION_EXAMPLES
 790
 791 AT_BANNER([OVSDB -- ovsdb-server transactions (SSL IPv6 sockets)])
 792
 793 # OVSDB_CHECK_EXECUTION(TITLE, SCHEMA, TRANSACTIONS, OUTPUT, [KEYWORDS])
 794 #
 795 # Creates a database with the given SCHEMA, starts an ovsdb-server on
 796 # that database, and runs each of the TRANSACTIONS (which should be a
 797 # quoted list of quoted strings) against it with ovsdb-client one at a
 798 # time.
 799 #
 800 # Checks that the overall output is OUTPUT, but UUIDs in the output
 801 # are replaced by markers of the form <N> where N is a number.  The
 802 # first unique UUID is replaced by <0>, the next by <1>, and so on.
 803 # If a given UUID appears more than once it is always replaced by the
 804 # same marker.
 805 #
 806 # TITLE is provided to AT_SETUP and KEYWORDS to AT_KEYWORDS.
 807 m4_define([OVSDB_CHECK_EXECUTION],
 808   [AT_SETUP([$1])
 809    AT_KEYWORDS([ovsdb server positive ssl6 $5])
 810    AT_SKIP_IF([test "$HAVE_OPENSSL" = no])
 811    OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 812    OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 813    $2 > schema
 814    PKIDIR=$abs_top_builddir/tests
 815    AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
 816    AT_CHECK([ovsdb-server --log-file --detach --no-chdir --pidfile="`pwd`"/pid --private-key=$PKIDIR/testpki-privkey2.pem --certificate=$PKIDIR/testpki-cert2.pem --ca-cert=$PKIDIR/testpki-cacert.pem --remote=pssl:0:[[::1]] --unixctl="`pwd`"/unixctl db], [0], [ignore], [ignore])
 817    SSL_PORT=`parse_listening_port < ovsdb-server.log`
 818    m4_foreach([txn], [$3],
 819      [AT_CHECK([ovsdb-client --private-key=$PKIDIR/testpki-privkey.pem --certificate=$PKIDIR/testpki-cert.pem --ca-cert=$PKIDIR/testpki-cacert.pem transact ssl:[[::1]]:$SSL_PORT 'txn'], [0], [stdout], [ignore],
 820      [test ! -e pid || kill `cat pid`])
 821 cat stdout >> output
 822 ])
 823    AT_CHECK([${PERL} $srcdir/uuidfilt.pl output], [0], [$4], [ignore],
 824             [test ! -e pid || kill `cat pid`])
 825    OVSDB_SERVER_SHUTDOWN
 826    AT_CLEANUP])
 827
 828 ONE_EXECUTION_EXAMPLE
 829
 830 AT_BANNER([OVSDB -- ovsdb-server transactions (TCP IPv4 sockets)])
 831
 832 AT_SETUP([ovsdb-client get-schema-version - tcp socket])
 833 AT_KEYWORDS([ovsdb server positive tcp])
 834 ordinal_schema > schema
 835 AT_CHECK([ovsdb-tool create db schema], [0], [ignore], [ignore])
 836 OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 837 AT_CHECK([ovsdb-server --log-file --detach --no-chdir --pidfile="`pwd`"/pid --unixctl="`pwd`"/unixctl --remote=ptcp:0:127.0.0.1 db], [0], [ignore], [ignore])
 838 TCP_PORT=`parse_listening_port < ovsdb-server.log`
 839 AT_CHECK([ovsdb-client get-schema-version tcp:127.0.0.1:$TCP_PORT ordinals], [0], [5.1.3
 840 ])
 841 OVSDB_SERVER_SHUTDOWN
 842 AT_CLEANUP])
 843
 844 # OVSDB_CHECK_EXECUTION(TITLE, SCHEMA, TRANSACTIONS, OUTPUT, [KEYWORDS])
 845 #
 846 # Creates a database with the given SCHEMA, starts an ovsdb-server on
 847 # that database, and runs each of the TRANSACTIONS (which should be a
 848 # quoted list of quoted strings) against it with ovsdb-client one at a
 849 # time.
 850 #
 851 # Checks that the overall output is OUTPUT, but UUIDs in the output
 852 # are replaced by markers of the form <N> where N is a number.  The
 853 # first unique UUID is replaced by <0>, the next by <1>, and so on.
 854 # If a given UUID appears more than once it is always replaced by the
 855 # same marker.
 856 #
 857 # TITLE is provided to AT_SETUP and KEYWORDS to AT_KEYWORDS.
 858 m4_define([OVSDB_CHECK_EXECUTION],
 859   [AT_SETUP([$1])
 860    AT_KEYWORDS([ovsdb server positive tcp $5])
 861    OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 862    OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 863    $2 > schema
 864    PKIDIR=$abs_top_builddir/tests
 865    AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
 866    AT_CHECK([ovsdb-server --log-file --detach --no-chdir --pidfile="`pwd`"/pid --remote=ptcp:0:127.0.0.1 --unixctl="`pwd`"/unixctl db], [0], [ignore], [ignore])
 867    TCP_PORT=`parse_listening_port < ovsdb-server.log`
 868    m4_foreach([txn], [$3],
 869      [AT_CHECK([ovsdb-client transact tcp:127.0.0.1:$TCP_PORT 'txn'], [0], [stdout], [ignore],
 870      [test ! -e pid || kill `cat pid`])
 871 cat stdout >> output
 872 ])
 873    AT_CHECK([${PERL} $srcdir/uuidfilt.pl output], [0], [$4], [ignore],
 874             [test ! -e pid || kill `cat pid`])
 875    OVSDB_SERVER_SHUTDOWN
 876    AT_CLEANUP])
 877
 878 EXECUTION_EXAMPLES
 879
 880 AT_BANNER([OVSDB -- ovsdb-server transactions (TCP IPv6 sockets)])
 881
 882 # OVSDB_CHECK_EXECUTION(TITLE, SCHEMA, TRANSACTIONS, OUTPUT, [KEYWORDS])
 883 #
 884 # Creates a database with the given SCHEMA, starts an ovsdb-server on
 885 # that database, and runs each of the TRANSACTIONS (which should be a
 886 # quoted list of quoted strings) against it with ovsdb-client one at a
 887 # time.
 888 #
 889 # Checks that the overall output is OUTPUT, but UUIDs in the output
 890 # are replaced by markers of the form <N> where N is a number.  The
 891 # first unique UUID is replaced by <0>, the next by <1>, and so on.
 892 # If a given UUID appears more than once it is always replaced by the
 893 # same marker.
 894 #
 895 # TITLE is provided to AT_SETUP and KEYWORDS to AT_KEYWORDS.
 896 m4_define([OVSDB_CHECK_EXECUTION],
 897   [AT_SETUP([$1])
 898    AT_KEYWORDS([ovsdb server positive tcp6 $5])
 899    OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 900    OVS_LOGDIR=`pwd`; export OVS_LOGDIR
 901    $2 > schema
 902    PKIDIR=$abs_top_builddir/tests
 903    AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
 904    AT_CHECK([ovsdb-server --log-file --detach --no-chdir --pidfile="`pwd`"/pid --remote=ptcp:0:[[::1]] --unixctl="`pwd`"/unixctl db], [0], [ignore], [ignore])
 905    TCP_PORT=`parse_listening_port < ovsdb-server.log`
 906    m4_foreach([txn], [$3],
 907      [AT_CHECK([ovsdb-client transact tcp:[[::1]]:$TCP_PORT 'txn'], [0], [stdout], [ignore],
 908      [test ! -e pid || kill `cat pid`])
 909 cat stdout >> output
 910 ])
 911    AT_CHECK([${PERL} $srcdir/uuidfilt.pl output], [0], [$4], [ignore],
 912             [test ! -e pid || kill `cat pid`])
 913    OVSDB_SERVER_SHUTDOWN
 914    AT_CLEANUP])
 915
 916 ONE_EXECUTION_EXAMPLE
 917 \f
 918 AT_BANNER([OVSDB -- transactions on transient ovsdb-server])
 919
 920 # OVSDB_CHECK_EXECUTION(TITLE, SCHEMA, TRANSACTIONS, OUTPUT, [KEYWORDS])
 921 #
 922 # Creates a database with the given SCHEMA and runs each of the
 923 # TRANSACTIONS (which should be a quoted list of quoted strings)
 924 # against it with ovsdb-client one at a time.  Each ovsdb-client
 925 # is run against a separately started ovsdb-server that executes
 926 # only that single transaction.  (The idea is that this should
 927 # help to ferret out any differences between what ovsdb-server has
 928 # in memory and what actually gets committed to disk.)
 929 #
 930 # Checks that the overall output is OUTPUT, but UUIDs in the output
 931 # are replaced by markers of the form <N> where N is a number.  The
 932 # first unique UUID is replaced by <0>, the next by <1>, and so on.
 933 # If a given UUID appears more than once it is always replaced by the
 934 # same marker.
 935 #
 936 # TITLE is provided to AT_SETUP and KEYWORDS to AT_KEYWORDS.
 937 m4_define([OVSDB_CHECK_EXECUTION],
 938   [AT_SETUP([$1])
 939    AT_KEYWORDS([ovsdb server positive transient $5])
 940    OVS_RUNDIR=`pwd`; export OVS_RUNDIR
 941    $2 > schema
 942    AT_CHECK([ovsdb-tool create db schema], [0], [stdout], [ignore])
 943    m4_foreach([txn], [$3],
 944      [AT_DATA([txnfile], [ovsdb-client transact unix:socket 'txn'
 945 ])
 946       AT_CHECK([ovsdb-server --remote=punix:socket --unixctl="`pwd`"/unixctl db --run="sh txnfile"], [0], [stdout], [ignore])
 947       cat stdout >> output
 948 ])
 949    AT_CHECK([${PERL} $srcdir/uuidfilt.pl output], [0], [$4], [ignore])
 950    AT_CLEANUP])
 951
 952 EXECUTION_EXAMPLES