hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use correct enum values in avrorouter

Browse Source 
The file flushing enums weren't used.
This commit is contained in:
Markus Mäkelä
2017-02-06 16:17:34 +02:00
parent d61f0d0afd
commit 7149775163
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/modules/routing/avrorouter/avro.c
View File

@ -1074,7 +1074,7 @@ void converter_func(void* data)
/** We reached end of file, flush unwritten records to disk */ /** We reached end of file, flush unwritten records to disk */
if (router->task_delay == 1) if (router->task_delay == 1)
{ {
avro_flush_all_tables(router, true); avro_flush_all_tables(router, AVROROUTER_FLUSH);
avro_save_conversion_state(router); avro_save_conversion_state(router);
} }

2
server/modules/routing/avrorouter/avro_file.c
View File

@ -745,7 +745,7 @@ avro_binlog_end_t avro_read_all_events(AVRO_INSTANCE *router)
router->trx_count >= router->trx_target) router->trx_count >= router->trx_target)
{ {
update_used_tables(router); update_used_tables(router);
avro_flush_all_tables(router, false); avro_flush_all_tables(router, AVROROUTER_SYNC);
avro_save_conversion_state(router); avro_save_conversion_state(router);
notify_all_clients(router); notify_all_clients(router);
total_rows += router->row_count; total_rows += router->row_count;