Skip to content

Commit 786c2d5

Browse files
authored
catch sigterm (#240)
1 parent 784621b commit 786c2d5

2 files changed

Lines changed: 4 additions & 0 deletions

File tree

based/crates/common/src/actor.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,8 @@ pub trait Actor<Db>: Sized {
5757
let term = Arc::new(AtomicBool::new(false));
5858
signal_hook::flag::register(signal_hook::consts::SIGINT, Arc::clone(&term))
5959
.expect("couldn't register signal hook for some reason");
60+
signal_hook::flag::register(signal_hook::consts::SIGTERM, Arc::clone(&term))
61+
.expect("couldn't register signal hook for some reason");
6062
let time_loop = actor_config.min_loop_duration.is_some();
6163
loop {
6264
loop_timer.start();

based/crates/metrics/src/consumer.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,8 @@ impl MetricsConsumer {
2727
let term = Arc::new(AtomicBool::new(false));
2828
signal_hook::flag::register(signal_hook::consts::SIGINT, Arc::clone(&term))
2929
.expect("couldn't register signal hook for some reason");
30+
signal_hook::flag::register(signal_hook::consts::SIGTERM, Arc::clone(&term))
31+
.expect("couldn't register signal hook for some reason");
3032

3133
let mut tick = Repeater::every(Duration::from_secs(30));
3234
let mut event_count_last_checkpoint = Instant::now();

0 commit comments

Comments
 (0)