Merge branch '2.3' into 2.4
This commit is contained in:
@ -350,6 +350,12 @@ DCB* dcb_connect(SERVER* srv, MXS_SESSION* session, const char* protocol)
|
|||||||
dcb->last_read = mxs_clock();
|
dcb->last_read = mxs_clock();
|
||||||
dcb->last_write = mxs_clock();
|
dcb->last_write = mxs_clock();
|
||||||
mxb::atomic::add(&server->stats.n_from_pool, 1, mxb::atomic::RELAXED);
|
mxb::atomic::add(&server->stats.n_from_pool, 1, mxb::atomic::RELAXED);
|
||||||
|
/* All callbacks were removed when the dcb was put into the pool. */
|
||||||
|
if (DCB_THROTTLING_ENABLED(dcb))
|
||||||
|
{
|
||||||
|
dcb_add_callback(dcb, DCB_REASON_HIGH_WATER, upstream_throttle_callback, NULL);
|
||||||
|
dcb_add_callback(dcb, DCB_REASON_LOW_WATER, upstream_throttle_callback, NULL);
|
||||||
|
}
|
||||||
return dcb;
|
return dcb;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
|
|||||||
Reference in New Issue
Block a user