intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 20 insertions, 0 deletions

diff --git a/library/cpp/messagebus/shutdown_state.cpp b/library/cpp/messagebus/shutdown_state.cpp
new file mode 100644
index 0000000000..a4e2bfa8b2
--- /dev/null
+++ b/library/cpp/messagebus/shutdown_state.cpp
@@ -0,0 +1,20 @@
+#include "shutdown_state.h"
+
+#include <util/system/yassert.h>
+
+void TAtomicShutdownState::ShutdownCommand() {
+    Y_VERIFY(State.CompareAndSet(SS_RUNNING, SS_SHUTDOWN_COMMAND));
+}
+
+void TAtomicShutdownState::CompleteShutdown() {
+    Y_VERIFY(State.CompareAndSet(SS_SHUTDOWN_COMMAND, SS_SHUTDOWN_COMPLETE));
+    ShutdownComplete.Signal();
+}
+
+bool TAtomicShutdownState::IsRunning() {
+    return State.Get() == SS_RUNNING;
+}
+
+TAtomicShutdownState::~TAtomicShutdownState() {
+    Y_VERIFY(SS_SHUTDOWN_COMPLETE == State.Get());
+}