1 /* Copyright (c) 2009 Nicira Networks
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at:
7 * http://www.apache.org/licenses/LICENSE-2.0
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
18 #include "ovsdb/column.h"
24 #include "ovsdb-error.h"
25 #include "ovsdb-parser.h"
30 ovsdb_column_create(const char *name, const char *comment,
31 bool mutable, bool persistent,
32 const struct ovsdb_type *type)
34 struct ovsdb_column *column;
36 column = xzalloc(sizeof *column);
37 column->name = xstrdup(name);
38 column->comment = comment ? xstrdup(comment) : NULL;
39 column->mutable = mutable;
40 column->persistent = persistent;
47 ovsdb_column_destroy(struct ovsdb_column *column)
50 free(column->comment);
55 ovsdb_column_from_json(const struct json *json, const char *name,
56 struct ovsdb_column **columnp)
58 const struct json *comment, *mutable, *ephemeral, *type_json;
59 struct ovsdb_error *error;
60 struct ovsdb_type type;
61 struct ovsdb_parser parser;
66 ovsdb_parser_init(&parser, json, "schema for column %s", name);
67 comment = ovsdb_parser_member(&parser, "comment", OP_STRING | OP_OPTIONAL);
68 mutable = ovsdb_parser_member(&parser, "mutable",
69 OP_TRUE | OP_FALSE | OP_OPTIONAL);
70 ephemeral = ovsdb_parser_member(&parser, "ephemeral",
71 OP_TRUE | OP_FALSE | OP_OPTIONAL);
72 type_json = ovsdb_parser_member(&parser, "type", OP_STRING | OP_OBJECT);
73 error = ovsdb_parser_finish(&parser);
78 error = ovsdb_type_from_json(&type, type_json);
83 persistent = ephemeral ? !json_boolean(ephemeral) : true;
84 *columnp = ovsdb_column_create(name,
85 comment ? json_string(comment) : NULL,
86 mutable ? json_boolean(mutable) : true,
92 ovsdb_column_to_json(const struct ovsdb_column *column)
94 struct json *json = json_object_create();
95 if (column->comment) {
96 json_object_put_string(json, "comment", column->comment);
98 if (!column->mutable) {
99 json_object_put(json, "mutable", json_boolean_create(false));
101 if (!column->persistent) {
102 json_object_put(json, "ephemeral", json_boolean_create(true));
104 json_object_put(json, "type", ovsdb_type_to_json(&column->type));
109 ovsdb_column_set_init(struct ovsdb_column_set *set)
112 set->n_columns = set->allocated_columns = 0;
116 ovsdb_column_set_destroy(struct ovsdb_column_set *set)
122 ovsdb_column_set_clone(struct ovsdb_column_set *new,
123 const struct ovsdb_column_set *old)
125 new->columns = xmemdup(old->columns,
126 old->n_columns * sizeof *old->columns);
127 new->n_columns = new->allocated_columns = old->n_columns;
131 ovsdb_column_set_from_json(const struct json *json,
132 const struct ovsdb_table *table,
133 struct ovsdb_column_set *set)
135 ovsdb_column_set_init(set);
137 struct shash_node *node;
139 SHASH_FOR_EACH (node, &table->schema->columns) {
140 const struct ovsdb_column *column = node->data;
141 ovsdb_column_set_add(set, column);
146 struct ovsdb_error *error = NULL;
149 if (json->type != JSON_ARRAY) {
153 /* XXX this is O(n**2) */
154 for (i = 0; i < json->u.array.n; i++) {
155 struct ovsdb_column *column;
158 if (json->u.array.elems[i]->type != JSON_STRING) {
162 s = json->u.array.elems[i]->u.string;
163 column = shash_find_data(&table->schema->columns, s);
165 error = ovsdb_syntax_error(json, NULL, "%s is not a valid "
168 } else if (ovsdb_column_set_contains(set, column->index)) {
171 ovsdb_column_set_add(set, column);
176 ovsdb_column_set_destroy(set);
177 ovsdb_column_set_init(set);
179 error = ovsdb_syntax_error(json, NULL, "array of distinct column "
187 ovsdb_column_set_to_json(const struct ovsdb_column_set *set)
192 json = json_array_create_empty();
193 for (i = 0; i < set->n_columns; i++) {
194 json_array_add(json, json_string_create(set->columns[i]->name));
200 ovsdb_column_set_add(struct ovsdb_column_set *set,
201 const struct ovsdb_column *column)
203 if (set->n_columns >= set->allocated_columns) {
204 set->columns = x2nrealloc(set->columns, &set->allocated_columns,
205 sizeof *set->columns);
207 set->columns[set->n_columns++] = column;
211 ovsdb_column_set_add_all(struct ovsdb_column_set *set,
212 const struct ovsdb_table *table)
214 struct shash_node *node;
216 SHASH_FOR_EACH (node, &table->schema->columns) {
217 const struct ovsdb_column *column = node->data;
218 ovsdb_column_set_add(set, column);
223 ovsdb_column_set_contains(const struct ovsdb_column_set *set,
224 unsigned int column_index)
228 for (i = 0; i < set->n_columns; i++) {
229 if (set->columns[i]->index == column_index) {
236 /* This comparison is sensitive to ordering of columns within a set, but that's
237 * good: the only existing caller wants to make sure that hash values are
238 * comparable, which is only true if column ordering is the same. */
240 ovsdb_column_set_equals(const struct ovsdb_column_set *a,
241 const struct ovsdb_column_set *b)
245 if (a->n_columns != b->n_columns) {
248 for (i = 0; i < a->n_columns; i++) {
249 if (a->columns[i] != b->columns[i]) {