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

Fix in DISCONNECT SERVER reply

Browse Source 
Fix in DISCONNECT SERVER reply
This commit is contained in:
MassimilianoPinto
2015-03-17 19:38:21 +01:00
parent c7e1bd5052
commit 4006052887
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
server/modules/routing/binlog/blr_slave.c
View File

@ -1885,6 +1885,13 @@ char serverid[40];
uint8_t *ptr; uint8_t *ptr;
int len, id_len, seqno = 2; int len, id_len, seqno = 2;
sprintf(serverid, "%d", server_id);
if (found)
strcpy(state, "disconnected");
else
strcpy(state, "not found");
id_len = strlen(serverid);
len = 5 + id_len + strlen(state) + 1; len = 5 + id_len + strlen(state) + 1;
if ((pkt = gwbuf_alloc(len)) == NULL) if ((pkt = gwbuf_alloc(len)) == NULL)
@ -1895,13 +1902,6 @@ int len, id_len, seqno = 2;
blr_slave_send_columndef(router, slave, "state", 0xf, 40, seqno++); blr_slave_send_columndef(router, slave, "state", 0xf, 40, seqno++);
blr_slave_send_eof(router, slave, seqno++); blr_slave_send_eof(router, slave, seqno++);
sprintf(serverid, "%d", server_id);
id_len = strlen(serverid);
if (found)
strcpy(state, "disconnected");
else
strcpy(state, "not found");
ptr = GWBUF_DATA(pkt); ptr = GWBUF_DATA(pkt);
encode_value(ptr, id_len + 2 + strlen(state), 24); // Add length of data packet encode_value(ptr, id_len + 2 + strlen(state), 24); // Add length of data packet
ptr += 3; ptr += 3;