b20334e09e
The slave part of the binlogrouter replication can be ignored for avrorouter tests. This will speed up the testing by skipping the unnecessary restarting and configuration of slave servers.
94 lines
2.3 KiB
C++
94 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.repl->fix_replication();
|
|
|
|
return test.global_result;
|
|
}
|