mirror of https://github.com/schoebel/mars
logger: improve trigger
This commit is contained in:
parent
5767a2fdbf
commit
506f57d04b
|
@ -2823,6 +2823,7 @@ void trans_logger_log(struct trans_logger_brick *brick)
|
||||||
mars_limit_reset(&global_writeback.limiter);
|
mars_limit_reset(&global_writeback.limiter);
|
||||||
|
|
||||||
brick->terminated = true;
|
brick->terminated = true;
|
||||||
|
mars_trigger();
|
||||||
}
|
}
|
||||||
|
|
||||||
////////////////////////////// log replay //////////////////////////////
|
////////////////////////////// log replay //////////////////////////////
|
||||||
|
@ -3199,10 +3200,10 @@ void trans_logger_replay(struct trans_logger_brick *brick)
|
||||||
brick_msleep(1000);
|
brick_msleep(1000);
|
||||||
}
|
}
|
||||||
|
|
||||||
mars_trigger();
|
|
||||||
|
|
||||||
mars_limit_reset(brick->replay_limiter);
|
mars_limit_reset(brick->replay_limiter);
|
||||||
brick->terminated = true;
|
brick->terminated = true;
|
||||||
|
mars_trigger();
|
||||||
|
|
||||||
while (!brick_thread_should_stop()) {
|
while (!brick_thread_should_stop()) {
|
||||||
brick_wait(brick->worker_event,
|
brick_wait(brick->worker_event,
|
||||||
brick->worker_flag,
|
brick->worker_flag,
|
||||||
|
|
Loading…
Reference in New Issue