Assert DCB ownership in dcb_drain_writeq

This will cause EPOLLOUT events for maxscaled to trigger the assert
immediately if the buffer was placed into the queue by another worker.
This commit is contained in:
Markus Mäkelä 2019-07-08 12:18:22 +03:00
parent e658dca4fe
commit 1b69e659db
No known key found for this signature in database
GPG Key ID: 72D48FCE664F7B19

View File

@ -1006,6 +1006,8 @@ static void dcb_log_write_failure(DCB* dcb, GWBUF* queue, int eno)
*/
int dcb_drain_writeq(DCB* dcb)
{
mxb_assert(dcb->poll.owner == RoutingWorker::get_current());
if (dcb->ssl_read_want_write)
{
/** The SSL library needs to write more data */