summaryrefslogtreecommitdiff
path: root/src/protocol.c
diff options
context:
space:
mode:
authorAldrik Ramaekers <aldrik@amftech.nl>2022-12-18 20:30:27 +0100
committerAldrik Ramaekers <aldrik@amftech.nl>2022-12-18 20:30:27 +0100
commitabc04fe225f1cd77343528bfa0db41b62ed8cbd8 (patch)
treeb959f2b7eb2e96ae874d2d0a4f41aa77a131cee4 /src/protocol.c
parente917400634a535c6c14afc4e37a759f7c777b73a (diff)
disable frame cap
Diffstat (limited to 'src/protocol.c')
-rw-r--r--src/protocol.c4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/protocol.c b/src/protocol.c
index 9dc944e..7d921de 100644
--- a/src/protocol.c
+++ b/src/protocol.c
@@ -120,12 +120,14 @@ void add_message_to_outgoing_queue(send_queue_entry entry) {
bool can_overwrite = type != MESSAGE_USER_SHOOT && type != MESSAGE_USER_MOVED && type != MESSAGE_USER_LOOK;
+ //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);
if (type == type_existing && can_overwrite) {
messages_to_send_queue[i] = entry;
+ //mutex_unlock(&messages_to_send_queue_mutex);
return;
}
else {
@@ -134,8 +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);
return;
}
+ //mutex_unlock(&messages_to_send_queue_mutex);
log_info("Outgoing network queue is full");
}