From 71497751632a0a6bea6aa8149c348094a2fccead Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Markus=20M=C3=A4kel=C3=A4?= Date: Mon, 6 Feb 2017 16:17:34 +0200 Subject: [PATCH] Use correct enum values in avrorouter The file flushing enums weren't used. --- server/modules/routing/avrorouter/avro.c | 2 +- server/modules/routing/avrorouter/avro_file.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/server/modules/routing/avrorouter/avro.c b/server/modules/routing/avrorouter/avro.c index 55a8ac6ee..0104c8b58 100644 --- a/server/modules/routing/avrorouter/avro.c +++ b/server/modules/routing/avrorouter/avro.c @@ -1074,7 +1074,7 @@ void converter_func(void* data) /** We reached end of file, flush unwritten records to disk */ if (router->task_delay == 1) { - avro_flush_all_tables(router, true); + avro_flush_all_tables(router, AVROROUTER_FLUSH); avro_save_conversion_state(router); } diff --git a/server/modules/routing/avrorouter/avro_file.c b/server/modules/routing/avrorouter/avro_file.c index 570a81031..602f2c2cb 100644 --- a/server/modules/routing/avrorouter/avro_file.c +++ b/server/modules/routing/avrorouter/avro_file.c @@ -745,7 +745,7 @@ avro_binlog_end_t avro_read_all_events(AVRO_INSTANCE *router) router->trx_count >= router->trx_target) { update_used_tables(router); - avro_flush_all_tables(router, false); + avro_flush_all_tables(router, AVROROUTER_SYNC); avro_save_conversion_state(router); notify_all_clients(router); total_rows += router->row_count;