mirror of
https://github.com/SoftEtherVPN/SoftEtherVPN.git
synced 2024-11-22 17:39:53 +03:00
Mayaqua/Network.c: Fix race condition in TUBE operation
This commit is contained in:
parent
bf14817f1f
commit
9182a9b4e9
@ -16732,8 +16732,12 @@ bool TubeSendEx2(TUBE *t, void *data, UINT size, void *header, bool no_flush, UI
|
|||||||
|
|
||||||
if (no_flush == false)
|
if (no_flush == false)
|
||||||
{
|
{
|
||||||
Set(t->Event);
|
Lock(t->Lock);
|
||||||
SetSockEvent(t->SockEvent);
|
{
|
||||||
|
Set(t->Event);
|
||||||
|
SetSockEvent(t->SockEvent);
|
||||||
|
}
|
||||||
|
Unlock(t->Lock);
|
||||||
}
|
}
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
@ -16765,8 +16769,12 @@ void TubeFlushEx(TUBE *t, bool force)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
Set(t->Event);
|
Lock(t->Lock);
|
||||||
SetSockEvent(t->SockEvent);
|
{
|
||||||
|
Set(t->Event);
|
||||||
|
SetSockEvent(t->SockEvent);
|
||||||
|
}
|
||||||
|
Unlock(t->Lock);
|
||||||
}
|
}
|
||||||
|
|
||||||
// Receive the data from the tube (asynchronous)
|
// Receive the data from the tube (asynchronous)
|
||||||
|
Loading…
Reference in New Issue
Block a user