Original Post
I don't know if this is a good system or not, but on the computer that is going to host my game, three threads are spawned. One is to listen for new connections (it also eventually needs to check for dead connections and keep the player connectivity info up to date). Another thread recieves information from a client and sends it out to the other clients. The last thread is the core thread that processes enemy information and AI and whatnot. I am able to produce a somewhat minimal example of my problem. Using the three threads as-is shown below, my game does some funny things. It starts out at about 98 fps, then after maybe 10-15 seconds it drops to around 47 frames per second and laggs something nasty. If you leave it like that for awile it eventually freezes. Not using the three threads, It stays at about 130 frames per second and doesn't drop or freeze. Here are the three threads, all are spawned in the order they are in the code when the host computer clicks on host. Any ideas? Thank you Dev578 [Edited by - dev578 on August 28, 2006 9:49:03 AM]
DWORD WINAPI ListeningThread(LPVOID pParam)
{
CMultiPlayer *p = (CMultiPlayer*)pParam;
// Wait for a client
sockaddr_in addr = {0};
int Size = sizeof(addr);
p->ClientNumber = -1;
fd_set Input_set, Exc_set;
int s;
timeval timeout;
timeout.tv_sec = 4;
timeout.tv_usec = 4000000;
FD_ZERO(&Input_set);
FD_ZERO(&Exc_set);
FD_SET(p->listeningSocket, &Input_set);
FD_SET(p->listeningSocket, &Exc_set);
while (true)
{
// Do the select
s = select(0, &Input_set, NULL, &Exc_set, &timeout);
if (p->CloseThreads == true)
{
p->ThreadCount--;
//OutputDebugString("ListeningThread returned\n");
return 0;
}
if (s > 0 && !FD_ISSET(p->listeningSocket, &Exc_set) && FD_ISSET(p->listeningSocket, &Input_set))
{
p->ClientNumber++;
p->theClient[p->ClientNumber] = accept(p->listeningSocket,
(sockaddr*)&addr,
&Size);
if (p->theClient[p->ClientNumber] == INVALID_SOCKET)
{
//nret = WSAGetLastError();
//ReportError(nret, "accept()");
OutputDebugString("accept failed\n");
WSACleanup();
return 1;
}
sprintf(p->ActionText[p->CurrentArray],"Someone Connected");
if (p->CurrentArray != 3)
p->CurrentArray++;
p->nClients++;
p->nClientArray[p->ClientNumber] = 1;
//send the client a packet with his client ID and the number of players and enemies
char buf[4];
buf[0] = 2;
buf[1] = (char)p->ClientNumber;
buf[2] = (char)p->nNumEnemies;
buf[3] = (char)p->nNumPlayers;
int Size = 4;
p->sendall(p->theClient[p->ClientNumber],buf,&Size);
}
}
return 0;
}
DWORD WINAPI ClientCommunicationsThread(LPVOID pParam)
{
CMultiPlayer *p = (CMultiPlayer*)pParam;
int nret;
char locationbuffer[256];
fd_set Input_set, Exc_set;
int s;
timeval timeout;
timeout.tv_sec = 4;
timeout.tv_usec = 4000000;
FD_ZERO(&Input_set);
FD_ZERO(&Exc_set);
for (int i = 0; i < p->nClients; i++)
{
FD_SET(p->theClient, &Input_set);
FD_SET(p->theClient, &Exc_set);
}
while (true)
{
s = select(0, &Input_set, NULL, &Exc_set, &timeout);
if (p->CloseThreads == true)
{
p->ThreadCount--;
//OutputDebugString("ClientThread returned\n");
return 0;
}
if (s > 0)
{
for (int i = 0; i < p->nClients; i++)
{
if (!FD_ISSET(p->theClient, &Exc_set) && FD_ISSET(p->theClient, &Input_set))
{
nret = recv(p->theClient,locationbuffer,sizeof(locationbuffer),0);
if (nret != -1)
{
for (int c = 0; c < p->nClients; c++)
{
if (p->nClientArray[c] == 1 && c != i)
{
p->sendall(p->theClient[c],locationbuffer,&nret);
}
}
}
}
}
}
}
return 0;
}
DWORD WINAPI ServerThread(LPVOID pParam)
{
CMultiPlayer *p = (CMultiPlayer*)pParam;
char buf[3];
int OldAction = 0;
while (true)
{
if (p->CloseThreads == true)
{
p->ThreadCount--;
//OutputDebugString("ServerThread returned\n");
return 0;
}
for (int i = 0; i < p->nNumEnemies; i++)
{
p->m_NEnemy.Update();
OldAction = p->m_NEnemy.Action;
p->m_NEnemy.AIMove();
//look for a change of action
if (OldAction != p->m_NEnemy.Action)
{
OldAction = p->m_NEnemy.Action;
//ID for an enemy packet
buf[0] = 3;
//ID of the enemy
buf[1] = (char)i;
//New action of the enemy
buf[2] = (char)(p->m_NEnemy[0].Action);
for (int i = 0; i < p->nNumPlayers; i++)
{
int Size = 3;
int retval = p->sendall(p->theClient[0],buf,&Size);
}
//TODO snap enemy position with NEnemy position
}
}
Sleep(100);
}
return 0;
}
