- list_record(row, columns, n_columns, out);
-
- next_row: ;
- }
- free(columns);
-}
-
-static void
-pre_cmd_set(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const struct vsctl_table_class *table;
- int i;
-
- table = pre_get_table(ctx, table_name);
- for (i = 3; i < ctx->argc; i++) {
- pre_parse_column_key_value(ctx, ctx->argv[i], table);
- }
-}
-
-static void
-set_column(const struct vsctl_table_class *table,
- const struct ovsdb_idl_row *row, const char *arg,
- struct ovsdb_symbol_table *symtab)
-{
- const struct ovsdb_idl_column *column;
- char *key_string, *value_string;
- char *error;
-
- error = parse_column_key_value(arg, table, &column, &key_string,
- NULL, NULL, 0, &value_string);
- die_if_error(error);
- if (!value_string) {
- vsctl_fatal("%s: missing value", arg);
- }
-
- if (key_string) {
- union ovsdb_atom key, value;
- struct ovsdb_datum datum;
-
- if (column->type.value.type == OVSDB_TYPE_VOID) {
- vsctl_fatal("cannot specify key to set for non-map column %s",
- column->name);
- }
-
- die_if_error(ovsdb_atom_from_string(&key, &column->type.key,
- key_string, symtab));
- die_if_error(ovsdb_atom_from_string(&value, &column->type.value,
- value_string, symtab));
-
- ovsdb_datum_init_empty(&datum);
- ovsdb_datum_add_unsafe(&datum, &key, &value, &column->type);
-
- ovsdb_atom_destroy(&key, column->type.key.type);
- ovsdb_atom_destroy(&value, column->type.value.type);
-
- ovsdb_datum_union(&datum, ovsdb_idl_read(row, column),
- &column->type, false);
- ovsdb_idl_txn_write(row, column, &datum);
- } else {
- struct ovsdb_datum datum;
-
- die_if_error(ovsdb_datum_from_string(&datum, &column->type,
- value_string, symtab));
- ovsdb_idl_txn_write(row, column, &datum);
- }
-
- free(key_string);
- free(value_string);
-}
-
-static void
-cmd_set(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const char *record_id = ctx->argv[2];
- const struct vsctl_table_class *table;
- const struct ovsdb_idl_row *row;
- int i;
-
- table = get_table(table_name);
- row = must_get_row(ctx, table, record_id);
- for (i = 3; i < ctx->argc; i++) {
- set_column(table, row, ctx->argv[i], ctx->symtab);
- }
-}
-
-static void
-pre_cmd_add(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const char *column_name = ctx->argv[3];
- const struct vsctl_table_class *table;
- const struct ovsdb_idl_column *column;
-
- table = pre_get_table(ctx, table_name);
- pre_get_column(ctx, table, column_name, &column);
-}
-
-static void
-cmd_add(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const char *record_id = ctx->argv[2];
- const char *column_name = ctx->argv[3];
- const struct vsctl_table_class *table;
- const struct ovsdb_idl_column *column;
- const struct ovsdb_idl_row *row;
- const struct ovsdb_type *type;
- struct ovsdb_datum old;
- int i;
-
- table = get_table(table_name);
- row = must_get_row(ctx, table, record_id);
- die_if_error(get_column(table, column_name, &column));
-
- type = &column->type;
- ovsdb_datum_clone(&old, ovsdb_idl_read(row, column), &column->type);
- for (i = 4; i < ctx->argc; i++) {
- struct ovsdb_type add_type;
- struct ovsdb_datum add;
-
- add_type = *type;
- add_type.n_min = 1;
- add_type.n_max = UINT_MAX;
- die_if_error(ovsdb_datum_from_string(&add, &add_type, ctx->argv[i],
- ctx->symtab));
- ovsdb_datum_union(&old, &add, type, false);
- ovsdb_datum_destroy(&add, type);
- }
- if (old.n > type->n_max) {
- vsctl_fatal("\"add\" operation would put %u %s in column %s of "
- "table %s but the maximum number is %u",
- old.n,
- type->value.type == OVSDB_TYPE_VOID ? "values" : "pairs",
- column->name, table->class->name, type->n_max);
- }
- ovsdb_idl_txn_verify(row, column);
- ovsdb_idl_txn_write(row, column, &old);
-}
-
-static void
-pre_cmd_remove(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const char *column_name = ctx->argv[3];
- const struct vsctl_table_class *table;
- const struct ovsdb_idl_column *column;
-
- table = pre_get_table(ctx, table_name);
- pre_get_column(ctx, table, column_name, &column);
-}
-
-static void
-cmd_remove(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const char *record_id = ctx->argv[2];
- const char *column_name = ctx->argv[3];
- const struct vsctl_table_class *table;
- const struct ovsdb_idl_column *column;
- const struct ovsdb_idl_row *row;
- const struct ovsdb_type *type;
- struct ovsdb_datum old;
- int i;
-
- table = get_table(table_name);
- row = must_get_row(ctx, table, record_id);
- die_if_error(get_column(table, column_name, &column));
-
- type = &column->type;
- ovsdb_datum_clone(&old, ovsdb_idl_read(row, column), &column->type);
- for (i = 4; i < ctx->argc; i++) {
- struct ovsdb_type rm_type;
- struct ovsdb_datum rm;
- char *error;
-
- rm_type = *type;
- rm_type.n_min = 1;
- rm_type.n_max = UINT_MAX;
- error = ovsdb_datum_from_string(&rm, &rm_type,
- ctx->argv[i], ctx->symtab);
- if (error && ovsdb_type_is_map(&rm_type)) {
- free(error);
- rm_type.value.type = OVSDB_TYPE_VOID;
- die_if_error(ovsdb_datum_from_string(&rm, &rm_type,
- ctx->argv[i], ctx->symtab));
- }
- ovsdb_datum_subtract(&old, type, &rm, &rm_type);
- ovsdb_datum_destroy(&rm, &rm_type);
- }
- if (old.n < type->n_min) {
- vsctl_fatal("\"remove\" operation would put %u %s in column %s of "
- "table %s but the minimum number is %u",
- old.n,
- type->value.type == OVSDB_TYPE_VOID ? "values" : "pairs",
- column->name, table->class->name, type->n_min);
- }
- ovsdb_idl_txn_verify(row, column);
- ovsdb_idl_txn_write(row, column, &old);
-}
-
-static void
-pre_cmd_clear(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const struct vsctl_table_class *table;
- int i;
-
- table = pre_get_table(ctx, table_name);
- for (i = 3; i < ctx->argc; i++) {
- const struct ovsdb_idl_column *column;
-
- pre_get_column(ctx, table, ctx->argv[i], &column);
- }
-}
-
-static void
-cmd_clear(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const char *record_id = ctx->argv[2];
- const struct vsctl_table_class *table;
- const struct ovsdb_idl_row *row;
- int i;
-
- table = get_table(table_name);
- row = must_get_row(ctx, table, record_id);
- for (i = 3; i < ctx->argc; i++) {
- const struct ovsdb_idl_column *column;
- const struct ovsdb_type *type;
- struct ovsdb_datum datum;
-
- die_if_error(get_column(table, ctx->argv[i], &column));
-
- type = &column->type;
- if (type->n_min > 0) {
- vsctl_fatal("\"clear\" operation cannot be applied to column %s "
- "of table %s, which is not allowed to be empty",
- column->name, table->class->name);
- }
-
- ovsdb_datum_init_empty(&datum);
- ovsdb_idl_txn_write(row, column, &datum);
- }
-}
-
-static void
-pre_create(struct vsctl_context *ctx)
-{
- const char *id = shash_find_data(&ctx->options, "--id");
- const char *table_name = ctx->argv[1];
- const struct vsctl_table_class *table;
-
- table = get_table(table_name);
- if (!id && !table->class->is_root) {
- VLOG_WARN("applying \"create\" command to table %s without --id "
- "option will have no effect", table->class->name);
- }
-}
-
-static void
-cmd_create(struct vsctl_context *ctx)
-{
- const char *id = shash_find_data(&ctx->options, "--id");
- const char *table_name = ctx->argv[1];
- const struct vsctl_table_class *table = get_table(table_name);
- const struct ovsdb_idl_row *row;
- const struct uuid *uuid;
- int i;
-
- if (id) {
- struct ovsdb_symbol *symbol = create_symbol(ctx->symtab, id, NULL);
- if (table->class->is_root) {
- /* This table is in the root set, meaning that rows created in it
- * won't disappear even if they are unreferenced, so disable
- * warnings about that by pretending that there is a reference. */
- symbol->strong_ref = true;
- }
- uuid = &symbol->uuid;
- } else {
- uuid = NULL;
- }
-
- row = ovsdb_idl_txn_insert(ctx->txn, table->class, uuid);
- for (i = 2; i < ctx->argc; i++) {
- set_column(table, row, ctx->argv[i], ctx->symtab);
- }
- ds_put_format(&ctx->output, UUID_FMT, UUID_ARGS(&row->uuid));
-}
-
-/* This function may be used as the 'postprocess' function for commands that
- * insert new rows into the database. It expects that the command's 'run'
- * function prints the UUID reported by ovsdb_idl_txn_insert() as the command's
- * sole output. It replaces that output by the row's permanent UUID assigned
- * by the database server and appends a new-line.
- *
- * Currently we use this only for "create", because the higher-level commands
- * are supposed to be independent of the actual structure of the vswitch
- * configuration. */
-static void
-post_create(struct vsctl_context *ctx)
-{
- const struct uuid *real;
- struct uuid dummy;
-
- if (!uuid_from_string(&dummy, ds_cstr(&ctx->output))) {
- NOT_REACHED();
- }
- real = ovsdb_idl_txn_get_insert_uuid(ctx->txn, &dummy);
- if (real) {
- ds_clear(&ctx->output);
- ds_put_format(&ctx->output, UUID_FMT, UUID_ARGS(real));
- }
- ds_put_char(&ctx->output, '\n');
-}
-
-static void
-pre_cmd_destroy(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
-
- pre_get_table(ctx, table_name);
-}
-
-static void
-cmd_destroy(struct vsctl_context *ctx)
-{
- bool must_exist = !shash_find(&ctx->options, "--if-exists");
- const char *table_name = ctx->argv[1];
- const struct vsctl_table_class *table;
- int i;
-
- table = get_table(table_name);
- for (i = 2; i < ctx->argc; i++) {
- const struct ovsdb_idl_row *row;
-
- row = (must_exist ? must_get_row : get_row)(ctx, table, ctx->argv[i]);
- if (row) {
- ovsdb_idl_txn_delete(row);
- }
- }
-}
-
-#define RELOPS \
- RELOP(RELOP_EQ, "=") \
- RELOP(RELOP_NE, "!=") \
- RELOP(RELOP_LT, "<") \
- RELOP(RELOP_GT, ">") \
- RELOP(RELOP_LE, "<=") \
- RELOP(RELOP_GE, ">=") \
- RELOP(RELOP_SET_EQ, "{=}") \
- RELOP(RELOP_SET_NE, "{!=}") \
- RELOP(RELOP_SET_LT, "{<}") \
- RELOP(RELOP_SET_GT, "{>}") \
- RELOP(RELOP_SET_LE, "{<=}") \
- RELOP(RELOP_SET_GE, "{>=}")
-
-enum relop {
-#define RELOP(ENUM, STRING) ENUM,
- RELOPS
-#undef RELOP
-};
-
-static bool
-is_set_operator(enum relop op)
-{
- return (op == RELOP_SET_EQ || op == RELOP_SET_NE ||
- op == RELOP_SET_LT || op == RELOP_SET_GT ||
- op == RELOP_SET_LE || op == RELOP_SET_GE);
-}
-
-static bool
-evaluate_relop(const struct ovsdb_datum *a, const struct ovsdb_datum *b,
- const struct ovsdb_type *type, enum relop op)
-{
- switch (op) {
- case RELOP_EQ:
- case RELOP_SET_EQ:
- return ovsdb_datum_compare_3way(a, b, type) == 0;
- case RELOP_NE:
- case RELOP_SET_NE:
- return ovsdb_datum_compare_3way(a, b, type) != 0;
- case RELOP_LT:
- return ovsdb_datum_compare_3way(a, b, type) < 0;
- case RELOP_GT:
- return ovsdb_datum_compare_3way(a, b, type) > 0;
- case RELOP_LE:
- return ovsdb_datum_compare_3way(a, b, type) <= 0;
- case RELOP_GE:
- return ovsdb_datum_compare_3way(a, b, type) >= 0;
-
- case RELOP_SET_LT:
- return b->n > a->n && ovsdb_datum_includes_all(a, b, type);
- case RELOP_SET_GT:
- return a->n > b->n && ovsdb_datum_includes_all(b, a, type);
- case RELOP_SET_LE:
- return ovsdb_datum_includes_all(a, b, type);
- case RELOP_SET_GE:
- return ovsdb_datum_includes_all(b, a, type);
-
- default:
- NOT_REACHED();