summaryrefslogtreecommitdiff
path: root/src/protocol.c
diff options
context:
space:
mode:
authorAldrik Ramaekers <aldrik@amftech.nl>2023-04-30 14:06:36 +0200
committerAldrik Ramaekers <aldrik@amftech.nl>2023-04-30 14:06:36 +0200
commit9e70ced6b48d627f236af8ea8366c6ed73748ab1 (patch)
tree0c8306a6744923364e7b4c17f9b334ff2529e700 /src/protocol.c
parentd402270d68d7d4a1c887b34cd93e5f11aa61b638 (diff)
fix zombie pathfinding bug
Diffstat (limited to 'src/protocol.c')
-rw-r--r--src/protocol.c12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/protocol.c b/src/protocol.c
index b54091e..555295c 100644
--- a/src/protocol.c
+++ b/src/protocol.c
@@ -116,18 +116,18 @@ void add_message_to_outgoing_queuex(network_message message, network_client c) {
}
void add_message_to_outgoing_queue(send_queue_entry entry) {
- network_message_type type = *(network_message_type*)(entry.message.data+12);
+ network_message_type type = *(network_message_type*)(entry.message.data+NETWORK_PACKET_OVERHEAD);
bool can_overwrite = type != MESSAGE_USER_SHOOT && type != MESSAGE_USER_MOVED && type != MESSAGE_USER_LOOK;
- //mutex_lock(&messages_to_send_queue_mutex);
+ mutex_lock(&messages_to_send_queue_mutex);
for (int i = 0; i < OUTGOING_QUEUE_SIZE; i++)
{
if (messages_to_send_queue[i].active) {
- network_message_type type_existing = *(network_message_type*)(messages_to_send_queue[i].message.data+12);
+ network_message_type type_existing = *(network_message_type*)(messages_to_send_queue[i].message.data+NETWORK_PACKET_OVERHEAD);
if (type == type_existing && can_overwrite) {
messages_to_send_queue[i] = entry;
- //mutex_unlock(&messages_to_send_queue_mutex);
+ mutex_unlock(&messages_to_send_queue_mutex);
return;
}
else {
@@ -136,10 +136,10 @@ void add_message_to_outgoing_queue(send_queue_entry entry) {
}
messages_to_send_queue[i] = entry;
messages_to_send_queue[i].active = true;
- //mutex_unlock(&messages_to_send_queue_mutex);
+ mutex_unlock(&messages_to_send_queue_mutex);
return;
}
- //mutex_unlock(&messages_to_send_queue_mutex);
+ mutex_unlock(&messages_to_send_queue_mutex);
log_info("Outgoing network queue is full");
}