hydrar/mistserver
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fixed buffer CPU usage when streams are ended.

Browse source
This commit is contained in:
Thulinma 2014-01-17 16:51:12 +01:00
parent e1e2ecf251
commit 3123aeb32a
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/buffer/buffer.cpp
View file

@ -55,13 +55,16 @@ namespace Buffer {
///\brief A function to handle input data. ///\brief A function to handle input data.
///\param conn A socket reference. ///\param conn A socket reference.
void handlePushIn(Socket::Connection & conn){ void handlePushIn(Socket::Connection & conn){
#if defined(_TTHREAD_POSIX_) && !(defined(__FreeBSD__) || defined(__APPLE__) || defined(__MACH__) || defined(_WIN32) || defined(__CYGWIN__)) #if defined(_TTHREAD_POSIX_) && defined(WITH_THREADNAMES) && !(defined(__FreeBSD__) || defined(__APPLE__) || defined(__MACH__) || defined(_WIN32) || defined(__CYGWIN__))
pthread_setname_np(pthread_self(), "Push Input"); pthread_setname_np(pthread_self(), "Push Input");
#endif #endif
conn.setBlocking(true); conn.setBlocking(true);
int sockNo = 0; int sockNo = 0;
while (buffer_running && conn.connected()){ while (buffer_running && conn.connected()){
thisStream->parsePacket(conn); while (thisStream->parsePacket(conn)){
//do nothing while parsing
}
Util::sleep(10);//sleep to prevent high CPU usage
} }
if (buffer_running){ if (buffer_running){
thisStream->endStream(); thisStream->endStream();