diff --git a/include/MySQL_Data_Stream.h b/include/MySQL_Data_Stream.h index d076f664b..378b243d5 100644 --- a/include/MySQL_Data_Stream.h +++ b/include/MySQL_Data_Stream.h @@ -81,7 +81,9 @@ class MySQL_Data_Stream unsigned int partial; } CompPktOUT; + MySQL_Protocol myprot; MyDS_real_query mysql_real_query; + bytes_stats_t bytes_info; // bytes statistics PtrSize_t multi_pkt; @@ -95,25 +97,23 @@ class MySQL_Data_Stream PtrSizeArray *resultset; unsigned int resultset_length; - unsigned int connect_tries; ProxySQL_Poll *mypolls; - int array2buffer_full(); //int listener; MySQL_Connection *myconn; - MySQL_Protocol myprot; + MySQL_Session *sess; // pointer to the session using this data stream + MySQL_Backend *mybe; // if this is a connection to a mysql server, this points to a backend structure + SSL *ssl; + struct sockaddr *client_addr; + + unsigned int connect_tries; int connect_retries_on_failure; enum mysql_data_stream_status DSS; enum MySQL_DS_type myds_type; - MySQL_Session *sess; // pointer to the session using this data stream - MySQL_Backend *mybe; // if this is a connection to a mysql server, this points to a backend structure - bytes_stats_t bytes_info; // bytes statistics - int fd; // file descriptor - struct sockaddr *client_addr; socklen_t client_addrlen; + int fd; // file descriptor int poll_fds_idx; - SSL *ssl; int active_transaction; // 1 if there is an active transaction @@ -136,7 +136,7 @@ class MySQL_Data_Stream MySQL_Data_Stream(); ~MySQL_Data_Stream(); - + int array2buffer_full(); void init(); // initialize the data stream void init(enum MySQL_DS_type, MySQL_Session *, int); // initialize with arguments void shut_soft();