summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSander Vrijders <sander.vrijders@intec.ugent.be>2016-11-29 14:59:42 +0100
committerSander Vrijders <sander.vrijders@intec.ugent.be>2016-11-29 14:59:42 +0100
commit959882e45f430e59d089bf34ed455afafa08cf29 (patch)
treeadc5383864952de115bf84cf993ffef5e71d9fdf
parent60a6970f4d004a3bdaedc5af4e1581890ab9b462 (diff)
downloadouroboros-959882e45f430e59d089bf34ed455afafa08cf29.tar.gz
ouroboros-959882e45f430e59d089bf34ed455afafa08cf29.zip
ipcpd: normal: Change ro_attr initialization
This changes the way RIB object attributes are set. Previously the struct was called ro_props and it had to be allocated on the heap. Now it follows the model of pthreads closely. This commit also changes the callbacks of the RO subscribers to return void instead of int.
-rw-r--r--src/ipcpd/normal/pol/flat.c77
-rw-r--r--src/ipcpd/normal/ribmgr.c148
-rw-r--r--src/ipcpd/normal/ro.h28
3 files changed, 109 insertions, 144 deletions
diff --git a/src/ipcpd/normal/pol/flat.c b/src/ipcpd/normal/pol/flat.c
index 4946d538..544d4f7e 100644
--- a/src/ipcpd/normal/pol/flat.c
+++ b/src/ipcpd/normal/pol/flat.c
@@ -76,8 +76,7 @@ static char * my_name(void)
return name;
}
-/* FIXME: We should return void */
-static int ro_created(const char * name,
+static void ro_created(const char * name,
uint8_t * data,
size_t len)
{
@@ -93,13 +92,11 @@ static int ro_created(const char * name,
msg->code = FLAT_ADDR_REPLY;
ro_write(name, data, len);
}
-
- return 0;
}
-static int ro_updated(const char * name,
- uint8_t * data,
- size_t len)
+static void ro_updated(const char * name,
+ uint8_t * data,
+ size_t len)
{
struct flat_addr_msg * msg;
char * ro_name;
@@ -109,8 +106,10 @@ static int ro_updated(const char * name,
assert(len >= sizeof(*msg));
ro_name = my_name();
- if (ro_name == NULL)
- return -1;
+ if (ro_name == NULL) {
+ free(data);
+ return;
+ }
msg = (struct flat_addr_msg *) data;
if (msg->code == FLAT_ADDR_REPLY &&
@@ -123,8 +122,6 @@ static int ro_updated(const char * name,
free(data);
free(ro_name);
-
- return 0;
}
static struct ro_sub_ops flat_sub_ops = {
@@ -135,16 +132,13 @@ static struct ro_sub_ops flat_sub_ops = {
int flat_init(void)
{
- struct ro_props * props;
+ struct ro_attr rattr;
pthread_condattr_t cattr;
srand(time(NULL));
flat.addr_in_use = false;
- props = malloc(sizeof(*props));
- if (props == NULL)
- return -ENOMEM;
-
+ ro_attr_init(&rattr);
pthread_mutex_init(&flat.lock, NULL);
pthread_condattr_init(&cattr);
#ifndef __APPLE__
@@ -158,20 +152,13 @@ int flat_init(void)
LOG_ERR("Could not subscribe to RIB.");
pthread_cond_destroy(&flat.cond);
pthread_mutex_destroy(&flat.lock);
- free(props);
return -1;
}
- props->enrol_sync = false;
- props->recv_set = NO_SYNC;
- props->expiry.tv_sec = 0;
- props->expiry.tv_nsec = 0;
-
- if (ro_create(POL_RO_ROOT, props, NULL, 0)) {
+ if (ro_create(POL_RO_ROOT, &rattr, NULL, 0)) {
LOG_ERR("Could not create RO.");
pthread_cond_destroy(&flat.cond);
pthread_mutex_destroy(&flat.lock);
- free(props);
ro_unsubscribe(flat.sid);
return -1;
}
@@ -189,16 +176,16 @@ int flat_fini(void)
uint64_t flat_address(void)
{
- int ret = 0;
- uint64_t max_addr;
- struct dt_const * dtc;
- struct timespec timeout = {(TIMEOUT / 1000),
- (TIMEOUT % 1000) * MILLION};
- struct timespec abstime;
- struct ro_props * props;
+ int ret = 0;
+ uint64_t max_addr;
+ struct dt_const * dtc;
+ struct timespec timeout = {(TIMEOUT / 1000),
+ (TIMEOUT % 1000) * MILLION};
+ struct timespec abstime;
+ struct ro_attr attr;
struct flat_addr_msg * msg;
- uint8_t * buf;
- char * ro_name;
+ uint8_t * buf;
+ char * ro_name;
dtc = ribmgr_dt_const();
if (dtc == NULL)
@@ -211,21 +198,14 @@ uint64_t flat_address(void)
max_addr = (1 << (8 * dtc->addr_size)) - 1;
flat.addr = (rand() % (max_addr - 1)) + 1;
- /* FIXME: We must change this to stack memory */
- props = malloc(sizeof(*props));
- if (props == NULL)
- return INVALID_ADDR;
-
- props->enrol_sync = false;
- props->recv_set = ALL_MEMBERS;
- props->expiry.tv_sec = TIMEOUT / 1000;
- props->expiry.tv_nsec = (TIMEOUT % 1000) * MILLION;
+ ro_attr_init(&attr);
+ attr.recv_set = ALL_MEMBERS;
+ attr.expiry.tv_sec = TIMEOUT / 1000;
+ attr.expiry.tv_nsec = (TIMEOUT % 1000) * MILLION;
buf = malloc(sizeof(*msg));
- if (buf == NULL) {
- free(props);
+ if (buf == NULL)
return INVALID_ADDR;
- }
msg = (struct flat_addr_msg *) buf;
msg->code = FLAT_ADDR_REQ;
@@ -233,15 +213,12 @@ uint64_t flat_address(void)
/* FIXME: We may require functions to construct pathnames */
ro_name = my_name();
- if (ro_name == NULL) {
- free(props);
+ if (ro_name == NULL)
return INVALID_ADDR;
- }
pthread_mutex_lock(&flat.lock);
- if (ro_create(ro_name, props, buf, sizeof(*msg))) {
+ if (ro_create(ro_name, &attr, buf, sizeof(*msg))) {
pthread_mutex_unlock(&flat.lock);
- free(props);
free(ro_name);
return INVALID_ADDR;
}
diff --git a/src/ipcpd/normal/ribmgr.c b/src/ipcpd/normal/ribmgr.c
index 79422909..5f9ea301 100644
--- a/src/ipcpd/normal/ribmgr.c
+++ b/src/ipcpd/normal/ribmgr.c
@@ -64,9 +64,9 @@ typedef RoMsg ro_msg_t;
/* RIB objects */
struct rnode {
- char * name;
- char * full_name;
- uint64_t seqno;
+ char * name;
+ char * full_name;
+ uint64_t seqno;
/*
* NOTE: Naive implementation for now, could be replaced by
@@ -75,12 +75,12 @@ struct rnode {
*/
/* If there are no children, this is a leaf */
- struct rnode * child;
- struct rnode * sibling;
+ struct rnode * child;
+ struct rnode * sibling;
- struct ro_props * props;
- uint8_t * data;
- size_t len;
+ struct ro_attr attr;
+ uint8_t * data;
+ size_t len;
};
struct mgmt_flow {
@@ -129,9 +129,9 @@ struct {
struct addr_auth * addr_auth;
} rib;
-int ribmgr_ro_created(const char * name,
- uint8_t * data,
- size_t len)
+void ribmgr_ro_created(const char * name,
+ uint8_t * data,
+ size_t len)
{
static_info_msg_t * stat_msg;
@@ -145,7 +145,7 @@ int ribmgr_ro_created(const char * name,
ipcp_set_state(IPCP_INIT);
pthread_rwlock_unlock(&ipcpi.state_lock);
LOG_ERR("Failed to unpack static info message.");
- return -1;
+ return;
}
rib.dtc.addr_size = stat_msg->addr_size;
@@ -163,7 +163,7 @@ int ribmgr_ro_created(const char * name,
pthread_rwlock_unlock(&ipcpi.state_lock);
static_info_msg__free_unpacked(stat_msg, NULL);
LOG_ERR("Failed to create address authority");
- return -1;
+ return;
}
rib.address = rib.addr_auth->address();
@@ -174,14 +174,12 @@ int ribmgr_ro_created(const char * name,
pthread_rwlock_unlock(&ipcpi.state_lock);
static_info_msg__free_unpacked(stat_msg, NULL);
LOG_ERR("Failed to init FRCT");
- return -1;
+ return;
}
static_info_msg__free_unpacked(stat_msg, NULL);
}
pthread_rwlock_unlock(&ipcpi.state_lock);
-
- return 0;
}
/* We only have a create operation for now */
@@ -234,10 +232,10 @@ static int ro_msg_create(struct rnode * node,
{
msg->address = rib.address;
msg->seqno = node->seqno;
- msg->recv_set = node->props->recv_set;
- msg->enrol_sync = node->props->enrol_sync;
- msg->sec = node->props->expiry.tv_sec;
- msg->nsec = node->props->expiry.tv_nsec;
+ msg->recv_set = node->attr.recv_set;
+ msg->enrol_sync = node->attr.enrol_sync;
+ msg->sec = node->attr.expiry.tv_sec;
+ msg->nsec = node->attr.expiry.tv_nsec;
msg->value.data = node->data;
msg->value.len = node->len;
@@ -319,10 +317,10 @@ static void ro_delete_timer(void * o)
}
}
-static struct rnode * ribmgr_ro_create(const char * name,
- struct ro_props * props,
- uint8_t * data,
- size_t len)
+static struct rnode * ribmgr_ro_create(const char * name,
+ struct ro_attr attr,
+ uint8_t * data,
+ size_t len)
{
char * str;
char * str1;
@@ -397,7 +395,7 @@ static struct rnode * ribmgr_ro_create(const char * name,
}
new->seqno = 0;
- new->props = props;
+ new->attr = attr;
if (sibling)
prev->sibling = new;
@@ -411,10 +409,10 @@ static struct rnode * ribmgr_ro_create(const char * name,
LOG_DBG("Created RO with name %s.", name);
- if (!(props->expiry.tv_sec == 0 &&
- props->expiry.tv_nsec == 0)) {
- timeout = props->expiry.tv_sec * 1000 +
- props->expiry.tv_nsec / MILLION;
+ if (!(attr.expiry.tv_sec == 0 &&
+ attr.expiry.tv_nsec == 0)) {
+ timeout = attr.expiry.tv_sec * 1000 +
+ attr.expiry.tv_nsec / MILLION;
if (timerwheel_add(rib.wheel, ro_delete_timer,
new->full_name, strlen(new->full_name),
timeout)) {
@@ -737,18 +735,14 @@ static int ribmgr_cdap_create(struct cdap * instance,
struct list_head * p = NULL;
size_t len_s, len_n;
uint8_t * ro_data;
- struct ro_props * props;
+ struct ro_attr attr;
struct rnode * node;
- props = malloc(sizeof(*props));
- if (props == NULL) {
- cdap_send_reply(instance, invoke_id, -1, NULL, 0);
- return -ENOMEM;
- }
-
- props->expiry.tv_sec = msg->sec;
- props->expiry.tv_nsec = msg->nsec;
- props->enrol_sync = msg->enrol_sync;
+ ro_attr_init(&attr);
+ attr.expiry.tv_sec = msg->sec;
+ attr.expiry.tv_nsec = msg->nsec;
+ attr.enrol_sync = msg->enrol_sync;
+ attr.recv_set = msg->recv_set;
pthread_mutex_lock(&rib.ro_lock);
@@ -756,16 +750,14 @@ static int ribmgr_cdap_create(struct cdap * instance,
if (ro_data == NULL) {
pthread_mutex_unlock(&rib.ro_lock);
cdap_send_reply(instance, invoke_id, -1, NULL, 0);
- free(props);
return -1;
}
memcpy(ro_data, msg->value.data, msg->value.len);
- node = ribmgr_ro_create(name, props, ro_data, msg->value.len);
+ node = ribmgr_ro_create(name, attr, ro_data, msg->value.len);
if (node == NULL) {
pthread_mutex_unlock(&rib.ro_lock);
cdap_send_reply(instance, invoke_id, -1, NULL, 0);
- free(props);
free(ro_data);
return -1;
}
@@ -922,7 +914,7 @@ static int ribmgr_enrol_sync(struct cdap * instance,
int ret = 0;
if (node != NULL) {
- if (node->props->enrol_sync == true) {
+ if (node->attr.enrol_sync == true) {
ro_msg_t msg = RO_MSG__INIT;
if (ro_msg_create(node, &msg)) {
@@ -1267,7 +1259,7 @@ int ribmgr_bootstrap(struct dif_config * conf)
static_info_msg_t stat_info = STATIC_INFO_MSG__INIT;
uint8_t * data = NULL;
size_t len = 0;
- struct ro_props * props;
+ struct ro_attr attr;
if (conf == NULL ||
conf->type != IPCP_NORMAL) {
@@ -1275,20 +1267,11 @@ int ribmgr_bootstrap(struct dif_config * conf)
return -1;
}
- props = malloc(sizeof(*props));
- if (props == NULL) {
- LOG_ERR("Failed to allocate memory.");
- return -1;
- }
+ ro_attr_init(&attr);
+ attr.enrol_sync = true;
- props->enrol_sync = true;
- props->recv_set = NEIGHBORS;
- props->expiry.tv_sec = 0;
- props->expiry.tv_nsec = 0;
-
- if (ribmgr_ro_create(RIBMGR_PREFIX, props, NULL, 0) == NULL) {
+ if (ribmgr_ro_create(RIBMGR_PREFIX, attr, NULL, 0) == NULL) {
LOG_ERR("Failed to create RIBMGR RO.");
- free(props);
return -1;
}
@@ -1329,25 +1312,10 @@ int ribmgr_bootstrap(struct dif_config * conf)
static_info_msg__pack(&stat_info, data);
- props = malloc(sizeof(*props));
- if (props == NULL) {
- LOG_ERR("Failed to allocate memory.");
- free(data);
- addr_auth_destroy(rib.addr_auth);
- ribmgr_ro_delete(RIBMGR_PREFIX);
- return -1;
- }
-
- props->enrol_sync = true;
- props->recv_set = NEIGHBORS;
- props->expiry.tv_sec = 0;
- props->expiry.tv_nsec = 0;
-
if (ribmgr_ro_create(RIBMGR_PREFIX STAT_INFO,
- props, data, len) == NULL) {
+ attr, data, len) == NULL) {
LOG_ERR("Failed to create static info RO.");
free(data);
- free(props);
addr_auth_destroy(rib.addr_auth);
ribmgr_ro_delete(RIBMGR_PREFIX);
return -1;
@@ -1400,27 +1368,33 @@ static int send_neighbors_ro(char * name,
return 0;
}
-int ro_create(const char * name,
- struct ro_props * props,
- uint8_t * data,
- size_t len)
+int ro_create(const char * name,
+ struct ro_attr * attr,
+ uint8_t * data,
+ size_t len)
{
struct rnode * node;
ro_msg_t msg = RO_MSG__INIT;
+ struct ro_attr rattr;
- if (name == NULL || props == NULL)
+ if (name == NULL)
return -EINVAL;
+ if (attr == NULL) {
+ ro_attr_init(&rattr);
+ attr = &rattr;
+ }
+
pthread_mutex_lock(&rib.ro_lock);
- node = ribmgr_ro_create(name, props, data, len);
+ node = ribmgr_ro_create(name, *attr, data, len);
if (node == NULL) {
pthread_mutex_unlock(&rib.ro_lock);
LOG_ERR("Failed to create RO.");
return -1;
}
- if (node->props->recv_set == NO_SYNC) {
+ if (node->attr.recv_set == NO_SYNC) {
pthread_mutex_unlock(&rib.ro_lock);
return 0;
}
@@ -1442,6 +1416,18 @@ int ro_create(const char * name,
return 0;
}
+int ro_attr_init(struct ro_attr * attr)
+{
+ assert(attr);
+
+ attr->enrol_sync = false;
+ attr->recv_set = NO_SYNC;
+ attr->expiry.tv_sec = 0;
+ attr->expiry.tv_nsec = 0;
+
+ return 0;
+}
+
int ro_delete(const char * name)
{
struct rnode * node;
@@ -1459,7 +1445,7 @@ int ro_delete(const char * name)
return -1;
}
- if (node->props->recv_set != NO_SYNC) {
+ if (node->attr.recv_set != NO_SYNC) {
if (ro_msg_create(node, &msg)) {
pthread_mutex_unlock(&rib.ro_lock);
LOG_ERR("Failed to create RO msg.");
@@ -1503,7 +1489,7 @@ int ro_write(const char * name,
}
node->seqno++;
- if (node->props->recv_set == NO_SYNC) {
+ if (node->attr.recv_set == NO_SYNC) {
pthread_mutex_unlock(&rib.ro_lock);
return 0;
}
diff --git a/src/ipcpd/normal/ro.h b/src/ipcpd/normal/ro.h
index 6fa1db2a..278c9213 100644
--- a/src/ipcpd/normal/ro.h
+++ b/src/ipcpd/normal/ro.h
@@ -29,18 +29,20 @@ enum ro_recv_set {
ALL_MEMBERS
};
-struct ro_props {
+struct ro_attr {
bool enrol_sync;
enum ro_recv_set recv_set;
struct timespec expiry;
};
/* All RIB-objects have a pathname, separated by a slash. */
-/* Takes ownership of the data and props */
-int ro_create(const char * name,
- struct ro_props * props,
- uint8_t * data,
- size_t len);
+/* Takes ownership of the data */
+int ro_create(const char * name,
+ struct ro_attr * attr,
+ uint8_t * data,
+ size_t len);
+
+int ro_attr_init(struct ro_attr * attr);
int ro_delete(const char * name);
@@ -54,13 +56,13 @@ ssize_t ro_read(const char * name,
/* Callback passes ownership of the data */
struct ro_sub_ops {
- int (* ro_created)(const char * name,
- uint8_t * data,
- size_t len);
- int (* ro_updated)(const char * name,
- uint8_t * data,
- size_t len);
- int (* ro_deleted)(const char * name);
+ void (* ro_created)(const char * name,
+ uint8_t * data,
+ size_t len);
+ void (* ro_updated)(const char * name,
+ uint8_t * data,
+ size_t len);
+ void (* ro_deleted)(const char * name);
};
/* Returns subscriber-id */