diff options
author | Rainer Gerhards <rgerhards@adiscon.com> | 2012-03-20 12:56:27 +0100 |
---|---|---|
committer | Rainer Gerhards <rgerhards@adiscon.com> | 2012-03-20 12:56:27 +0100 |
commit | 8aa7784e3d3e3926bbf41bfecdde2abe373dcc06 (patch) | |
tree | 2ce9dcda8d2a9752740aa08a22f99cc7b124fdb7 | |
parent | e0d69d3e10bae3f108a58c12ca6a3ac3974827d0 (diff) | |
download | rsyslog-8aa7784e3d3e3926bbf41bfecdde2abe373dcc06.tar.gz rsyslog-8aa7784e3d3e3926bbf41bfecdde2abe373dcc06.tar.xz rsyslog-8aa7784e3d3e3926bbf41bfecdde2abe373dcc06.zip |
ommongodb: working on error reporting
-rw-r--r-- | plugins/ommongodb/ommongodb.c | 15 |
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: |