1 files changed, 26 insertions, 19 deletions

diff --git a/plugins/ommongodb/ommongodb.c b/plugins/ommongodb/ommongodb.c
index f2de33df..0da6dc48 100644
--- a/plugins/ommongodb/ommongodb.c
+++ b/plugins/ommongodb/ommongodb.c
@@ -68,6 +68,7 @@ typedef struct _instanceData {
 	uchar *pwd;
 	uchar *dbNcoll;
 	uchar *tplName;
+	int bErrMsgPermitted;	/* only one errmsg permitted per connection */
 } instanceData;
 
 
@@ -139,19 +140,21 @@ 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) == 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");
+	int eno;
+
+	if(pData->bErrMsgPermitted) {
+		eno = errno;
+		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 {
+			DBGPRINTF("ommongodb: we had an error, but can not obtain specifics, "
+				  "using plain old errno error message generator\n");
+			errmsg.LogError(0, RS_RET_ERR, "ommongodb: error: %s",
+				rs_strerror_r(eno, errStr, sizeof(errStr)));
+		}
+		pData->bErrMsgPermitted = 0;
 	}
-#else
-	(void)pData;
-#endif
 }
 
 
@@ -224,11 +227,11 @@ static bson *
 getDefaultBSON(msg_t *pMsg)
 {
 	bson *doc = NULL;
-	uchar *procid; short unsigned procid_free; size_t procid_len;
-	uchar *tag; short unsigned tag_free; size_t tag_len;
-	uchar *pid; short unsigned pid_free; size_t pid_len;
-	uchar *sys; short unsigned sys_free; size_t sys_len;
-	uchar *msg; short unsigned msg_free; size_t msg_len;
+	uchar *procid; short unsigned procid_free; rs_size_t procid_len;
+	uchar *tag; short unsigned tag_free; rs_size_t tag_len;
+	uchar *pid; short unsigned pid_free; rs_size_t pid_len;
+	uchar *sys; short unsigned sys_free; rs_size_t sys_len;
+	uchar *msg; short unsigned msg_free; rs_size_t msg_len;
 	int severity, facil;
 	gint64 ts_gen, ts_rcv; /* timestamps: generated, received */
 	int secfrac;
@@ -296,7 +299,9 @@ static bson *BSONFromJSONObject(struct json_object *json);
 static gboolean
 BSONAppendJSONObject(bson *doc, const gchar *name, struct json_object *json)
 {
-	switch(json_object_get_type(json)) {
+	switch(json != NULL ? json_object_get_type(json) : json_type_null) {
+	case json_type_null:
+		return bson_append_null(doc, name);
 	case json_type_boolean:
 		return bson_append_boolean(doc, name,
 					   json_object_get_boolean(json));
@@ -431,9 +436,11 @@ CODESTARTdoAction
 		/* FIXME: is this a correct return code? */
 		ABORT_FINALIZE(RS_RET_ERR);
 	}
-	if(!mongo_sync_cmd_insert(pData->conn, (char*)pData->dbNcoll, doc, NULL)) {
-		reportMongoError(pData);
+	if(mongo_sync_cmd_insert(pData->conn, (char*)pData->dbNcoll, doc, NULL)) {
+		pData->bErrMsgPermitted = 1;
+	} else {
 		dbgprintf("ommongodb: insert error\n");
+		reportMongoError(pData);
 		ABORT_FINALIZE(RS_RET_SUSPENDED);
 	}