Added extra debug fprintf

Added extra debug fprintf
This commit is contained in:
MassimilianoPinto
2017-04-27 09:15:32 +02:00
parent deb11ae6eb
commit 1e98de7b15
2 changed files with 9 additions and 0 deletions

View File

@ -3492,6 +3492,11 @@ int poll_add_dcb(DCB *dcb)
else if (dcb->dcb_role == DCB_ROLE_BACKEND_HANDLER) else if (dcb->dcb_role == DCB_ROLE_BACKEND_HANDLER)
{ {
worker_id = dcb->session->client_dcb->poll.thread.id; worker_id = dcb->session->client_dcb->poll.thread.id;
fprintf(stderr, "%i, %i\n",
worker_id,
Worker::get_current_id());
ss_dassert(worker_id == Worker::get_current_id()); ss_dassert(worker_id == Worker::get_current_id());
} }
else else

View File

@ -1789,6 +1789,10 @@ errorReply(MXS_ROUTER *instance,
mxs_error_action_t action, mxs_error_action_t action,
bool *succp) bool *succp)
{ {
fprintf(stderr, "errorReply %i, %i\n",
backend_dcb->poll.thread.id,
mxs_worker_get_current_id());
ss_dassert(backend_dcb->dcb_role == DCB_ROLE_BACKEND_HANDLER); ss_dassert(backend_dcb->dcb_role == DCB_ROLE_BACKEND_HANDLER);
ROUTER_INSTANCE *router = (ROUTER_INSTANCE *)instance; ROUTER_INSTANCE *router = (ROUTER_INSTANCE *)instance;
int error; int error;