2ab4a4fd20
The timeout is hit very often if the cluster fixing takes some time. This causes false positives so the timeout should be stopped before attempting to fix the cluster.
95 lines
2.3 KiB
C++
95 lines
2.3 KiB
C++
/**
|
|
* @file avro.cpp test of avro
|
|
* - setup binlog and avro
|
|
* - put some data to t1
|
|
* - check avro file with "maxavrocheck -vv /var/lib/maxscale/avro/test.t1.000001.avro"
|
|
* - check that data in avro file is correct
|
|
*/
|
|
|
|
|
|
#include <iostream>
|
|
#include "testconnections.h"
|
|
#include "maxadmin_operations.h"
|
|
#include "sql_t1.h"
|
|
|
|
#include "test_binlog_fnc.h"
|
|
#include <jansson.h>
|
|
#include "maxinfo_func.h"
|
|
|
|
#include <sstream>
|
|
#include <iostream>
|
|
|
|
using std::cout;
|
|
using std::endl;
|
|
|
|
int main(int argc, char *argv[])
|
|
{
|
|
|
|
TestConnections test(argc, argv);
|
|
test.set_timeout(600);
|
|
test.ssh_maxscale(true, (char *) "rm -rf /var/lib/maxscale/avro");
|
|
|
|
/** Start master to binlogrouter replication */
|
|
if (!test.replicate_from_master())
|
|
{
|
|
return 1;
|
|
}
|
|
|
|
test.set_timeout(120);
|
|
test.repl->connect();
|
|
|
|
create_t1(test.repl->nodes[0]);
|
|
insert_into_t1(test.repl->nodes[0], 3);
|
|
execute_query(test.repl->nodes[0], "FLUSH LOGS");
|
|
|
|
test.repl->close_connections();
|
|
|
|
/** Give avrorouter some time to process the events */
|
|
test.stop_timeout();
|
|
sleep(10);
|
|
test.set_timeout(120);
|
|
|
|
char * avro_check = test.ssh_maxscale_output(true,
|
|
"maxavrocheck -vv /var/lib/maxscale/avro/test.t1.000001.avro | grep \"{\"");
|
|
char * output = test.ssh_maxscale_output(true, "maxavrocheck -d /var/lib/maxscale/avro/test.t1.000001.avro");
|
|
|
|
std::istringstream iss;
|
|
iss.str(output);
|
|
int x1_exp = 0;
|
|
int fl_exp = 0;
|
|
int x = 16;
|
|
|
|
for (std::string line; std::getline(iss, line);)
|
|
{
|
|
long long int x1, fl;
|
|
test.set_timeout(20);
|
|
get_x_fl_from_json((char*)line.c_str(), &x1, &fl);
|
|
|
|
if (x1 != x1_exp || fl != fl_exp)
|
|
{
|
|
test.add_result(1, "Output:x1 %lld, fl %lld, Expected: x1 %d, fl %d",
|
|
x1, fl, x1_exp, fl_exp);
|
|
break;
|
|
}
|
|
|
|
if ((++x1_exp) >= x)
|
|
{
|
|
x1_exp = 0;
|
|
x = x * 16;
|
|
fl_exp++;
|
|
test.tprintf("fl = %d", fl_exp);
|
|
}
|
|
}
|
|
|
|
if (fl_exp != 3)
|
|
{
|
|
test.add_result(1, "not enough lines in avrocheck output");
|
|
}
|
|
|
|
execute_query(test.repl->nodes[0], "DROP TABLE test.t1;RESET MASTER");
|
|
test.stop_timeout();
|
|
test.repl->fix_replication();
|
|
|
|
return test.global_result;
|
|
}
|