hcq/MaxScale
hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Write queue emptied in dcb_final_free.

Browse Source 
NOTE: Invalid indentation for reduced conflicts with MXS-329.
This commit is contained in:
Johan Wikman 2015-09-23 15:05:16 +03:00
parent f7946a05fa
commit 3b19acd1de
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server/core/dcb.c
View File

@ -374,6 +374,11 @@ dcb_final_free(DCB *dcb)
GWBUF *queue = dcb->delayq;
while ((queue = gwbuf_consume(queue, GWBUF_LENGTH(queue))) != NULL);
}
if (dcb->writeq) {
GWBUF *queue = dcb->writeq;
while ((queue = gwbuf_consume(queue, GWBUF_LENGTH(queue))) != NULL);
dcb->writeq = NULL;
}
if (dcb->dcb_readqueue)
{
GWBUF* queue = dcb->dcb_readqueue;
@ -3141,4 +3146,4 @@ void dcb_log_ssl_read_error(DCB *dcb, int ssl_errno, int rc)
}
}
}
}
}