diff --git a/server/inc/logic/reactor.h b/server/inc/logic/reactor.h index a3ea31d..256160d 100644 --- a/server/inc/logic/reactor.h +++ b/server/inc/logic/reactor.h @@ -14,8 +14,8 @@ public: ChatReactor(Service *service, absl::Mutex *mu, std::vector *msgs); - void OnReadDone(bool ok) override; - void OnWriteDone(bool /*ok*/) override { StartRead(&m_msg); } + void OnReadDone(bool) override; + void OnWriteDone(bool) override; void OnDone() override { std::cout << "RPC Completed"; @@ -30,4 +30,5 @@ private: absl::Mutex *m_mu; std::vector *m_messages ABSL_GUARDED_BY(m_mu); + // std::atomic m_reading{false}; }; diff --git a/server/src/logic/reactor.cpp b/server/src/logic/reactor.cpp index 3b91f7e..1f71268 100644 --- a/server/src/logic/reactor.cpp +++ b/server/src/logic/reactor.cpp @@ -19,3 +19,9 @@ void ChatReactor::OnReadDone(bool ok) { Finish(grpc::Status::OK); } } + +void ChatReactor::OnWriteDone(bool ok) { + if (!ok) { + std::cerr << "Write failed to client" << std::endl; + } +}