aherman
/
proxysql
mirror of https://github.com/sysown/proxysql
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adding more errors in MySQL Events log

Browse Source 
Adding logging for errors generated directly directly by ProxySQL
v2.x-logging_mem
René Cannaò 2 years ago
parent 223573df39
commit b05f6bdef5
1 changed files with 14 additions and 11 deletions
Show Stats Download Patch File Download Diff File

25
lib/MySQL_Session.cpp
Unescape View File

@ -1436,9 +1436,10 @@ void MySQL_Session::return_proxysql_internal(PtrSize_t *pkt) {
}
// default
client_myds->DSS=STATE_QUERY_SENT_NET;
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,1,1064,(char *)"42000",(char *)"Unknown PROXYSQL INTERNAL command",true);
string errmsg = "Unknown PROXYSQL INTERNAL command";
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,1,1064,(char *)"42000", errmsg.c_str() ,true);
if (mirror==false) {
RequestEnd(NULL);
RequestEnd(NULL, errmsg.c_str());
} else {
client_myds->DSS=STATE_SLEEP;
status=WAITING_CLIENT_DATA;
@ -1588,7 +1589,7 @@ bool MySQL_Session::handler_special_queries(PtrSize_t *pkt) {
status=WAITING_CLIENT_DATA;
if (mirror==false) {
RequestEnd(NULL);
RequestEnd(NULL, err_info.second);
}
l_free(pkt->size,pkt->ptr);
@ -1787,9 +1788,10 @@ bool MySQL_Session::handler_special_queries(PtrSize_t *pkt) {
if ( (pkt->size >= 22 + 5) && (strncasecmp((char *)"LOAD DATA LOCAL INFILE",(char *)pkt->ptr+5, 22)==0) ) {
if (mysql_thread___enable_load_data_local_infile == false) {
client_myds->DSS=STATE_QUERY_SENT_NET;
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,1,1047,(char *)"HY000",(char *)"Unsupported 'LOAD DATA LOCAL INFILE' command",true);
string errmsg = "Unsupported 'LOAD DATA LOCAL INFILE' command";
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,1,1047,(char *)"HY000", errmsg.c_str(), true);
if (mirror==false) {
RequestEnd(NULL);
RequestEnd(NULL, errmsg.c_str());
} else {
client_myds->DSS=STATE_SLEEP;
status=WAITING_CLIENT_DATA;
@ -3614,7 +3616,7 @@ void MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C
sprintf(buf, err_msg, current_hostgroup, locked_on_hostgroup, nqn.c_str(), end);
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,client_myds->pkt_sid+1,9005,(char *)"HY000",buf, true);
thread->status_variables.stvar[st_var_hostgroup_locked_queries]++;
RequestEnd(NULL);
RequestEnd(NULL, buf);
free(buf);
l_free(pkt.size,pkt.ptr);
return;
@ -3787,7 +3789,7 @@ void MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C
sprintf(buf, err_msg, current_hostgroup, locked_on_hostgroup, nqn.c_str(), end);
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,client_myds->pkt_sid+1,9005,(char *)"HY000",buf, true);
thread->status_variables.stvar[st_var_hostgroup_locked_queries]++;
RequestEnd(NULL);
RequestEnd(NULL, buf);
free(buf);
l_free(pkt.size,pkt.ptr);
return;
@ -4506,7 +4508,7 @@ __get_pkts_from_client:
sprintf(buf, err_msg, current_hostgroup, locked_on_hostgroup, nqn.c_str(), end);
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,client_myds->pkt_sid+1,9005,(char *)"HY000",buf, true);
thread->status_variables.stvar[st_var_hostgroup_locked_queries]++;
RequestEnd(NULL);
RequestEnd(NULL, buf);
free(buf);
l_free(pkt.size,pkt.ptr);
break;
@ -6264,8 +6266,9 @@ void MySQL_Session::handler_WCD_SS_MCQ_qpo_error_msg(PtrSize_t *pkt) {
void MySQL_Session::handler_WCD_SS_MCQ_qpo_LargePacket(PtrSize_t *pkt) {
// ER_NET_PACKET_TOO_LARGE
client_myds->DSS=STATE_QUERY_SENT_NET;
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,client_myds->pkt_sid+1,1153,(char *)"08S01",(char *)"Got a packet bigger than 'max_allowed_packet' bytes", true);
RequestEnd(NULL);
string errmsg = "Got a packet bigger than 'max_allowed_packet' bytes";
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,client_myds->pkt_sid+1,1153,(char *)"08S01", errmsg.c_str(), true);
RequestEnd(NULL, errmsg.c_str());
l_free(pkt->size,pkt->ptr);
}
@ -7354,7 +7357,7 @@ __exit_set_destination_hostgroup:
sprintf(buf,"ProxySQL Error: connection is locked to hostgroup %d but trying to reach hostgroup %d", locked_on_hostgroup, current_hostgroup);
client_myds->myprot.generate_pkt_ERR(true,NULL,NULL,client_myds->pkt_sid+1,9006,(char *)"Y0000",buf);
thread->status_variables.stvar[st_var_hostgroup_locked_queries]++;
RequestEnd(NULL);
RequestEnd(NULL, buf);
l_free(pkt->size,pkt->ptr);
return true;
}

Write Preview
Loading…
Cancel
Save