diff options
Diffstat (limited to 'reference/game.c')
| -rw-r--r-- | reference/game.c | 406 |
1 files changed, 0 insertions, 406 deletions
diff --git a/reference/game.c b/reference/game.c index 3711e19..acbdbfa 100644 --- a/reference/game.c +++ b/reference/game.c @@ -37401,412 +37401,6 @@ void __static_initialization_and_destruction_0(int __initialize_p,int __priority return;
}
-
-
-// WARNING: Unknown calling convention -- yet parameter storage is locked
-
-void InitCommunicationThreadStacks(void)
-
-{
- int i;
- int iVar1;
-
- if (UseOwnStacks) {
- memset(CommunicationThreadStacks,0xaa,0x44c0000);
- iVar1 = 0;
- do {
- LastUsingCommunicationThread[iVar1] = 0;
- FreeCommunicationThreadStacks[iVar1] = iVar1;
- iVar1 = iVar1 + 1;
- } while (iVar1 < 0x44c);
- NumberOfFreeCommunicationThreadStacks = 0x44c;
- }
- return;
-}
-
-
-
-// WARNING: Variable defined which should be unmapped: Stack_local
-
-void GetCommunicationThreadStack(int *StackNumber,void **Stack)
-
-{
- int iVar1;
- int iVar2;
- int Number;
- int i;
- int iVar3;
- bool bVar4;
- void **Stack_local;
-
- if (!UseOwnStacks) {
- error(&DAT_0810b9a0);
- *StackNumber = -1;
- *Stack = (void *)0x0;
- return;
- }
- iVar3 = 0;
- Semaphore::down(&CommunicationThreadMutex);
- *StackNumber = -1;
- bVar4 = 0 < NumberOfFreeCommunicationThreadStacks;
- *Stack = (void *)0x0;
- if (bVar4) {
- do {
- iVar1 = FreeCommunicationThreadStacks[iVar3];
- if (LastUsingCommunicationThread[iVar1] == 0) {
-LAB_080dbcd6:
- *StackNumber = iVar1;
- NumberOfFreeCommunicationThreadStacks = NumberOfFreeCommunicationThreadStacks + -1;
- *Stack = CommunicationThreadStacks + iVar1 * 0x10000;
- FreeCommunicationThreadStacks[iVar3] =
- FreeCommunicationThreadStacks[NumberOfFreeCommunicationThreadStacks];
- break;
- }
- iVar2 = kill(LastUsingCommunicationThread[iVar1],0);
- if (iVar2 == -1) goto LAB_080dbcd6;
- iVar3 = iVar3 + 1;
- } while (iVar3 < NumberOfFreeCommunicationThreadStacks);
- }
- Semaphore::up(&CommunicationThreadMutex);
- return;
-}
-
-
-
-void AttachCommunicationThreadStack(int StackNumber)
-
-{
- __pid_t _Var1;
-
- _Var1 = getpid();
- LastUsingCommunicationThread[StackNumber] = _Var1;
- return;
-}
-
-
-
-void ReleaseCommunicationThreadStack(int StackNumber)
-
-{
- Semaphore::down(&CommunicationThreadMutex);
- FreeCommunicationThreadStacks[NumberOfFreeCommunicationThreadStacks] = StackNumber;
- NumberOfFreeCommunicationThreadStacks = NumberOfFreeCommunicationThreadStacks + 1;
- Semaphore::up(&CommunicationThreadMutex);
- return;
-}
-
-
-
-// WARNING: Unknown calling convention -- yet parameter storage is locked
-
-void ExitCommunicationThreadStacks(void)
-
-{
- int i;
- int iVar1;
- int HighestStackAddress;
- int iVar2;
- int LowestStackAddress;
- int iVar3;
- int Stack;
- int iVar4;
-
- if (UseOwnStacks) {
- if (NumberOfFreeCommunicationThreadStacks != 0x44c) {
- error("FreeCommunicationThreadStacks: Nicht alle Stacks freigegeben.\n");
- }
- iVar2 = -1;
- iVar3 = 0x10000;
- iVar4 = 0;
- do {
- iVar1 = 0;
- do {
- if (CommunicationThreadStacks[iVar4 * 0x10000 + iVar1] != 0xaa) {
- if (iVar2 < iVar1) {
- iVar2 = iVar1;
- }
- if (iVar1 < iVar3) {
- iVar3 = iVar1;
- }
- }
- iVar1 = iVar1 + 1;
- } while (iVar1 < 0x10000);
- iVar4 = iVar4 + 1;
- } while (iVar4 < 0x44c);
- if (0x10000 - (iVar2 - iVar3) < 0x8000) {
- error("Maximale Stack-Ausdehnung: %d..%d\n",iVar3,iVar2);
- }
- }
- return;
-}
-
-
-
-// WARNING: Unknown calling convention -- yet parameter storage is locked
-
-void InitLoadHistory(void)
-
-{
- int i;
- int iVar1;
-
- iVar1 = 0;
- do {
- LoadHistory[iVar1] = 0;
- iVar1 = iVar1 + 1;
- } while (iVar1 < 0x168);
- LoadHistoryPointer = 0;
- TotalSend = 0;
- TotalLoad = 0;
- LagEnd = 0;
- TotalRecv = 0;
- EarliestFreeAccountAdmissionRound = 0;
- InitLog("netload");
- return;
-}
-
-
-
-// WARNING: Unknown calling convention -- yet parameter storage is locked
-
-bool LagDetected(void)
-
-{
- return RoundNr <= LagEnd;
-}
-
-
-
-void NetLoad(int Amount,bool Send)
-
-{
- Semaphore::down(&CommunicationThreadMutex);
- if (Send) {
- TotalSend = TotalSend + Amount;
- }
- else {
- TotalRecv = TotalRecv + Amount;
- }
- Semaphore::up(&CommunicationThreadMutex);
- return;
-}
-
-
-
-// WARNING: Unknown calling convention -- yet parameter storage is locked
-
-void NetLoadSummary(void)
-
-{
- Semaphore::down(&CommunicationThreadMutex);
- Log("netload","gesendet: %d Bytes.\n",TotalSend);
- Log("netload","empfangen: %d Bytes.\n",TotalRecv);
- TotalSend = 0;
- TotalRecv = 0;
- Semaphore::up(&CommunicationThreadMutex);
- return;
-}
-
-
-
-// WARNING: Unknown calling convention -- yet parameter storage is locked
-
-void NetLoadCheck(void)
-
-{
- int Delay;
- int iVar1;
- TConnection *this;
- ulong *puVar2;
- TConnection *Connection;
- int iVar3;
- int DeltaRecv;
- int iVar4;
- uint local_c;
-
- iVar4 = NetLoadCheck::LastRecv;
- NetLoadCheck::LastRecv = TotalRecv;
- iVar4 = TotalRecv - iVar4;
- if (-1 < iVar4) {
- iVar1 = GetPlayersOnline();
- if (iVar1 == 0) {
- iVar4 = 0;
- }
- else {
- iVar1 = GetPlayersOnline();
- iVar4 = iVar4 / iVar1;
- }
- iVar1 = LoadHistory[LoadHistoryPointer];
- LoadHistory[LoadHistoryPointer] = iVar4;
- iVar3 = LoadHistoryPointer + 1;
- TotalLoad = (TotalLoad - iVar1) + iVar4;
- LoadHistoryPointer = 0;
- if (iVar3 != 0x168) {
- LoadHistoryPointer = iVar3;
- }
- if (((0xe0f < RoundNr) && (iVar1 = GetPlayersOnline(), 0x31 < iVar1)) &&
- (iVar4 < TotalLoad / 0x2d0)) {
- Log("game","Lag erkannt!\n");
- LagEnd = RoundNr + 0x1e;
- if (PremiumPlayerBuffer == 0) {
- iVar4 = 0x3c;
- }
- else {
- iVar4 = GetPlayersOnline();
- iVar4 = ((iVar4 - (MaxPlayers + PremiumPlayerBuffer * -2)) * 0x1e) /
- PremiumPlayerBuffer;
- }
- local_c = iVar4 + RoundNr;
- puVar2 = &EarliestFreeAccountAdmissionRound;
- if (EarliestFreeAccountAdmissionRound < iVar4 + RoundNr) {
- puVar2 = &local_c;
- }
- EarliestFreeAccountAdmissionRound = *puVar2;
- this = GetFirstConnection();
- while (this != (TConnection *)0x0) {
- if (this->State - CONNECTION_LOGIN < 4) {
- TConnection::EmergencyPing(this);
- }
- this = GetNextConnection();
- }
- }
- }
- return;
-}
-
-
-
-bool WriteToSocket(TConnection *Connection,uchar *Buffer,int Size)
-
-{
- uchar *__block;
- int iVar1;
- ssize_t sVar2;
- int *piVar3;
- int Offset;
- size_t __n;
- int in_stack_ffffffbc;
- int local_30;
- int Chances;
- TWriteBuffer WriteBuffer;
-
- if ((Size & 7U) != 0) {
- do {
- iVar1 = rand_r(&Connection->RandomSeed);
- Buffer[Size + 2] = (uchar)iVar1;
- Size = Size + 1;
- } while ((Size & 7U) != 0);
- }
- __n = Size + 2;
- iVar1 = 2;
- if (2 < (int)__n) {
- do {
- __block = Buffer + iVar1;
- iVar1 = iVar1 + 8;
- TXTEASymmetricKey::encrypt(&Connection->SymmetricKey,(char *)__block,in_stack_ffffffbc);
- } while (iVar1 < (int)__n);
- }
- TWriteBuffer::TWriteBuffer((TWriteBuffer *)&Chances,Buffer,__n);
- TWriteBuffer::writeWord((TWriteBuffer *)&Chances,(ushort)Size);
- local_30 = 0x32;
-joined_r0x080dc15b:
- if ((int)__n < 1) {
- Semaphore::down(&CommunicationThreadMutex);
- TotalSend = TotalSend + Size + 0x32U;
- Semaphore::up(&CommunicationThreadMutex);
- return true;
- }
- iVar1 = TConnection::GetSocket(Connection);
- sVar2 = write(iVar1,Buffer,__n);
- if (sVar2 == -1) goto LAB_080dc1f0;
- goto LAB_080dc182;
-LAB_080dc1f0:
- piVar3 = __errno_location();
- if (*piVar3 != 4) {
- if ((*piVar3 != 0xb) || (local_30 < 1)) {
- piVar3 = __errno_location();
- iVar1 = *piVar3;
- if (((iVar1 == 0x68) || (iVar1 == 0x20)) || (iVar1 == 0xb)) {
- iVar1 = TConnection::GetSocket(Connection);
- Log("game","Verbindung an Socket %d zusammengebrochen.\n",iVar1);
- }
- else {
-LAB_080dc182:
- if (0 < sVar2) {
- __n = __n - sVar2;
- Buffer = Buffer + sVar2;
- goto joined_r0x080dc15b;
- }
- iVar1 = TConnection::GetSocket(Connection);
- piVar3 = __errno_location();
- error("WriteToSocket: Fehler %d beim Senden an Socket %d.\n",*piVar3,iVar1);
- }
- return false;
- }
- DelayThread(0,100000);
- local_30 = local_30 + -1;
- }
- goto joined_r0x080dc15b;
-}
-
-
-
-bool SendLoginMessage(TConnection *Connection,int Type,char *Message,int WaitingTime)
-
-{
- int Size;
- bool bVar1;
- size_t sVar2;
- char *Text;
- undefined1 local_15c [4];
- TWriteBuffer Buffer;
- uchar Data [302];
-
- if (Type - 0x14U < 3) {
- if (Message == (char *)0x0) {
- error("SendLoginMessage: Message ist NULL.\n");
- return true;
- }
- if (Type == 0x16) {
- bVar1 = false;
- if ((0 < WaitingTime) && (WaitingTime < 0x100)) {
- bVar1 = true;
- }
- if (!bVar1) {
- Text = &DAT_0810bb40;
- goto LAB_080dc3c0;
- }
- }
- // try { // try from 080dc2d0 to 080dc390 has its CatchHandler @ 080dc3f0
- TWriteBuffer::TWriteBuffer
- ((TWriteBuffer *)local_15c,(uchar *)((int)&Buffer.Position + 2),300);
- TWriteBuffer::writeWord((TWriteBuffer *)local_15c,0);
- TWriteBuffer::writeByte((TWriteBuffer *)local_15c,(uchar)Type);
- sVar2 = strlen(Message);
- if (sVar2 < 0x123) {
- TWriteStream::writeString((TWriteStream *)local_15c,Message);
- if (Type == 0x16) {
- TWriteBuffer::writeByte((TWriteBuffer *)local_15c,(uchar)WaitingTime);
- }
- Size = Buffer.Size;
- Buffer.Size = 0;
- TWriteBuffer::writeWord((TWriteBuffer *)local_15c,(short)Size - 2);
- bVar1 = WriteToSocket(Connection,(uchar *)&Buffer.Position,Size);
- return bVar1;
- }
- error("SendLoginMessage: Botschaft zu lang (%s).\n",Message);
- }
- else {
- Text = &DAT_0810bbc0;
- WaitingTime = Type;
-LAB_080dc3c0:
- error(Text,WaitingTime);
- }
- return true;
-}
-
-
-
bool SendData(TConnection *Connection)
{
|