[ovs-dev] [PATCH monitor_cond V4 14/17] ovsdb: Implement data structure to hold changed rows that matchs condition's clauses
Liran Schour
lirans at il.ibm.com
Thu Feb 18 11:46:52 UTC 2016
This patch implements a data structure to hold all changed rows that match's any
condition's clauses with function "==" in this ovsdb_monitor_table.
This data structure will be used only for sessions that have maximal
clause function of "==" (which is the most common case in conditional monitoring).
We want to achieve O(#clauses) in insertion of new changed row and O(#sent changes)
in composing update message.
Signed-off-by: Liran Schour <lirans at il.ibm.com>
---
ovsdb/monitor.c | 179 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 179 insertions(+)
diff --git a/ovsdb/monitor.c b/ovsdb/monitor.c
index 9c907ef..cc89f6a 100644
--- a/ovsdb/monitor.c
+++ b/ovsdb/monitor.c
@@ -102,6 +102,13 @@ struct ovsdb_monitor_column {
enum ovsdb_monitor_selection select;
bool monitored;
};
+/* Conditional tracked column */
+struct ovsdb_tracked_clauses {
+ const struct ovsdb_column *column;
+ /* Contains 'ovsdb_monitor_changes' indexed by datum hash. */
+ struct hmap changes;
+};
+
struct ovsdb_monitor_data {
struct ovs_list node;
uint64_t transaction;
@@ -164,6 +171,9 @@ struct ovsdb_monitor_table {
struct hmap json_cache;
/* Contains 'ovsdb_monitor_changes' indexed by 'transaction'. */
struct hmap changes;
+ bool track_columns;
+ /* Contains ovsdb_tracked_clauses * */
+ struct shash trk_clauses;
};
enum ovsdb_monitor_row_type {
@@ -439,6 +449,7 @@ ovsdb_monitor_add_table(struct ovsdb_monitor *m,
shash_add(&m->tables, table->schema->name, mt);
hmap_init(&mt->changes);
hmap_init(&mt->json_cache);
+ shash_init(&mt->trk_clauses);
mt->columns_index_map =
xmalloc(sizeof(unsigned int) * shash_count(&table->schema->columns));
for (i = 0; i < shash_count(&table->schema->columns); i++) {
@@ -516,6 +527,96 @@ ovsdb_monitor_condition_add_columns(struct ovsdb_monitor *dbmon,
}
}
+/* Clause function should be OVSDB_F_EQ OR OVSDB_F_INCLUDES
+ * add this clause to trk_columns */
+static void
+add_tracked_clause(struct ovsdb_monitor_table *mt, struct ovsdb_clause *c)
+{
+ struct ovsdb_monitor_changes *changes;
+ size_t hash = ovsdb_datum_hash(&c->arg, &c->column->type, 0);
+ struct ovsdb_tracked_clauses *column = shash_find_data(&mt->trk_clauses, c->column->name);
+
+ if (!column) {
+ column = xmalloc(sizeof *column);
+ column->column = c->column;
+ hmap_init(&column->changes);
+ shash_add(&mt->trk_clauses, c->column->name, column);
+ }
+
+ HMAP_FOR_EACH_WITH_HASH(changes, hmap_node, hash, &column->changes) {
+ if (ovsdb_datum_equals(&c->arg, &changes->arg, &c->column->type)) {
+ changes->n_refs++;
+ return;
+ }
+ }
+
+ changes = xzalloc(sizeof *changes);
+ changes->mt = mt;
+ changes->n_refs = 1;
+ ovsdb_datum_clone(&changes->arg, &c->arg, &c->column->type);
+ changes->type = &c->column->type;
+ hmap_init(&changes->rows);
+ hmap_insert(&column->changes, &changes->hmap_node, hash);
+}
+
+static void
+remove_tracked_clause(struct ovsdb_monitor_table *mt, struct ovsdb_clause *c)
+{
+ struct ovsdb_monitor_changes *changes;
+ size_t hash = ovsdb_datum_hash(&c->arg, &c->column->type, 0);
+ struct ovsdb_tracked_clauses *column = shash_find_data(&mt->trk_clauses, c->column->name);
+
+ ovs_assert(column);
+
+ HMAP_FOR_EACH_WITH_HASH(changes, hmap_node, hash, &column->changes) {
+ if (ovsdb_datum_equals(&c->arg, &changes->arg, &c->column->type)) {
+ if (--changes->n_refs == 0) {
+ hmap_remove(&column->changes, &changes->hmap_node);
+ ovsdb_monitor_changes_destroy(changes);
+ if (hmap_is_empty(&column->changes)) {
+ shash_delete(&mt->trk_clauses,
+ shash_find_data(&mt->trk_clauses,
+ c->column->name));
+ free(column);
+ }
+ return;
+ }
+ }
+ }
+
+ OVS_NOT_REACHED();
+}
+
+static void
+ovsdb_monitor_condition_update_tracking(struct ovsdb_monitor_table *mt,
+ struct ovsdb_condition *old,
+ struct ovsdb_condition *new)
+{
+ struct ovsdb_condition *added, a = OVSDB_CONDITION_INITIALIZER;
+ struct ovsdb_condition *removed, b = OVSDB_CONDITION_INITIALIZER;
+ int i;
+
+ if (!new) {
+ added = old;
+ removed = NULL;
+ } else {
+ added = &a;
+ removed = &b;
+ ovsdb_conditon_diff(old, new, added, removed);
+ }
+
+ for (i = 0; i < added->n_clauses; i++) {
+ if (added->clauses[i].function > OVSDB_F_TRUE) {
+ add_tracked_clause(mt, &added->clauses[i]);
+ }
+ }
+ for (i = 0; removed && i < removed->n_clauses; i++) {
+ if (removed->clauses[i].function > OVSDB_F_TRUE) {
+ remove_tracked_clause(mt, &removed->clauses[i]);
+ }
+ }
+}
+
void
ovsdb_monitor_condition_bind(struct ovsdb_monitor *dbmon,
struct ovsdb_monitor_session_condition *cond)
@@ -630,6 +731,84 @@ ovsdb_monitor_table_track_changes(struct ovsdb_monitor_table *mt,
}
}
+static struct ovsdb_monitor_changes *
+ovsdb_monitor_table_find_clause_changes(
+ struct ovsdb_monitor_table_condition *mtc,
+ struct ovsdb_clause *clause)
+{
+ struct ovsdb_monitor_table *mt = mtc->mt;
+ size_t hash = ovsdb_datum_hash(&clause->arg, &clause->column->type, 0);
+ struct ovsdb_tracked_clauses *column;
+
+ if (clause->function == OVSDB_F_FALSE) {
+ return NULL;
+ }
+ ovs_assert(clause->function == OVSDB_F_EQ ||
+ clause->function == OVSDB_F_INCLUDES);
+
+ column = shash_find_data(&mt->trk_clauses, clause->column->name);
+ ovs_assert(column);
+
+ struct ovsdb_monitor_changes *changes;
+ HMAP_FOR_EACH_WITH_HASH(changes, hmap_node, hash, &column->changes) {
+ if (ovsdb_datum_equals(&clause->arg, &changes->arg,
+ &clause->column->type)) {
+ break;
+ }
+ }
+
+ return changes;
+}
+
+static void
+ovsdb_monitor_clauses_track_update(const struct ovsdb_row *old,
+ const struct ovsdb_row *new,
+ struct ovsdb_monitor_table *mt)
+{
+ //struct ovsdb_monitor_txn_id *trk;
+ /* First element in list is minimal tracked transaction */
+ //INIT_CONTAINER(trk, &mt->tracked_txns, node);
+ struct shash_node *node;
+ struct ovsdb_monitor_changes *changes;
+ //uint64_t unflushed = trk->txn_id;
+
+ /* Insert row to tracked columns */
+ SHASH_FOR_EACH(node, &mt->trk_clauses) {
+ struct ovsdb_tracked_clauses *c = node->data;
+ size_t hash;
+
+ if (old) {
+ hash = ovsdb_datum_hash(&old->fields[c->column->index],
+ &c->column->type, 0);
+
+ HMAP_FOR_EACH_WITH_HASH(changes, hmap_node, hash, &c->changes) {
+ if (ovsdb_datum_equals(&old->fields[c->column->index],
+ &changes->arg, &c->column->type)) {
+ ovsdb_monitor_changes_update(old, new, mt, changes,
+ mt->dbmon->n_transactions + 1);
+ }
+ }
+ }
+ if (new) {
+ if (old && ovsdb_datum_equals(&old->fields[c->column->index],
+ &new->fields[c->column->index],
+ &c->column->type)) {
+ continue;
+ }
+ hash = ovsdb_datum_hash(&new->fields[c->column->index],
+ &c->column->type, 0);
+ HMAP_FOR_EACH_WITH_HASH(changes, hmap_node, hash, &c->changes) {
+ /* Insert to changes if old or new match match datum */
+ if (ovsdb_datum_equals(&new->fields[c->column->index],
+ &changes->arg, &c->column->type)) {
+ ovsdb_monitor_changes_update(old, new, mt, changes,
+ mt->dbmon->n_transactions + 1);
+ }
+ }
+ }
+ }
+}
+
static void
ovsdb_monitor_changes_destroy(struct ovsdb_monitor_changes *changes)
{
--
2.1.4
More information about the dev
mailing list