From patchwork Mon Aug 23 22:59:15 2021 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Numan Siddique X-Patchwork-Id: 1520031 Return-Path: X-Original-To: incoming@patchwork.ozlabs.org Delivered-To: patchwork-incoming@bilbo.ozlabs.org Authentication-Results: ozlabs.org; spf=pass (sender SPF authorized) smtp.mailfrom=openvswitch.org (client-ip=2605:bc80:3010::136; helo=smtp3.osuosl.org; envelope-from=ovs-dev-bounces@openvswitch.org; receiver=) Received: from smtp3.osuosl.org (smtp3.osuosl.org [IPv6:2605:bc80:3010::136]) (using TLSv1.3 with cipher TLS_AES_256_GCM_SHA384 (256/256 bits) key-exchange X25519 server-signature RSA-PSS (4096 bits) server-digest SHA256) (No client certificate requested) by ozlabs.org (Postfix) with ESMTPS id 4GtnkS1g67z9sVw for ; Tue, 24 Aug 2021 08:59:44 +1000 (AEST) Received: from localhost (localhost [127.0.0.1]) by smtp3.osuosl.org (Postfix) with ESMTP id DCD7C6080B; Mon, 23 Aug 2021 22:59:41 +0000 (UTC) X-Virus-Scanned: amavisd-new at osuosl.org Received: from smtp3.osuosl.org ([127.0.0.1]) by localhost (smtp3.osuosl.org [127.0.0.1]) (amavisd-new, port 10024) with ESMTP id 24o8ZBCQHn0Q; Mon, 23 Aug 2021 22:59:37 +0000 (UTC) Received: from lists.linuxfoundation.org (lf-lists.osuosl.org [140.211.9.56]) by smtp3.osuosl.org (Postfix) with ESMTPS id B3A1B607DA; Mon, 23 Aug 2021 22:59:36 +0000 (UTC) Received: from lf-lists.osuosl.org (localhost [127.0.0.1]) by lists.linuxfoundation.org (Postfix) with ESMTP id 7D052C001B; Mon, 23 Aug 2021 22:59:36 +0000 (UTC) X-Original-To: dev@openvswitch.org Delivered-To: ovs-dev@lists.linuxfoundation.org Received: from smtp2.osuosl.org (smtp2.osuosl.org [140.211.166.133]) by lists.linuxfoundation.org (Postfix) with ESMTP id 178C9C000E for ; Mon, 23 Aug 2021 22:59:35 +0000 (UTC) Received: from localhost (localhost [127.0.0.1]) by smtp2.osuosl.org (Postfix) with ESMTP id 84AF9403A5 for ; Mon, 23 Aug 2021 22:59:31 +0000 (UTC) X-Virus-Scanned: amavisd-new at osuosl.org Received: from smtp2.osuosl.org ([127.0.0.1]) by localhost (smtp2.osuosl.org [127.0.0.1]) (amavisd-new, port 10024) with ESMTP id Zr1fXPcyDjxr for ; Mon, 23 Aug 2021 22:59:30 +0000 (UTC) X-Greylist: domain auto-whitelisted by SQLgrey-1.8.0 Received: from relay8-d.mail.gandi.net (relay8-d.mail.gandi.net [217.70.183.201]) by smtp2.osuosl.org (Postfix) with ESMTPS id 2DAF1403A2 for ; Mon, 23 Aug 2021 22:59:27 +0000 (UTC) Received: (Authenticated sender: numans@ovn.org) by relay8-d.mail.gandi.net (Postfix) with ESMTPSA id B8B9F1BF203; Mon, 23 Aug 2021 22:59:25 +0000 (UTC) From: numans@ovn.org To: dev@openvswitch.org Date: Mon, 23 Aug 2021 18:59:15 -0400 Message-Id: <20210823225915.3903510-1-numans@ovn.org> X-Mailer: git-send-email 2.31.1 In-Reply-To: <20210823225826.3903356-1-numans@ovn.org> References: <20210823225826.3903356-1-numans@ovn.org> MIME-Version: 1.0 Subject: [ovs-dev] [PATCH v3 2/2] ovsdb-idl: Exclude missing tables and columns in the transaction. X-BeenThere: ovs-dev@openvswitch.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: ovs-dev-bounces@openvswitch.org Sender: "dev" From: Numan Siddique In the cases where the C idl client is compiled with a newer schema and the ovsdb-server is running with older schema, the IDL clients can included tables or columns in the transaction which are missing in the server schema. ovsdb-server will reject the transaction, but the IDL client keeps on trying the transaction resulting in a continuous loop. This patch fixes this issue. For the missing tables, the function ovsdb_idl_txn_insert() will now return NULL. The client should check for NULL before accessing the row object. For the missing columns, the columns are excluded from the transaction object. Relevant test cases are added. Related issue: https://bugzilla.redhat.com/show_bug.cgi?id=1992705 Signed-off-by: Numan Siddique --- lib/ovsdb-idl.c | 15 +++++++++++- tests/idltest.ovsschema | 9 +++++++ tests/idltest2.ovsschema | 7 ++++++ tests/ovsdb-idl.at | 26 ++++++++++++++++++++ tests/test-ovsdb.c | 53 ++++++++++++++++++++++++++++++++++++++++ 5 files changed, 109 insertions(+), 1 deletion(-) diff --git a/lib/ovsdb-idl.c b/lib/ovsdb-idl.c index b2dfff46c..8e4ce43b7 100644 --- a/lib/ovsdb-idl.c +++ b/lib/ovsdb-idl.c @@ -3382,6 +3382,12 @@ ovsdb_idl_txn_write__(const struct ovsdb_idl_row *row_, } class = row->table->class_; + + if (!ovsdb_idl_has_column_in_table(row->table->idl, class->name, + column->name)) { + goto discard_datum; + } + column_idx = column - class->columns; write_only = row->table->modes[column_idx] == OVSDB_IDL_MONITOR; @@ -3599,12 +3605,19 @@ ovsdb_idl_txn_delete(const struct ovsdb_idl_row *row_) * ovsdb-server. * * Usually this function is used indirectly through one of the "insert" - * functions generated by ovsdb-idlc. */ + * functions generated by ovsdb-idlc. + * + * Returns NULL if the table is not part of the idl schema. + * */ const struct ovsdb_idl_row * ovsdb_idl_txn_insert(struct ovsdb_idl_txn *txn, const struct ovsdb_idl_table_class *class, const struct uuid *uuid) { + if (!ovsdb_idl_has_table(txn->idl, class->name)) { + return NULL; + } + struct ovsdb_idl_row *row = ovsdb_idl_row_create__(class); if (uuid) { diff --git a/tests/idltest.ovsschema b/tests/idltest.ovsschema index 3ddb612b0..65eadb961 100644 --- a/tests/idltest.ovsschema +++ b/tests/idltest.ovsschema @@ -210,6 +210,15 @@ }, "isRoot": true }, + "simple7" : { + "columns" : { + "name" : { + "type": "string" + }, + "id": {"type": "string"} + }, + "isRoot" : true + }, "singleton" : { "columns" : { "name" : { diff --git a/tests/idltest2.ovsschema b/tests/idltest2.ovsschema index 210e4c389..a8199e56c 100644 --- a/tests/idltest2.ovsschema +++ b/tests/idltest2.ovsschema @@ -139,6 +139,13 @@ "type": "string" } } + }, + "simple7" : { + "columns" : { + "name" : { + "type": "string" + } + } } } } diff --git a/tests/ovsdb-idl.at b/tests/ovsdb-idl.at index b11fabe70..b3cf31af0 100644 --- a/tests/ovsdb-idl.at +++ b/tests/ovsdb-idl.at @@ -999,6 +999,7 @@ test-ovsdb|ovsdb_idl|idltest database lacks simple5 table (database needs upgrad test-ovsdb|ovsdb_idl|idltest database lacks simple6 table (database needs upgrade?) test-ovsdb|ovsdb_idl|idltest database lacks singleton table (database needs upgrade?) test-ovsdb|ovsdb_idl|link1 table in idltest database lacks l2 column (database needs upgrade?) +test-ovsdb|ovsdb_idl|simple7 table in idltest database lacks id column (database needs upgrade?) ]) # Check that ovsdb-idl sent on "monitor" request and that it didn't @@ -2410,3 +2411,28 @@ column l2 in table link1 is present OVSDB_SERVER_SHUTDOWN AT_CLEANUP + +AT_SETUP([idl transaction handling of missing tables and columns - C]) +AT_KEYWORDS([ovsdb client idl txn]) + +# idltest2.ovsschema is the same as idltest.ovsschema, except that +# few tables and columns are missing. This test checks that idl doesn't +# include the missing tables and columns in the transactions. +# idl-missing-table-column-txn inserts +# - a row for table - 'simple' +# - a row for table - 'simple5' which is missing. This should not be +# included in the transaction. +# - a row for table - 'simple7 with the missing column 'id'. + +AT_CHECK([ovsdb_start_idltest "" "$abs_srcdir/idltest2.ovsschema"]) +AT_CHECK([test-ovsdb '-vPATTERN:console:test-ovsdb|%c|%m' -vjsonrpc -t10 idl-missing-table-column-txn unix:socket], + [0], [stdout], [stderr]) +AT_CHECK([sort stdout | uuidfilt], [0], + [[000: After inserting simple, simple5 and simple7 +001: table simple7: name=simple7 id= uuid=<0> +001: table simple: i=0 r=0 b=false s=simple u=<1> ia=[] ra=[] ba=[] sa=[] ua=[] uuid=<2> +002: End test +]]) + +OVSDB_SERVER_SHUTDOWN +AT_CLEANUP diff --git a/tests/test-ovsdb.c b/tests/test-ovsdb.c index 462d2e57e..9353a5a43 100644 --- a/tests/test-ovsdb.c +++ b/tests/test-ovsdb.c @@ -2140,6 +2140,17 @@ print_idl_row_simple6(const struct idltest_simple6 *s6, int step) print_idl_row_updated_simple6(s6, step); } +static void +print_idl_row_simple7(const struct idltest_simple7 *s7, int step) +{ + struct ds msg = DS_EMPTY_INITIALIZER; + ds_put_format(&msg, "name=%s id=%s", s7->name, s7->id); + char *row_msg = format_idl_row(&s7->header_, step, ds_cstr(&msg)); + print_and_log("%s", row_msg); + ds_destroy(&msg); + free(row_msg); +} + static void print_idl_row_singleton(const struct idltest_singleton *sng, int step) { @@ -2164,6 +2175,7 @@ print_idl(struct ovsdb_idl *idl, int step) const struct idltest_link1 *l1; const struct idltest_link2 *l2; const struct idltest_singleton *sng; + const struct idltest_simple7 *s7; int n = 0; IDLTEST_SIMPLE_FOR_EACH (s, idl) { @@ -2194,6 +2206,10 @@ print_idl(struct ovsdb_idl *idl, int step) print_idl_row_singleton(sng, step); n++; } + IDLTEST_SIMPLE7_FOR_EACH (s7, idl) { + print_idl_row_simple7(s7, step); + n++; + } if (!n) { print_and_log("%03d: empty", step); } @@ -3339,6 +3355,41 @@ do_idl_table_column_check(struct ovs_cmdl_context *ctx) ovsdb_idl_destroy(idl); } +static void +do_idl_missing_table_column_txn(struct ovs_cmdl_context *ctx) +{ + struct ovsdb_idl *idl; + struct ovsdb_idl_txn *myTxn; + int step = 0; + + idl = ovsdb_idl_create(ctx->argv[1], &idltest_idl_class, true, true); + + ovsdb_idl_get_initial_snapshot(idl); + + ovsdb_idl_run(idl); + + /* Insert a row in simple2. */ + myTxn = ovsdb_idl_txn_create(idl); + struct idltest_simple *simple_row = idltest_simple_insert(myTxn); + idltest_simple_set_s(simple_row, "simple"); + + /* Insert a row in simple5. simple5 table doesn't exist. */ + struct idltest_simple5 *simple5_row = idltest_simple5_insert(myTxn); + ovs_assert(!simple5_row); + + struct idltest_simple7 *simple7_row = idltest_simple7_insert(myTxn); + idltest_simple7_set_name(simple7_row, "simple7"); + idltest_simple7_set_id(simple7_row, "simple7_id"); + + ovsdb_idl_txn_commit_block(myTxn); + ovsdb_idl_txn_destroy(myTxn); + ovsdb_idl_get_initial_snapshot(idl); + printf("%03d: After inserting simple, simple5 and simple7\n", step++); + print_idl(idl, step++); + ovsdb_idl_destroy(idl); + printf("%03d: End test\n", step); +} + static struct ovs_cmdl_command all_commands[] = { { "log-io", NULL, 2, INT_MAX, do_log_io, OVS_RO }, { "default-atoms", NULL, 0, 0, do_default_atoms, OVS_RO }, @@ -3379,6 +3430,8 @@ static struct ovs_cmdl_command all_commands[] = { do_idl_partial_update_set_column, OVS_RO }, { "idl-table-column-check", NULL, 1, INT_MAX, do_idl_table_column_check, OVS_RO }, + { "idl-missing-table-column-txn", NULL, 1, INT_MAX, + do_idl_missing_table_column_txn, OVS_RO }, { "help", NULL, 0, INT_MAX, do_help, OVS_RO }, { NULL, NULL, 0, 0, NULL, OVS_RO }, };