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

Whenever monitored server's state changes, a callback, router_handle_state_switch is called for each DCB in MaxScale session. The DCB referring to the server in question will be passed as parameter to backend DCB's hangup function.

Browse Source 
The logic that solves the situation is not in place yet.
This commit is contained in:
VilhoRaatikka
2014-06-13 13:30:50 +03:00
parent 9eda859724
commit dfc9141a38
4 changed files with 63 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -224,8 +224,7 @@ static void refreshInstance(
static void bref_clear_state(backend_ref_t* bref, bref_state_t state);
static void bref_set_state(backend_ref_t* bref, bref_state_t state);
static int router_handle_not_responding(DCB* dcb, DCB_REASON reason, void* data);
static void hangup_server_connections (ROUTER_INSTANCE* inst);
static int router_handle_state_switch(DCB* dcb, DCB_REASON reason, void* data);
static SPINLOCK instlock;
static ROUTER_INSTANCE* instances;
@ -1596,14 +1595,14 @@ static bool select_connect_backend_servers(
session,
b->backend_server->protocol);
if (backend_ref[i].bref_dcb != NULL)
if (backend_ref[i].bref_dcb != NULL)
{
slaves_connected += 1;
dcb_add_callback(
backend_ref[i].bref_dcb,
DCB_REASON_NOT_RESPONDING,
&router_handle_not_responding,
NULL);
&router_handle_state_switch,
(void *)&backend_ref[i]);
bref_clear_state(&backend_ref[i],
BREF_NOT_USED);
bref_set_state(&backend_ref[i],
@ -2745,56 +2744,36 @@ static backend_ref_t* get_bref_from_dcb(
return bref;
}
static int router_handle_not_responding(
static int router_handle_state_switch(
DCB* dcb,
DCB_REASON reason,
void* data)
{
ROUTER_INSTANCE* inst;
backend_ref_t* bref;
int rc = 1;
CHK_DCB(dcb);
CHK_SESSION(dcb->session);
inst = dcb->session->service->router_instance;
bref = (backend_ref_t *)data;
CHK_BACKEND_REF(bref);
if (bref->bref_dcb != dcb)
{
goto return_rc;
}
switch (reason) {
case DCB_REASON_NOT_RESPONDING:
hangup_server_connections(inst);
if (BREF_IS_WAITING_RESULT(bref))
{
printf("foo");
dcb->func.hangup(dcb);
}
break;
default:
break;
}
return 1;
return_rc:
return rc;
}
static void hangup_server_connections (
ROUTER_INSTANCE* inst)
{
ROUTER_CLIENT_SES* rses;
SERVER* fail_server;
rses = inst->connections;
while (rses != NULL)
{
backend_ref_t* bref;
CHK_CLIENT_RSES(rses);
bref = rses->rses_backend_ref;
while (bref != NULL)
{
CHK_BACKEND_REF(bref);
CHK_BACKEND(bref->bref_backend);
if (bref->bref_backend->backend_server == fail_server &&
BREF_IS_WAITING_RESPONSE(bref))
{
bref->bref_dcb->func.hangup;
}
bref ++;
}
rses = rses->next;
}
}