X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Futils_ovs.h;h=52c2f915ce62f55e65d6e001638cee2b5740048d;hb=711f5b6c86f51061c21bedcaa46214a01de0125c;hp=aa91e30a5f9dfd8a4b6604f8c3c443fa1fa24760;hpb=12f649741333f3b36d0f859800041674ad9e5011;p=collectd.git diff --git a/src/utils_ovs.h b/src/utils_ovs.h index aa91e30a..52c2f915 100644 --- a/src/utils_ovs.h +++ b/src/utils_ovs.h @@ -65,15 +65,15 @@ #ifndef UTILS_OVS_H #define UTILS_OVS_H -#include #include +#include /* Forward declaration */ typedef struct ovs_db_s ovs_db_t; /* OVS DB callback type declaration */ -typedef void (*ovs_db_table_cb_t) (yajl_val jupdates); -typedef void (*ovs_db_result_cb_t) (yajl_val jresult, yajl_val jerror); +typedef void (*ovs_db_table_cb_t)(yajl_val jupdates); +typedef void (*ovs_db_result_cb_t)(yajl_val jresult, yajl_val jerror); /* OVS DB structures */ struct ovs_db_callback_s { @@ -84,15 +84,20 @@ struct ovs_db_callback_s { * to subscribe to table update notification or poll * some OVS DB data. This field can be NULL. */ - void (*post_conn_init) (ovs_db_t *pdb); + void (*post_conn_init)(ovs_db_t *pdb); /* - * This callback is called when OVD DB connection + * This callback is called when OVS DB connection * has been lost. This field can be NULL. */ - void (*post_conn_terminate) (void); + void (*post_conn_terminate)(void); }; typedef struct ovs_db_callback_s ovs_db_callback_t; +/* OVS DB defines */ +#define OVS_DB_ADDR_NODE_SIZE 256 +#define OVS_DB_ADDR_SERVICE_SIZE 128 +#define OVS_DB_ADDR_UNIX_SIZE 108 + /* OVS DB prototypes */ /* @@ -104,13 +109,16 @@ typedef struct ovs_db_callback_s ovs_db_callback_t; * shall destroy the returned object. * * PARAMETERS - * `surl' OVS DB communication URL. + * `node' OVS DB Address. + * `service' OVS DB service name. + * `unix' OVS DB unix socket path. * `cb' OVS DB callbacks. * * RETURN VALUE * New ovs_db_t object upon success or NULL if an error occurred. */ -ovs_db_t *ovs_db_init(const char *surl, ovs_db_callback_t *cb); +ovs_db_t *ovs_db_init(const char *node, const char *service, + const char *unix_path, ovs_db_callback_t *cb); /* * NAME @@ -144,15 +152,15 @@ int ovs_db_destroy(ovs_db_t *pdb); * RETURN VALUE * Zero upon success or non-zero if an error occurred. */ -int ovs_db_send_request(ovs_db_t *pdb, const char *method, - const char *params, ovs_db_result_cb_t cb); +int ovs_db_send_request(ovs_db_t *pdb, const char *method, const char *params, + ovs_db_result_cb_t cb); /* callback types */ #define OVS_DB_TABLE_CB_FLAG_INITIAL 0x01U -#define OVS_DB_TABLE_CB_FLAG_INSERT 0x02U -#define OVS_DB_TABLE_CB_FLAG_DELETE 0x04U -#define OVS_DB_TABLE_CB_FLAG_MODIFY 0x08U -#define OVS_DB_TABLE_CB_FLAG_ALL 0x0FU +#define OVS_DB_TABLE_CB_FLAG_INSERT 0x02U +#define OVS_DB_TABLE_CB_FLAG_DELETE 0x04U +#define OVS_DB_TABLE_CB_FLAG_MODIFY 0x08U +#define OVS_DB_TABLE_CB_FLAG_ALL 0x0FU /* * NAME @@ -187,8 +195,7 @@ int ovs_db_send_request(ovs_db_t *pdb, const char *method, int ovs_db_table_cb_register(ovs_db_t *pdb, const char *tb_name, const char **tb_column, ovs_db_table_cb_t update_cb, - ovs_db_result_cb_t result_cb, - unsigned int flags); + ovs_db_result_cb_t result_cb, unsigned int flags); /* * OVS utils API