summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2012-03-20 12:56:27 +0100
committerRainer Gerhards <rgerhards@adiscon.com>2012-03-20 12:56:27 +0100
commit8aa7784e3d3e3926bbf41bfecdde2abe373dcc06 (patch)
tree2ce9dcda8d2a9752740aa08a22f99cc7b124fdb7
parente0d69d3e10bae3f108a58c12ca6a3ac3974827d0 (diff)
downloadrsyslog-8aa7784e3d3e3926bbf41bfecdde2abe373dcc06.tar.gz
rsyslog-8aa7784e3d3e3926bbf41bfecdde2abe373dcc06.tar.xz
rsyslog-8aa7784e3d3e3926bbf41bfecdde2abe373dcc06.zip
ommongodb: working on error reporting
-rw-r--r--plugins/ommongodb/ommongodb.c15
1 files changed, 10 insertions, 5 deletions
diff --git a/plugins/ommongodb/ommongodb.c b/plugins/ommongodb/ommongodb.c
index a247909d..5591b693 100644
--- a/plugins/ommongodb/ommongodb.c
+++ b/plugins/ommongodb/ommongodb.c
@@ -128,13 +128,18 @@ ENDdbgPrintInstInfo
static void
reportMongoError(instanceData *pData)
{
+ char errStr[1024];
+ errmsg.LogError(0, RS_RET_ERR, "ommongodb: error: %s",
+ rs_strerror_r(errno, errStr, sizeof(errStr)));
+#if 0
gchar *err;
- if(mongo_sync_cmd_get_last_error(pData->conn, (gchar*)pData->db, &err)) {
+ if(mongo_sync_cmd_get_last_error(pData->conn, (gchar*)pData->db, &err) == TRUE) {
errmsg.LogError(0, RS_RET_ERR, "ommongodb: error: %s", err);
} else {
errmsg.LogError(0, RS_RET_ERR, "ommongodb: we had an error, but can "
"not obtain specifics");
}
+#endif
}
@@ -227,15 +232,15 @@ rsRetVal writeMongoDB_msg(msg_t *pMsg, instanceData *pData)
if(msg_free) free(msg);
if(doc == NULL) {
- dbgprintf("ommongodb: error creating BSON doc\n");
reportMongoError(pData);
- ABORT_FINALIZE(RS_RET_ERR);
+ dbgprintf("ommongodb: error creating BSON doc\n");
+ ABORT_FINALIZE(RS_RET_SUSPENDED);
}
bson_finish(doc);
if(!mongo_sync_cmd_insert(pData->conn, (char*)pData->dbNcoll, doc, NULL)) {
- dbgprintf("ommongodb: insert error\n");
reportMongoError(pData);
- ABORT_FINALIZE(RS_RET_ERR);
+ dbgprintf("ommongodb: insert error\n");
+ ABORT_FINALIZE(RS_RET_SUSPENDED);
}
finalize_it: