Code Cleanup

include/PgSQL_Connection.h

@@ -259,11 +259,6 @@ public:
 	char* param_value[PG_PARAM_SIZE]{};
 };
 
-struct Pkt_result {
-	char type;
-	PtrSize_t pkt;
-};
-
 class PgSQL_Variable {
 public:
 	char *value = (char*)"";

lib/PgSQL_Connection.cpp

@@ -2733,30 +2733,6 @@ void PgSQL_Connection::next_multi_statement_result(PGresult* result) {
 	query_result->buffer_to_PSarrayOut();
 }
 
-static int wait_for_pgsql(PGconn* pgsql_conn, int wait_event) {
-	struct pollfd pfd;
-	int timeout, res;
-
-	pfd.fd = PQsocket(pgsql_conn);
-	pfd.events =
-		(wait_event & PG_EVENT_READ ? POLLIN : 0) |
-		(wait_event & PG_EVENT_WRITE ? POLLOUT : 0) |
-		(wait_event & PG_EVENT_EXCEPT ? POLLPRI : 0);
-	timeout = 1;
-	res = poll(&pfd, 1, timeout);
-	if (res == 0)
-		return PG_EVENT_TIMEOUT | wait_event;
-	else if (res < 0)
-		return PG_EVENT_TIMEOUT;
-	else {
-		int status = 0;
-		if (pfd.revents & POLLIN) status |= PG_EVENT_READ;
-		if (pfd.revents & POLLOUT) status |= PG_EVENT_WRITE;
-		if (pfd.revents & POLLPRI) status |= PG_EVENT_EXCEPT;
-		return status;
-	}
-}
-
 void PgSQL_Connection::reset_session_start() {
 	PROXY_TRACE();
 	assert(pgsql_conn);

lib/PgSQL_HostGroups_Manager.cpp

@@ -69,30 +69,6 @@ static pthread_mutex_t ev_loop_mutex;
 
 const int PgSQL_ERRORS_STATS_FIELD_NUM = 11;
 
-static int wait_for_pgsql(MYSQL *mysql, int status) {
-	struct pollfd pfd;
-	int timeout, res;
-
-	pfd.fd = mysql_get_socket(mysql);
-	pfd.events =
-		(status & MYSQL_WAIT_READ ? POLLIN : 0) |
-		(status & MYSQL_WAIT_WRITE ? POLLOUT : 0) |
-		(status & MYSQL_WAIT_EXCEPT ? POLLPRI : 0);
-	timeout = 1;
-	res = poll(&pfd, 1, timeout);
-	if (res == 0)
-		return MYSQL_WAIT_TIMEOUT | status;
-	else if (res < 0)
-		return MYSQL_WAIT_TIMEOUT;
-	else {
-		int status = 0;
-		if (pfd.revents & POLLIN) status |= MYSQL_WAIT_READ;
-		if (pfd.revents & POLLOUT) status |= MYSQL_WAIT_WRITE;
-		if (pfd.revents & POLLPRI) status |= MYSQL_WAIT_EXCEPT;
-		return status;
-	}
-}
-
 /**
  * @brief Helper function used to try to extract a value from the JSON field 'servers_defaults'.
  *