projects/grpc_chat_cpp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

No more panick

Browse Source
This commit is contained in:
Fabian Schmidt
2026-02-09 20:46:32 +01:00
parent 38f6488ba1
commit ed02a86331
2 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
server/inc/logic/reactor.h
View File

@@ -14,8 +14,8 @@ public:
ChatReactor(Service *service, absl::Mutex *mu, ChatReactor(Service *service, absl::Mutex *mu,
std::vector<chat::chatMsg> *msgs); std::vector<chat::chatMsg> *msgs);
void OnReadDone(bool ok) override; void OnReadDone(bool) override;
void OnWriteDone(bool /*ok*/) override { StartRead(&m_msg); } void OnWriteDone(bool) override;
void OnDone() override { void OnDone() override {
std::cout << "RPC Completed"; std::cout << "RPC Completed";
@@ -30,4 +30,5 @@ private:
absl::Mutex *m_mu; absl::Mutex *m_mu;
std::vector<chat::chatMsg> *m_messages ABSL_GUARDED_BY(m_mu); std::vector<chat::chatMsg> *m_messages ABSL_GUARDED_BY(m_mu);
// std::atomic<bool> m_reading{false};
}; };

6
server/src/logic/reactor.cpp
View File

@@ -19,3 +19,9 @@ void ChatReactor::OnReadDone(bool ok) {
Finish(grpc::Status::OK); Finish(grpc::Status::OK);
} }
} }
void ChatReactor::OnWriteDone(bool ok) {
if (!ok) {
std::cerr << "Write failed to client" << std::endl;
}
}