mirror-games/glest-source
1
0
Fork 0
mirror of https://github.com/glest/glest-source.git synced 2025-08-18 14:11:15 +02:00
Code Issues Projects Releases Wiki Activity

- try to improve network perf

Browse Source
This commit is contained in:
SoftCoder
2015-12-28 22:27:45 -08:00
parent 64139523d4
commit ac0c0eafb9
1 changed files with 13 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
source/shared_lib/sources/platform/posix/socket.cpp
View File

@@ -1702,7 +1702,7 @@ void Socket::setBlock(bool block, PLATFORM_SOCKET socket) {
} }
} }
bool Socket::isReadable(bool lockMutex) { inline bool Socket::isReadable(bool lockMutex) {
if(isSocketValid() == false) return false; if(isSocketValid() == false) return false;
struct timeval tv; struct timeval tv;
@@ -1712,10 +1712,11 @@ bool Socket::isReadable(bool lockMutex) {
fd_set set; fd_set set;
FD_ZERO(&set); FD_ZERO(&set);
MutexSafeWrapper safeMutex(NULL,CODE_AT_LINE); Mutex *lockMutexObj = (lockMutex == true ? dataSynchAccessorRead : NULL);
if(lockMutex == true) { MutexSafeWrapper safeMutex(lockMutexObj,CODE_AT_LINE);
safeMutex.setMutex(dataSynchAccessorRead,CODE_AT_LINE); //if(lockMutex == true) {
} // safeMutex.setMutex(dataSynchAccessorRead,CODE_AT_LINE);
//}
FD_SET(sock, &set); FD_SET(sock, &set);
int i = select((int)sock + 1, &set, NULL, NULL, &tv); int i = select((int)sock + 1, &set, NULL, NULL, &tv);
safeMutex.ReleaseLock(); safeMutex.ReleaseLock();
@@ -1732,7 +1733,7 @@ bool Socket::isReadable(bool lockMutex) {
return result; return result;
} }
bool Socket::isWritable(struct timeval *timeVal, bool lockMutex) { inline bool Socket::isWritable(struct timeval *timeVal, bool lockMutex) {
if(isSocketValid() == false) return false; if(isSocketValid() == false) return false;
struct timeval tv; struct timeval tv;
@@ -1747,10 +1748,12 @@ bool Socket::isWritable(struct timeval *timeVal, bool lockMutex) {
fd_set set; fd_set set;
FD_ZERO(&set); FD_ZERO(&set);
MutexSafeWrapper safeMutex(NULL,CODE_AT_LINE); Mutex *lockMutexObj = (lockMutex == true ? dataSynchAccessorWrite : NULL);
if(lockMutex == true) { MutexSafeWrapper safeMutex(lockMutexObj,CODE_AT_LINE);
safeMutex.setMutex(dataSynchAccessorWrite,CODE_AT_LINE); // MutexSafeWrapper safeMutex(NULL,CODE_AT_LINE);
} // if(lockMutex == true) {
// safeMutex.setMutex(dataSynchAccessorWrite,CODE_AT_LINE);
// }
FD_SET(sock, &set); FD_SET(sock, &set);
int i = select((int)sock + 1, NULL, &set, NULL, &tv); int i = select((int)sock + 1, NULL, &set, NULL, &tv);
safeMutex.ReleaseLock(); safeMutex.ReleaseLock();