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

Fixed compile error.

Browse Source
This commit is contained in:
VilhoRaatikka
2014-03-18 11:21:51 +02:00
parent 526762bcc7
commit 35c460457a
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
server/modules/routing/readwritesplit/readwritesplit.c
View File

@ -463,14 +463,14 @@ static void closeSession(
*/ */
if (rses_begin_locked_router_action(router_cli_ses)) if (rses_begin_locked_router_action(router_cli_ses))
{ {
/* decrease server current connection counters */ /** decrease server current connection counters */
atomic_add(&router_cli_ses->rses_backend[BE_SLAVE]->backend_server->stats.n_current, -1); atomic_add(&router_cli_ses->rses_backend[BE_SLAVE]->backend_server->stats.n_current, -1);
atomic_add(&router_cli_ses->rses_backend[BE_MASTER]->backend_server->stats.n_current, -1); atomic_add(&router_cli_ses->rses_backend[BE_MASTER]->backend_server->stats.n_current, -1);
slave_dcb = router_cli_ses->slave_dcb; slave_dcb = router_cli_ses->rses_dcb[BE_SLAVE];
router_cli_ses->slave_dcb = NULL; router_cli_ses->rses_dcb[BE_SLAVE] = NULL;
master_dcb = router_cli_ses->master_dcb; master_dcb = router_cli_ses->rses_dcb[BE_MASTER];
router_cli_ses->master_dcb = NULL; router_cli_ses->rses_dcb[BE_MASTER] = NULL;
router_cli_ses->rses_closed = true; router_cli_ses->rses_closed = true;
/** Unlock */ /** Unlock */
@ -502,7 +502,7 @@ static void freeSession(
router_cli_ses = (ROUTER_CLIENT_SES *)router_client_session; router_cli_ses = (ROUTER_CLIENT_SES *)router_client_session;
router = (ROUTER_INSTANCE *)router_instance; router = (ROUTER_INSTANCE *)router_instance;
atomic_add(&router_cli_ses->rses_backend[BE_SLAVE]->backend_conn_count, -1); atomic_add(&router_cli_ses->rses_backend[BE_SLAVE]->backend_conn_count, -1);
atomic_add(&router_cli_ses->rses_backend[BE_MASTER]->backend_conn_count, -1); atomic_add(&router_cli_ses->rses_backend[BE_MASTER]->backend_conn_count, -1);
spinlock_acquire(&router->lock); spinlock_acquire(&router->lock);