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

Fixed missing session lock in schemarouter.

Browse Source
This commit is contained in:
Markus Makela
2015-03-13 03:33:37 +02:00
parent 8d0ca74b9c
commit 57fc4696f2
1 changed files with 19 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
server/modules/routing/schemarouter/schemarouter.c
View File

@ -1685,7 +1685,16 @@ static int routeQuery(
} }
ss_dassert(!GWBUF_IS_TYPE_UNDEFINED(querybuf)); ss_dassert(!GWBUF_IS_TYPE_UNDEFINED(querybuf));
if(!rses_is_closed) if (!rses_begin_locked_router_action(router_cli_ses))
{
LOGIF(LT, (skygw_log_write(
LOGFILE_TRACE,
"Route query aborted! Routing session is closed <")));
ret = 0;
goto retblock;
}
if(!(rses_is_closed = router_cli_ses->rses_closed))
{ {
if(router_cli_ses->init & INIT_UNINT) if(router_cli_ses->init & INIT_UNINT)
{ {
@ -1717,12 +1726,16 @@ static int routeQuery(
else else
{ {
ptr->next = querybuf; ptr->next = querybuf;
} }
rses_end_locked_router_action(router_cli_ses);
return 1; return 1;
} }
} }
rses_end_locked_router_action(router_cli_ses);
packet = GWBUF_DATA(querybuf); packet = GWBUF_DATA(querybuf);
packet_type = packet[4]; packet_type = packet[4];
@ -1891,14 +1904,6 @@ static int routeQuery(
* for an alternate backend with the database. If this is not found * for an alternate backend with the database. If this is not found
* the target is undefined and an error will be returned to the client. * the target is undefined and an error will be returned to the client.
*/ */
/*
if((tname = get_shard_target_name(inst,router_cli_ses,querybuf,qtype)) != NULL &&
check_shard_status(inst,tname))
{
route_target = TARGET_NAMED_SERVER;
}
*/
} }
} }
@ -2477,6 +2482,10 @@ static void clientReply (
if (writebuf != NULL && client_dcb != NULL) if (writebuf != NULL && client_dcb != NULL)
{ {
/** Write reply to client DCB */ /** Write reply to client DCB */
char* query = modutil_get_SQL(writebuf);
skygw_log_write(LOGFILE_TRACE, "schemarouter: returning reply [%x]: %s",
writebuf->start+4,
query);
SESSION_ROUTE_REPLY(backend_dcb->session, writebuf); SESSION_ROUTE_REPLY(backend_dcb->session, writebuf);
} }
/** Unlock router session */ /** Unlock router session */