Addition to previous fix
This commit is contained in:
@ -392,13 +392,10 @@ static int gw_read_backend_event(DCB *dcb) {
|
|||||||
dcb,
|
dcb,
|
||||||
dcb->session)));
|
dcb->session)));
|
||||||
|
|
||||||
if (session != NULL)
|
spinlock_acquire(&session->ses_lock);
|
||||||
{
|
session->state = SESSION_STATE_STOPPING;
|
||||||
spinlock_acquire(&session->ses_lock);
|
spinlock_release(&session->ses_lock);
|
||||||
session->state = SESSION_STATE_STOPPING;
|
ss_dassert(dcb->dcb_errhandle_called);
|
||||||
spinlock_release(&session->ses_lock);
|
|
||||||
}
|
|
||||||
ss_dassert(dcb->dcb_errhandle_called);
|
|
||||||
dcb_close(dcb);
|
dcb_close(dcb);
|
||||||
}
|
}
|
||||||
rc = 1;
|
rc = 1;
|
||||||
|
@ -1767,7 +1767,7 @@ void protocol_archive_srv_command(
|
|||||||
}
|
}
|
||||||
else /*< scan and count history commands */
|
else /*< scan and count history commands */
|
||||||
{
|
{
|
||||||
len += 1;
|
len = 1;
|
||||||
|
|
||||||
while (h1->scom_next != NULL)
|
while (h1->scom_next != NULL)
|
||||||
{
|
{
|
||||||
|
Reference in New Issue
Block a user