ShuriZma
/
fceux
mirror of https://github.com/TASEmulators/fceux.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reduce netplay max tcp transmission size to 8k for ROM transfers.

This commit is contained in:
harry 2024-03-24 22:08:15 -04:00
parent 84654b1c06
commit f50b70b87e
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/drivers/Qt/NetPlay.cpp
View File

@ -315,7 +315,7 @@ int NetPlayServer::sendMsg( NetPlayClient *client, void *msg, size_t msgSize, st
//----------------------------------------------------------------------------- //-----------------------------------------------------------------------------
int NetPlayServer::sendRomLoadReq( NetPlayClient *client ) int NetPlayServer::sendRomLoadReq( NetPlayClient *client )
{ {
constexpr size_t BufferSize = 64 * 1024; constexpr size_t BufferSize = 8 * 1024;
char buf[BufferSize]; char buf[BufferSize];
size_t bytesRead; size_t bytesRead;
long fileSize = 0; long fileSize = 0;
@ -1193,7 +1193,7 @@ void NetPlayClient::onSocketError(QAbstractSocket::SocketError error)
//----------------------------------------------------------------------------- //-----------------------------------------------------------------------------
int NetPlayClient::requestRomLoad( const char *romPath ) int NetPlayClient::requestRomLoad( const char *romPath )
{ {
constexpr size_t BufferSize = 64 * 1024; constexpr size_t BufferSize = 8 * 1024;
char buf[BufferSize]; char buf[BufferSize];
size_t bytesRead; size_t bytesRead;
long fileSize = 0; long fileSize = 0;
@ -1227,6 +1227,7 @@ int NetPlayClient::requestRomLoad( const char *romPath )
{ {
sock->write( buf, bytesRead ); sock->write( buf, bytesRead );
} }
sock->flush();
::fclose(fp); ::fclose(fp);
@ -1355,10 +1356,10 @@ int NetPlayClient::readMessages( void (*msgCallback)( void *userData, void *msgB
int bytesAvailable = sock->bytesAvailable(); int bytesAvailable = sock->bytesAvailable();
readReq = bytesAvailable > 0; readReq = bytesAvailable > 0;
//printf("Read Bytes Available: %lu %i %i\n", ts.toMilliSeconds(), bytesAvailable, recvMsgBytesLeft);
while (readReq) while (readReq)
{ {
//printf("Read Bytes Available: %lu %i %i\n", ts.toMilliSeconds(), bytesAvailable, recvMsgBytesLeft);
if (recvMsgBytesLeft > 0) if (recvMsgBytesLeft > 0)
{ {
bytesAvailable = sock->bytesAvailable(); bytesAvailable = sock->bytesAvailable();