You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
143 lines
3.0 KiB
143 lines
3.0 KiB
#include "diablo.h" |
|
#include "../3rdParty/Storm/Source/storm.h" |
|
|
|
DEVILUTION_BEGIN_NAMESPACE |
|
|
|
static CCritSect sgMemCrit; |
|
unsigned int glpDThreadId; |
|
TMegaPkt *sgpInfoHead; /* may not be right struct */ |
|
BOOLEAN dthread_running; |
|
HANDLE sghWorkToDoEvent; |
|
|
|
/* rdata */ |
|
static HANDLE sghThread = INVALID_HANDLE_VALUE; |
|
|
|
void dthread_remove_player(int pnum) |
|
{ |
|
TMegaPkt *pkt; |
|
|
|
sgMemCrit.Enter(); |
|
for (pkt = sgpInfoHead; pkt; pkt = pkt->pNext) { |
|
if (pkt->dwSpaceLeft == pnum) |
|
pkt->dwSpaceLeft = 4; |
|
} |
|
sgMemCrit.Leave(); |
|
} |
|
|
|
void dthread_send_delta(int pnum, char cmd, void *pbSrc, int dwLen) |
|
{ |
|
TMegaPkt *pkt; |
|
TMegaPkt *p; |
|
|
|
if (gbMaxPlayers == 1) { |
|
return; |
|
} |
|
|
|
pkt = (TMegaPkt *)DiabloAllocPtr(dwLen + 20); |
|
pkt->pNext = NULL; |
|
pkt->dwSpaceLeft = pnum; |
|
pkt->data[0] = cmd; |
|
*(DWORD *)&pkt->data[4] = dwLen; |
|
memcpy(&pkt->data[8], pbSrc, dwLen); |
|
sgMemCrit.Enter(); |
|
p = (TMegaPkt *)&sgpInfoHead; |
|
while (p->pNext) { |
|
p = p->pNext; |
|
} |
|
p->pNext = pkt; |
|
|
|
SetEvent(sghWorkToDoEvent); |
|
sgMemCrit.Leave(); |
|
} |
|
|
|
void dthread_start() |
|
{ |
|
char *error_buf; |
|
|
|
if (gbMaxPlayers == 1) { |
|
return; |
|
} |
|
|
|
sghWorkToDoEvent = CreateEvent(NULL, TRUE, FALSE, NULL); |
|
if (!sghWorkToDoEvent) { |
|
error_buf = TraceLastError(); |
|
app_fatal("dthread:1\n%s", error_buf); |
|
} |
|
|
|
dthread_running = TRUE; |
|
|
|
sghThread = (HANDLE)_beginthreadex(NULL, 0, dthread_handler, NULL, 0, &glpDThreadId); |
|
if (sghThread == INVALID_HANDLE_VALUE) { |
|
error_buf = TraceLastError(); |
|
app_fatal("dthread2:\n%s", error_buf); |
|
} |
|
} |
|
|
|
unsigned int __stdcall dthread_handler(void *) |
|
{ |
|
char *error_buf; |
|
TMegaPkt *pkt; |
|
DWORD dwMilliseconds; |
|
|
|
while (dthread_running) { |
|
if (!sgpInfoHead && WaitForSingleObject(sghWorkToDoEvent, 0xFFFFFFFF) == -1) { |
|
error_buf = TraceLastError(); |
|
app_fatal("dthread4:\n%s", error_buf); |
|
} |
|
|
|
sgMemCrit.Enter(); |
|
pkt = sgpInfoHead; |
|
if (sgpInfoHead) |
|
sgpInfoHead = sgpInfoHead->pNext; |
|
else |
|
ResetEvent(sghWorkToDoEvent); |
|
sgMemCrit.Leave(); |
|
|
|
if (pkt) { |
|
if (pkt->dwSpaceLeft != 4) |
|
multi_send_zero_packet(pkt->dwSpaceLeft, pkt->data[0], &pkt->data[8], *(DWORD *)&pkt->data[4]); |
|
|
|
dwMilliseconds = 1000 * *(DWORD *)&pkt->data[4] / gdwDeltaBytesSec; |
|
if (dwMilliseconds >= 1) |
|
dwMilliseconds = 1; |
|
|
|
mem_free_dbg(pkt); |
|
|
|
if (dwMilliseconds) |
|
Sleep(dwMilliseconds); |
|
} |
|
} |
|
|
|
return 0; |
|
} |
|
|
|
void dthread_cleanup() |
|
{ |
|
char *error_buf; |
|
TMegaPkt *tmp; |
|
|
|
if (sghWorkToDoEvent == NULL) { |
|
return; |
|
} |
|
|
|
dthread_running = FALSE; |
|
SetEvent(sghWorkToDoEvent); |
|
if (sghThread != INVALID_HANDLE_VALUE && glpDThreadId != GetCurrentThreadId()) { |
|
if (WaitForSingleObject(sghThread, 0xFFFFFFFF) == -1) { |
|
error_buf = TraceLastError(); |
|
app_fatal("dthread3:\n(%s)", error_buf); |
|
} |
|
CloseHandle(sghThread); |
|
sghThread = INVALID_HANDLE_VALUE; |
|
} |
|
CloseHandle(sghWorkToDoEvent); |
|
sghWorkToDoEvent = NULL; |
|
|
|
while (sgpInfoHead) { |
|
tmp = sgpInfoHead->pNext; |
|
MemFreeDbg(sgpInfoHead); |
|
sgpInfoHead = tmp; |
|
} |
|
} |
|
|
|
DEVILUTION_END_NAMESPACE
|
|
|