projects
/
collectd.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
26868df
)
Use bson_destroy instead of bson_free, and fix memleak issue.
author
Saikrishna Arcot
<saiarcot895@gmail.com>
Wed, 31 May 2017 14:49:25 +0000
(07:49 -0700)
committer
Saikrishna Arcot
<saiarcot895@gmail.com>
Wed, 31 May 2017 14:49:25 +0000
(07:49 -0700)
src/write_mongodb.c
patch
|
blob
|
history
diff --git
a/src/write_mongodb.c
b/src/write_mongodb.c
index
3cdc3d1
..
33f9bd5
100644
(file)
--- a/
src/write_mongodb.c
+++ b/
src/write_mongodb.c
@@
-78,7
+78,7
@@
static bson_t *wm_create_bson(const data_set_t *ds, /* {{{ */
rates = uc_get_rate(ds, vl);
if (rates == NULL) {
ERROR("write_mongodb plugin: uc_get_rate() failed.");
rates = uc_get_rate(ds, vl);
if (rates == NULL) {
ERROR("write_mongodb plugin: uc_get_rate() failed.");
- bson_
free
(ret);
+ bson_
destroy
(ret);
return NULL;
}
} else {
return NULL;
}
} else {
@@
-111,7
+111,7
@@
static bson_t *wm_create_bson(const data_set_t *ds, /* {{{ */
else {
ERROR("write_mongodb plugin: Unknown ds_type %d for index %d",
ds->ds[i].type, i);
else {
ERROR("write_mongodb plugin: Unknown ds_type %d for index %d",
ds->ds[i].type, i);
- bson_
free
(ret);
+ bson_
destroy
(ret);
return NULL;
}
}
return NULL;
}
}
@@
-145,7
+145,7
@@
static bson_t *wm_create_bson(const data_set_t *ds, /* {{{ */
if (!bson_validate(ret, BSON_VALIDATE_UTF8, &error_location)) {
ERROR("write_mongodb plugin: Error in generated BSON document "
"at byte %zu", error_location);
if (!bson_validate(ret, BSON_VALIDATE_UTF8, &error_location)) {
ERROR("write_mongodb plugin: Error in generated BSON document "
"at byte %zu", error_location);
- bson_
free
(ret);
+ bson_
destroy
(ret);
return NULL;
}
return NULL;
}
@@
-249,7
+249,7
@@
static int wm_write(const data_set_t *ds, /* {{{ */
if (wm_initialize(node) < 0) {
ERROR("write_mongodb plugin: error making connection to server");
pthread_mutex_unlock(&node->lock);
if (wm_initialize(node) < 0) {
ERROR("write_mongodb plugin: error making connection to server");
pthread_mutex_unlock(&node->lock);
- bson_
free
(bson_record);
+ bson_
destroy
(bson_record);
return -1;
}
return -1;
}
@@
-263,7
+263,7
@@
static int wm_write(const data_set_t *ds, /* {{{ */
node->client = NULL;
node->connected = 0;
pthread_mutex_unlock(&node->lock);
node->client = NULL;
node->connected = 0;
pthread_mutex_unlock(&node->lock);
- bson_
free
(bson_record);
+ bson_
destroy
(bson_record);
return -1;
}
return -1;
}
@@
-278,7
+278,7
@@
static int wm_write(const data_set_t *ds, /* {{{ */
node->client = NULL;
node->connected = 0;
pthread_mutex_unlock(&node->lock);
node->client = NULL;
node->connected = 0;
pthread_mutex_unlock(&node->lock);
- bson_
free
(bson_record);
+ bson_
destroy
(bson_record);
mongoc_collection_destroy(collection);
return -1;
}
mongoc_collection_destroy(collection);
return -1;
}
@@
-288,7
+288,7
@@
static int wm_write(const data_set_t *ds, /* {{{ */
pthread_mutex_unlock(&node->lock);
pthread_mutex_unlock(&node->lock);
- bson_
free
(bson_record);
+ bson_
destroy
(bson_record);
return 0;
} /* }}} int wm_write */
return 0;
} /* }}} int wm_write */