13f7015e7b
The EOF packet calculation function in modutil.cc didn't handle the case where the payload exceeded maximum packet size and could mistake binary data for a ERR packet. The state of a multi-packet payload is now exposed by the modutil_count_signal_packets function. This allows proper handling of large multi-packet payloads. Added minor improvements to mxs1110_16mb to handle testing of this change.
58 lines
2.0 KiB
C++
58 lines
2.0 KiB
C++
/**
|
|
* @file mxs1110_16mb.cpp - trying to use LONGBLOB with > 16 mb data blocks
|
|
* - try to insert large LONGBLOB via RWSplit in blocks > 16mb
|
|
* - read data via RWsplit, ReadConn master, ReadConn slave, compare with inserted data
|
|
*/
|
|
|
|
|
|
#include "testconnections.h"
|
|
#include "blob_test.h"
|
|
#include "fw_copy_rules.h"
|
|
|
|
int main(int argc, char *argv[])
|
|
{
|
|
TestConnections::skip_maxscale_start(true);
|
|
TestConnections * Test = new TestConnections(argc, argv);
|
|
Test->stop_maxscale();
|
|
Test->set_timeout(60);
|
|
int chunk_size = 2500000;
|
|
int chunk_num = 5;
|
|
|
|
Test->copy_to_maxscale("./masking/masking_user/masking_rules.json", "~/");
|
|
|
|
Test->copy_to_maxscale("./cache/cache_basic/cache_rules.json", "~/");
|
|
|
|
copy_rules(Test, (char *) "rules2", "./fw/");
|
|
|
|
Test->start_maxscale();
|
|
|
|
Test->repl->execute_query_all_nodes( (char *) "set global max_allowed_packet=100000000");
|
|
Test->galera->execute_query_all_nodes( (char *) "set global max_allowed_packet=100000000");
|
|
|
|
Test->connect_maxscale();
|
|
Test->repl->connect();
|
|
Test->tprintf("LONGBLOB: Trying send data via RWSplit\n");
|
|
test_longblob(Test, Test->conn_rwsplit, (char *) "LONGBLOB", chunk_size, chunk_num, 2);
|
|
Test->repl->close_connections();
|
|
Test->close_maxscale_connections();
|
|
|
|
Test->repl->sync_slaves();
|
|
Test->connect_maxscale();
|
|
Test->tprintf("Checking data via RWSplit\n");
|
|
check_longblob_data(Test, Test->conn_rwsplit, chunk_size, chunk_num, 2);
|
|
Test->tprintf("Checking data via ReadConn master\n");
|
|
check_longblob_data(Test, Test->conn_master, chunk_size, chunk_num, 2);
|
|
Test->tprintf("Checking data via ReadConn slave\n");
|
|
check_longblob_data(Test, Test->conn_slave, chunk_size, chunk_num, 2);
|
|
Test->close_maxscale_connections();
|
|
|
|
MYSQL * conn_galera = open_conn(4016, Test->maxscale_IP, Test->maxscale_user,
|
|
Test->maxscale_password, Test->ssl);
|
|
mysql_close(conn_galera);
|
|
|
|
int rval = Test->global_result;
|
|
delete Test;
|
|
return rval;
|
|
}
|
|
|