-
Notifications
You must be signed in to change notification settings - Fork 977
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #4114 from sysown/v2.x_fast_forward_SSL_2302
Set correct backend encryption when switching to fast_forward
- Loading branch information
Showing
9 changed files
with
257 additions
and
7 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,16 @@ | ||
| @@ -386,6 +386,15 @@ | ||
| memcpy(rpl_event->event.rows.row_data, ev, rpl_event->event.rows.row_data_size); | ||
| } | ||
| break; | ||
| + case PREVIOUS_GTIDS_LOG_EVENT: | ||
| + case ANONYMOUS_GTID_LOG_EVENT: | ||
| + case WRITE_ROWS_EVENT: | ||
| + case UPDATE_ROWS_EVENT: | ||
| + case DELETE_ROWS_EVENT: | ||
| + case GTID_LOG_EVENT: | ||
| + case HEARTBEAT_LOG_EVENT_V2: | ||
| + case ROWS_QUERY_LOG_EVENT: | ||
| + break; | ||
| default: | ||
| free(rpl_event); | ||
| return NULL; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,9 @@ | ||
| @@ -94,6 +94,8 @@ | ||
| VIEW_CHANGE_EVENT= 37, | ||
| XA_PREPARE_LOG_EVENT= 38, | ||
|
|
||
| + HEARTBEAT_LOG_EVENT_V2 = 41, | ||
| + | ||
| /* | ||
| Add new events here - right above this comment! | ||
| Existing events (except ENUM_END_EVENT) should never change their numbers |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,161 @@ | ||
| #include <cstdlib> | ||
| #include <cstdio> | ||
| #include <cstring> | ||
| #include <unistd.h> | ||
|
|
||
| #include <vector> | ||
| #include <string> | ||
| #include <sstream> | ||
| #include <mysql.h> | ||
|
|
||
| #include "tap.h" | ||
| #include "command_line.h" | ||
| #include "utils.h" | ||
| #include "mariadb_rpl.h" | ||
|
|
||
| MYSQL * mysqladmin = NULL; | ||
| CommandLine cl; | ||
|
|
||
| #define NHB 10 // the number of heartbeat to wait | ||
|
|
||
| int run_queries_sets(std::vector<std::string>& queries, MYSQL *my, const std::string& message_prefix) { | ||
| for (std::vector<std::string>::iterator it = queries.begin(); it != queries.end(); it++) { | ||
| std::string q = *it; | ||
| diag("%s: %s", message_prefix.c_str(), q.c_str()); | ||
| MYSQL_QUERY(my, q.c_str()); | ||
| } | ||
| return 0; | ||
| } | ||
|
|
||
| std::vector<std::string> adminQ_set1 = { | ||
| "SET mysql-have_ssl='false'", | ||
| "LOAD MYSQL VARIABLES TO RUNTIME", | ||
| "UPDATE mysql_servers SET use_ssl=1", | ||
| "LOAD MYSQL SERVERS TO RUNTIME", | ||
| }; | ||
|
|
||
|
|
||
| int pull_replication(MYSQL *mysql, int server_id) { | ||
| MARIADB_RPL_EVENT *event= NULL; | ||
| MARIADB_RPL *rpl= mariadb_rpl_init(mysql); | ||
| rpl->server_id= server_id; | ||
| rpl->start_position= 4; | ||
| rpl->flags= MARIADB_RPL_BINLOG_SEND_ANNOTATE_ROWS; | ||
|
|
||
| if (mariadb_rpl_open(rpl)) | ||
| return exit_status(); | ||
|
|
||
| int num_heartbeats = 0; | ||
| int num_events = 0; | ||
|
|
||
| diag("Pulling all binlog events, it may take some time, be patient..."); | ||
| /* | ||
| * we iterate through all the events, | ||
| * and then wait NHB heartbeats | ||
| */ | ||
| while(num_heartbeats < NHB && (event= mariadb_rpl_fetch(rpl, event))) | ||
| { | ||
| num_events++; | ||
| bool print_diag = false; | ||
| if (event->event_type == HEARTBEAT_LOG_EVENT_V2 || event->event_type == HEARTBEAT_LOG_EVENT) { | ||
| num_heartbeats++; | ||
| print_diag = true; | ||
| } | ||
| if (print_diag == false) { | ||
| // we try to not flood the log | ||
| if (num_events < 10) { | ||
| print_diag = true; | ||
| } else if (num_events < 100) { | ||
| if (num_events % 10 == 0) { | ||
| print_diag = true; | ||
| } | ||
| } else if (num_events < 1000) { | ||
| if (num_events % 100 == 0) { | ||
| print_diag = true; | ||
| } | ||
| } else { | ||
| if (num_events % 1000 == 0) { | ||
| print_diag = true; | ||
| } | ||
| } | ||
| } | ||
| if (print_diag == true) | ||
| diag("%s: server_id %d , event: %d , received events: %d , received heartbeats: %d", tap_curtime().c_str(), server_id, event->event_type, num_events, num_heartbeats); | ||
| } | ||
| // we expects NHB heartbeats | ||
| ok(num_heartbeats == NHB , "For server_id %d received %d heartbeats", server_id, num_heartbeats); | ||
| mariadb_free_rpl_event(event); | ||
| mariadb_rpl_close(rpl); | ||
| if (num_heartbeats != NHB) { | ||
| return 1; | ||
| } | ||
| return 0; | ||
| } | ||
|
|
||
|
|
||
| std::vector<std::string> repl_queries_set1 = { // only 1 set, maybe more later | ||
| "SET NAMES latin1", | ||
| "SET NAMES utf8", | ||
| "SET @master_binlog_checksum = 'NONE'", | ||
| "SET @master_heartbeat_period=2000000000", // 2 seconds heartbeat | ||
| }; | ||
|
|
||
| int setup_replication(int server_id, bool frontend_ssl, bool backend_ssl, std::vector<std::string>& mysql_queries) { | ||
| diag("Running %s using server_id %d , frontend_ssl = %s , backend_ssl = %s", __func__ , server_id, (frontend_ssl ? "TRUE" : "FALSE") , (backend_ssl ? "TRUE" : "FALSE")); | ||
| MYSQL * mysql = mysql_init(NULL); | ||
|
|
||
| std::vector<std::string> admin_queries = {}; | ||
| admin_queries.push_back(std::string("SET mysql-have_ssl='") + std::string(frontend_ssl ? "true" : "false") + "'"); | ||
| admin_queries.push_back("LOAD MYSQL VARIABLES TO RUNTIME"); | ||
| admin_queries.push_back(std::string("UPDATE mysql_servers SET use_ssl=") + std::string(backend_ssl ? "1" : "0")); | ||
| admin_queries.push_back("LOAD MYSQL SERVERS TO RUNTIME"); | ||
|
|
||
| if (!mysql) | ||
| return exit_status(); | ||
| if (frontend_ssl) { | ||
| mysql_ssl_set(mysql, NULL, NULL, NULL, NULL, NULL); | ||
| } | ||
| if (!mysql_real_connect(mysql, cl.host, cl.username, cl.password, NULL, cl.port, NULL, 0)) { | ||
| //if (!mysql_real_connect(mysql, cl.host, cl.username, cl.password, NULL, 3306, NULL, 0)) { | ||
| fprintf(stderr, "Failed to connect to database: Error: %s\n", mysql_error(mysql)); | ||
| return exit_status(); | ||
| } | ||
| if (run_queries_sets(admin_queries, mysqladmin, "Running on Admin")) | ||
| return exit_status(); | ||
| if (run_queries_sets(mysql_queries, mysql, "Running on MySQL")) | ||
| return exit_status(); | ||
| int rc = pull_replication(mysql, server_id); | ||
| ok(rc==0,"Result with server_id %d , frontend_ssl = %s , backend_ssl = %s , rc = %d", server_id, (frontend_ssl ? "TRUE" : "FALSE") , (backend_ssl ? "TRUE" : "FALSE") , rc); | ||
| if (rc != 0) | ||
| return exit_status(); | ||
| mysql_close(mysql); | ||
| return 0; | ||
| } | ||
|
|
||
| int main(int argc, char** argv) { | ||
|
|
||
| if(cl.getEnv()) | ||
| return exit_status(); | ||
|
|
||
| plan(8); // each test has 2 OK | ||
|
|
||
| mysqladmin = mysql_init(NULL); | ||
| if (!mysqladmin) | ||
| return exit_status(); | ||
|
|
||
| if (!mysql_real_connect(mysqladmin, cl.host, cl.admin_username, cl.admin_password, NULL, cl.admin_port, NULL, 0)) { | ||
| fprintf(stderr, "File %s, line %d, Error: %s\n", | ||
| __FILE__, __LINE__, mysql_error(mysqladmin)); | ||
| return exit_status(); | ||
| } | ||
| // we now test various combination | ||
| setup_replication(11, false, false, repl_queries_set1); | ||
| setup_replication(12, true, false, repl_queries_set1); | ||
| setup_replication(13, false, true, repl_queries_set1); | ||
| setup_replication(14, true, true, repl_queries_set1); | ||
|
|
||
| mysql_close(mysqladmin); | ||
|
|
||
| return exit_status(); | ||
| } | ||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters