MXS-2610: Prevent watchdog timeouts in avrorouter
The file processing can take a very long time and as it is done on a routing worker, the workaround needs to be used.
This commit is contained in:
@ -37,6 +37,7 @@
|
|||||||
#include <maxscale/maxscale.h>
|
#include <maxscale/maxscale.h>
|
||||||
#include <maxscale/pcre2.h>
|
#include <maxscale/pcre2.h>
|
||||||
#include <maxscale/utils.h>
|
#include <maxscale/utils.h>
|
||||||
|
#include <maxscale/routingworker.hh>
|
||||||
|
|
||||||
static const char* statefile_section = "avro-conversion";
|
static const char* statefile_section = "avro-conversion";
|
||||||
|
|
||||||
@ -529,6 +530,7 @@ bool read_fde(Avro* router)
|
|||||||
*/
|
*/
|
||||||
avro_binlog_end_t avro_read_all_events(Avro* router)
|
avro_binlog_end_t avro_read_all_events(Avro* router)
|
||||||
{
|
{
|
||||||
|
mxs::WatchdogWorkaround workaround;
|
||||||
mxb_assert(router->binlog_fd != -1);
|
mxb_assert(router->binlog_fd != -1);
|
||||||
|
|
||||||
if (!read_fde(router))
|
if (!read_fde(router))
|
||||||
|
|||||||
Reference in New Issue
Block a user