From 9182a9b4e9ba44b4a92739163e6256fb7d1c5d94 Mon Sep 17 00:00:00 2001
From: domosekai <54519668+domosekai@users.noreply.github.com>
Date: Thu, 22 Jul 2021 11:59:15 +0000
Subject: [PATCH] Mayaqua/Network.c: Fix race condition in TUBE operation

---
 src/Mayaqua/Network.c | 16 ++++++++++++----
 1 file changed, 12 insertions(+), 4 deletions(-)

diff --git a/src/Mayaqua/Network.c b/src/Mayaqua/Network.c
index 4760b2b5..9ee9a10e 100644
--- a/src/Mayaqua/Network.c
+++ b/src/Mayaqua/Network.c
@@ -16732,8 +16732,12 @@ bool TubeSendEx2(TUBE *t, void *data, UINT size, void *header, bool no_flush, UI
 
 	if (no_flush == false)
 	{
-		Set(t->Event);
-		SetSockEvent(t->SockEvent);
+		Lock(t->Lock);
+		{
+			Set(t->Event);
+			SetSockEvent(t->SockEvent);
+		}
+		Unlock(t->Lock);
 	}
 
 	return true;
@@ -16765,8 +16769,12 @@ void TubeFlushEx(TUBE *t, bool force)
 		}
 	}
 
-	Set(t->Event);
-	SetSockEvent(t->SockEvent);
+	Lock(t->Lock);
+	{
+		Set(t->Event);
+		SetSockEvent(t->SockEvent);
+	}
+	Unlock(t->Lock);
 }
 
 // Receive the data from the tube (asynchronous)