From 2c81480d28e7380939d43da2e8592dc257379822 Mon Sep 17 00:00:00 2001
From: Rainer Gerhards <rgerhards@adiscon.com>
Date: Sun, 6 Jan 2008 17:59:40 +0000
Subject: worked on object header (now also contains the size)

---
 queue.c | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

(limited to 'queue.c')

diff --git a/queue.c b/queue.c
index ffd007e2..17e33675 100644
--- a/queue.c
+++ b/queue.c
@@ -40,6 +40,7 @@
 #include "rsyslog.h"
 #include "syslogd.h"
 #include "queue.h"
+#include "stringbuf.h"
 #include "srUtils.h"
 
 /* static data */
@@ -233,13 +234,12 @@ rsRetVal qAddDisk(queue_t *pThis, void* pUsr)
 {
 	DEFiRet;
 	int i;
-	long lenBuf;
-	uchar *pBuf;
+	rsCStrObj *pCStr;
 
 	assert(pThis != NULL);
 	dbgprintf("writing to file %d\n", pThis->tVars.disk.fd);
-	CHKiRet((objSerialize(pUsr))(pUsr, &pBuf, &lenBuf)); // TODO: hier weiter machen!
-	i = write(pThis->tVars.disk.fd, pBuf, strlen((char*) pBuf));
+	CHKiRet((objSerialize(pUsr))(pUsr, &pCStr)); // TODO: hier weiter machen!
+	i = write(pThis->tVars.disk.fd, rsCStrGetBufBeg(pCStr), rsCStrLen(pCStr));
 	dbgprintf("write wrote %d bytes, errno: %d, err %s\n", i, errno, strerror(errno));
 
 finalize_it:
-- 
cgit v1.2.3