diff --git a/stepmania/src/NetworkSyncManager.cpp b/stepmania/src/NetworkSyncManager.cpp index dbb214da1c..7e32e61ce2 100644 --- a/stepmania/src/NetworkSyncManager.cpp +++ b/stepmania/src/NetworkSyncManager.cpp @@ -14,6 +14,16 @@ void NetworkSyncManager::ReportSongOver() { } void NetworkSyncManager::StartRequest() { } void NetworkSyncManager::DisplayStartupStatus() { } void NetworkSyncManager::Update( float fDeltaTime ) { } +void NetworkSyncManager::WriteNT() { } +void NetworkSyncManager::Write1() { } +void NetworkSyncManager::Write2() { } +void NetworkSyncManager::Write4() { } +void NetworkSyncManager::ProcessInput() { } +void NetworkSyncManager::Read1() { } +void NetworkSyncManager::Read2() { } +void NetworkSyncManager::Read4() { } +void NetworkSyncManager::ReadNT() { } + #else #include "ezsockets.h" @@ -294,7 +304,8 @@ void NetworkSyncManager::Update(float fDeltaTime) void NetworkSyncManager::ProcessInput() { //If we're disconnected, just exit - if (NetPlayerClient->state!=NetPlayerClient->skCONNECTED) + if ((NetPlayerClient->state!=NetPlayerClient->skCONNECTED) || + NetPlayerClient->IsError()) return; //load new data into buffer diff --git a/stepmania/src/ezsockets.cpp b/stepmania/src/ezsockets.cpp index 8a04222d1b..0f44e7f3c4 100644 --- a/stepmania/src/ezsockets.cpp +++ b/stepmania/src/ezsockets.cpp @@ -214,7 +214,8 @@ void EzSockets::update() //Check for reading while (CanRead() && !IsError()) - pUpdateRead(); + if (pUpdateRead()<1) + break; if (CanWrite() && (outBuffer.length()>0)) pUpdateWrite(); @@ -259,16 +260,15 @@ int EzSockets::PeekData(char *data, unsigned int bytes) while ((inBuffer.length()Info("TTY:%d",inBuffer.length() unsigned int size=0; PeekData((char*)&size,4); size = ntohl(size); - +// LOG->Info("TXA:%d",size); while ((inBuffer.length()<(size+4)) && !IsError()) { pUpdateRead(); @@ -325,7 +329,7 @@ int EzSockets::PeekPack(char * data, unsigned int max) unsigned int size=0; PeekData((char*)&size,4); size = ntohl(size); - if (inBuffer.length()<(size+4)) + if ((inBuffer.length()<(size+4)) || (inBuffer.length()<=4)) return (-1); string tBuff(inBuffer.substr(4,size));