ovsdb/monitor.h

   1 /*
   2  * Copyright (c) 2015 Nicira, Inc.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at:
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 #ifndef OVSDB_MONITOR_H
  18 #define OVSDB_MONITOR_H
  19
  20 struct ovsdb_monitor;
  21
  22 enum ovsdb_monitor_selection {
  23     OJMS_INITIAL = 1 << 0,      /* All rows when monitor is created. */
  24     OJMS_INSERT = 1 << 1,       /* New rows. */
  25     OJMS_DELETE = 1 << 2,       /* Deleted rows. */
  26     OJMS_MODIFY = 1 << 3        /* Modified rows. */
  27 };
  28
  29
  30 struct ovsdb_monitor *ovsdb_monitor_create(struct ovsdb *db,
  31                        struct ovsdb_jsonrpc_monitor *jsonrpc_monitor);
  32
  33 struct ovsdb_monitor *ovsdb_monitor_add(struct ovsdb_monitor *dbmon);
  34
  35 void ovsdb_monitor_add_jsonrpc_monitor(struct ovsdb_monitor *dbmon,
  36                        struct ovsdb_jsonrpc_monitor *jsonrpc_monitor);
  37
  38 void ovsdb_monitor_remove_jsonrpc_monitor(struct ovsdb_monitor *dbmon,
  39                        struct ovsdb_jsonrpc_monitor *jsonrpc_monitor);
  40
  41 void ovsdb_monitor_remove_jsonrpc_monitor(struct ovsdb_monitor *dbmon,
  42                                struct ovsdb_jsonrpc_monitor *jsonrpc_monitor);
  43
  44 void ovsdb_monitor_add_table(struct ovsdb_monitor *m,
  45                              const struct ovsdb_table *table);
  46
  47 void ovsdb_monitor_add_column(struct ovsdb_monitor *dbmon,
  48                               const struct ovsdb_table *table,
  49                               const struct ovsdb_column *column,
  50                               enum ovsdb_monitor_selection select,
  51                               size_t *allocated_columns);
  52
  53 const char * OVS_WARN_UNUSED_RESULT
  54 ovsdb_monitor_table_check_duplicates(struct ovsdb_monitor *,
  55                           const struct ovsdb_table *);
  56
  57 struct json *ovsdb_monitor_compose_update(const struct ovsdb_monitor *dbmon,
  58                                 bool initial, uint64_t *unflushed_transaction);
  59
  60 void ovsdb_monitor_table_add_select(struct ovsdb_monitor *dbmon,
  61                                     const struct ovsdb_table *table,
  62                                     enum ovsdb_monitor_selection select);
  63
  64 bool ovsdb_monitor_needs_flush(struct ovsdb_monitor *dbmon,
  65                                uint64_t next_transaction);
  66
  67 void ovsdb_monitor_get_initial(const struct ovsdb_monitor *dbmon);
  68 #endif