This commit is contained in:
J. Nick Koston
2025-05-13 21:11:19 -05:00
parent 4096c943cc
commit edd755323c

View File

@@ -434,7 +434,7 @@ class APIConnection : public APIServerConnection {
template<typename EntityT> bool send_state_(EntityT *entity, bool (APIConnection::*try_send_func)(EntityT *)) {
if (!this->state_subscription_)
return false;
if (this->try_to_clear_buffer() && (this->*try_send_func)(entity)) {
if (this->try_to_clear_buffer(true) && (this->*try_send_func)(entity)) {
return true;
}
this->deferred_message_queue_.defer(entity, reinterpret_cast<send_message_t>(try_send_func));
@@ -464,7 +464,7 @@ class APIConnection : public APIServerConnection {
Args... args) {
if (!this->state_subscription_)
return false;
if (this->try_to_clear_buffer() && (this->*try_send_state_func)(entity, state, args...)) {
if (this->try_to_clear_buffer(true) && (this->*try_send_state_func)(entity, state, args...)) {
return true;
}
this->deferred_message_queue_.defer(entity, reinterpret_cast<send_message_t>(try_send_entity_func));
@@ -479,7 +479,7 @@ class APIConnection : public APIServerConnection {
* @param try_send_func The function that tries to send the info
*/
template<typename EntityT> void send_info_(EntityT *entity, bool (APIConnection::*try_send_func)(EntityT *)) {
if (this->try_to_clear_buffer() && (this->*try_send_func)(entity)) {
if (this->try_to_clear_buffer(true) && (this->*try_send_func)(entity)) {
return;
}
this->deferred_message_queue_.defer(entity, reinterpret_cast<send_message_t>(try_send_func));