1 files changed, 2 insertions, 0 deletions
diff --git a/queue.c b/queue.c
index 20ead4a1..a502ff40 100644
--- a/queue.c
+++ b/queue.c
@@ -845,6 +845,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);