Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 0 additions & 4 deletions src/include/framework/state.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,6 @@ class state : public std::enable_shared_from_this<state> {
boost::asio::io_context ioc_{
static_cast<int>(std::thread::hardware_concurrency())};
shared_of<boost::mysql::connection_pool> connection_pool_;
std::unordered_map<uuid, shared_of<tcp_service>, boost::hash<uuid>>
endpoints_;
std::unordered_map<uuid, shared_of<tcp_service>, boost::hash<uuid>> services_;
std::mutex sessions_mutex_;

Expand All @@ -57,8 +55,6 @@ class state : public std::enable_shared_from_this<state> {
void set_running(bool running);
map_hash_of<std::string, shared_queue, std::less<>>& queues() noexcept;
std::unordered_map<uuid, shared_of<tcp_service>, boost::hash<uuid>>&
endpoints() noexcept;
std::unordered_map<uuid, shared_of<tcp_service>, boost::hash<uuid>>&
services() noexcept;
shared_router get_router() const noexcept;
shared_queue get_queue(const std::string& name) noexcept;
Expand Down
1 change: 0 additions & 1 deletion src/include/framework/support.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,6 @@

namespace framework {
#ifdef DEBUG_ENABLED
inline std::mutex LOG_MUTEX;
#define LOG(msg) \
do { \
std::osyncstream(std::cout) << "[" << __FILE__ << ":" << __LINE__ << " - " \
Expand Down
4 changes: 0 additions & 4 deletions src/objects/framework/state.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -70,10 +70,6 @@ map_hash_of<std::string, shared_queue, std::less<>>& state::queues() noexcept {
return queues_;
}

std::unordered_map<uuid, shared_of<tcp_service>, boost::hash<uuid>>&
state::endpoints() noexcept {
return endpoints_;
}
std::unordered_map<uuid, shared_of<tcp_service>, boost::hash<uuid>>&
state::services() noexcept {
return services_;
Expand Down
3 changes: 2 additions & 1 deletion tests/test_server.cc
Original file line number Diff line number Diff line change
Expand Up @@ -1167,7 +1167,8 @@ TEST_F(test_server, basic_tcp_endpoint_check_with_runtime_client) {
ASSERT_TRUE(_wait_for_flag([&]() { return client_write_.load(); }, 2000) &&
"client_write (pong) timed out");

_service->stop_clients();
_service->stop();
_endpoint->stop();

ASSERT_TRUE(
_wait_for_flag([&]() { return client_disconnected_.load(); }, 2000) &&
Expand Down
Loading