Исправляем ошибку таймеров клиента и сервера

anyks · Oct 5, 2024 · bf82e8c · bf82e8c
1 parent 0b707d6
commit bf82e8c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/core/client.cpp b/src/core/client.cpp
@@ -596,7 +596,7 @@ void awh::client::Core::createTimeout(const uint64_t bid, const time_t msec) noe
 			// Выполняем блокировку потока
 			const lock_guard <recursive_mutex> lock(this->_mtx.receive);
 			// Выполняем создание нового таймаута
-			this->_timeouts.emplace(bid, (tid = this->_timer.timeout(msec)));
+			this->_receive.emplace(bid, (tid = this->_timer.timeout(msec)));
 		}
 		// Выполняем добавление функции обратного вызова
 		this->_timer.set <void (const uint64_t)> (tid, std::bind(static_cast <void (core_t::*)(const uint64_t)> (&core_t::close), this, bid));

diff --git a/src/core/server.cpp b/src/core/server.cpp
@@ -1011,7 +1011,7 @@ void awh::server::Core::createTimeout(const uint16_t sid, const uint64_t bid, co
 						// Выполняем блокировку потока
 						const lock_guard <recursive_mutex> lock(this->_mtx.receive);
 						// Выполняем создание нового таймаута
-						this->_timeouts.emplace(bid, (tid = this->_timer->timeout(msec)));
+						this->_receive.emplace(bid, (tid = this->_timer->timeout(msec)));
 					}
 					// Выполняем добавление функции обратного вызова
 					this->_timer->set <void (const uint64_t)> (tid, std::bind(static_cast <void (core_t::*)(const uint64_t)> (&core_t::close), this, bid));