bugfix: memory leak in disk queue modes

this is a backport from 3.19.10

1 files changed, 2 insertions, 0 deletions

diff --git a/queue.c b/queue.c
index 0f58c545..081f48b3 100644
--- a/queue.c
+++ b/queue.c
@@ -849,6 +849,8 @@ static rsRetVal qAddDisk(queue_t *pThis, void* pUsr)
 
 	pThis->tVars.disk.sizeOnDisk += nWriteCount;
 
+	/* The following line is a backport from 3.19.10 - fixes mem leak */
+	objDestruct(pUsr);
 	dbgoprint((obj_t*) pThis, "write wrote %lld octets to disk, queue disk size now %lld octets\n",
 		   nWriteCount, pThis->tVars.disk.sizeOnDisk);