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

Added some checks for return values.

Browse Source
This commit is contained in:
vraatikka
2013-09-08 23:37:34 +03:00
parent a13396bc66
commit e7e44667c3
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/modules/protocol/mysql_client.c
View File

@ -232,6 +232,7 @@ MySQLSendHandshake(DCB* dcb)
// allocate memory for packet header + payload // allocate memory for packet header + payload
if ((buf = gwbuf_alloc(sizeof(mysql_packet_header) + mysql_payload_size)) == NULL) if ((buf = gwbuf_alloc(sizeof(mysql_packet_header) + mysql_payload_size)) == NULL)
{ {
ss_dassert(buf != NULL);
return 0; return 0;
} }
outbuf = GWBUF_DATA(buf); outbuf = GWBUF_DATA(buf);
@ -882,6 +883,7 @@ int gw_MySQLAccept(DCB *listener)
client_dcb->remote = strdup(inet_ntoa(local.sin_addr)); client_dcb->remote = strdup(inet_ntoa(local.sin_addr));
protocol = mysql_protocol_init(client_dcb); protocol = mysql_protocol_init(client_dcb);
ss_dassert(protocol != NULL);
if (protocol == NULL) { if (protocol == NULL) {
skygw_log_write_flush( skygw_log_write_flush(
@ -933,8 +935,12 @@ int gw_MySQLAccept(DCB *listener)
/* /*
*/ */
static int gw_error_client_event(DCB *dcb) { static int gw_error_client_event(DCB *dcb) {
/**
* should this be removed if we don't want to execute it ?
*
//fprintf(stderr, "#### Handle error function gw_error_client_event, for [%i] is [%s]\n", dcb->fd, gw_dcb_state2string(dcb->state)); //fprintf(stderr, "#### Handle error function gw_error_client_event, for [%i] is [%s]\n", dcb->fd, gw_dcb_state2string(dcb->state));
dcb_close(dcb); //dcb_close(dcb);
*/
return 1; return 1;
} }