|
|
|
|
@ -96,6 +96,7 @@ void * ProxySQL_Cluster_Monitor_thread(void *args) {
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_CONNECT_TIMEOUT, &timeout);
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_READ_TIMEOUT, &timeout_long);
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_WRITE_TIMEOUT, &timeout);
|
|
|
|
|
{ unsigned char val = 1; mysql_options(conn, MYSQL_OPT_SSL_ENFORCE, &val); }
|
|
|
|
|
//rc_conn = mysql_real_connect(conn, node->hostname, username, password, NULL, node->port, NULL, CLIENT_COMPRESS); // FIXME: add optional support for compression
|
|
|
|
|
rc_conn = mysql_real_connect(conn, node->hostname, username, password, NULL, node->port, NULL, 0);
|
|
|
|
|
//char *query = query1;
|
|
|
|
|
@ -615,6 +616,7 @@ void ProxySQL_Cluster::pull_mysql_query_rules_from_peer() {
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_CONNECT_TIMEOUT, &timeout);
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_READ_TIMEOUT, &timeout_long);
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_WRITE_TIMEOUT, &timeout);
|
|
|
|
|
{ unsigned char val = 1; mysql_options(conn, MYSQL_OPT_SSL_ENFORCE, &val); }
|
|
|
|
|
proxy_info("Cluster: Fetching MySQL Query Rules from peer %s:%d started\n", hostname, port);
|
|
|
|
|
rc_conn = mysql_real_connect(conn, hostname, username, password, NULL, port, NULL, 0);
|
|
|
|
|
if (rc_conn) {
|
|
|
|
|
@ -770,6 +772,7 @@ void ProxySQL_Cluster::pull_mysql_users_from_peer() {
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_CONNECT_TIMEOUT, &timeout);
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_READ_TIMEOUT, &timeout_long);
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_WRITE_TIMEOUT, &timeout);
|
|
|
|
|
{ unsigned char val = 1; mysql_options(conn, MYSQL_OPT_SSL_ENFORCE, &val); }
|
|
|
|
|
proxy_info("Cluster: Fetching MySQL Users from peer %s:%d started\n", hostname, port);
|
|
|
|
|
rc_conn = mysql_real_connect(conn, hostname, username, password, NULL, port, NULL, 0);
|
|
|
|
|
if (rc_conn) {
|
|
|
|
|
@ -853,6 +856,7 @@ void ProxySQL_Cluster::pull_mysql_servers_from_peer() {
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_CONNECT_TIMEOUT, &timeout);
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_READ_TIMEOUT, &timeout_long);
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_WRITE_TIMEOUT, &timeout);
|
|
|
|
|
{ unsigned char val = 1; mysql_options(conn, MYSQL_OPT_SSL_ENFORCE, &val); }
|
|
|
|
|
proxy_info("Cluster: Fetching MySQL Servers from peer %s:%d started. Expected checksum %s\n", hostname, port, peer_checksum);
|
|
|
|
|
rc_conn = mysql_real_connect(conn, hostname, username, password, NULL, port, NULL, 0);
|
|
|
|
|
if (rc_conn) {
|
|
|
|
|
@ -997,6 +1001,7 @@ void ProxySQL_Cluster::pull_proxysql_servers_from_peer() {
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_CONNECT_TIMEOUT, &timeout);
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_READ_TIMEOUT, &timeout_long);
|
|
|
|
|
mysql_options(conn, MYSQL_OPT_WRITE_TIMEOUT, &timeout);
|
|
|
|
|
{ unsigned char val = 1; mysql_options(conn, MYSQL_OPT_SSL_ENFORCE, &val); }
|
|
|
|
|
proxy_info("Cluster: Fetching ProxySQL Servers from peer %s:%d started\n", hostname, port);
|
|
|
|
|
rc_conn = mysql_real_connect(conn, hostname, username, password, NULL, port, NULL, 0);
|
|
|
|
|
if (rc_conn) {
|
|
|
|
|
|