reactor: Add and use stopped() getter

To facilitate next patch. Signed-off-by: Pavel Emelyanov <[email protected]>
scylladb · Jun 18, 2024 · 594a8fb · 594a8fb
1 parent cee4698
commit 594a8fb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/include/seastar/core/reactor.hh b/include/seastar/core/reactor.hh
@@ -368,6 +368,8 @@ public:
  /// Register a user-defined signal handler
  void handle_signal(int signo, noncopyable_function<void ()>&& handler);
  void wakeup();
+ /// @private
+ bool stopped() const noexcept { return _stopped; }
 
 private:
  class signals {

diff --git a/src/core/reactor.cc b/src/core/reactor.cc
@@ -3602,7 +3602,7 @@ void smp_message_queue::submit_item(shard_id t, smp_timeout_clock::time_point ti
 
 void smp_message_queue::respond(work_item* item) {
  _completed_fifo.push_back(item);
- if (_completed_fifo.size() >= batch_size || engine()._stopped) {
+ if (_completed_fifo.size() >= batch_size || engine().stopped()) {
  flush_response_batch();
  }
 }