Git-Mirrors/RetroShare
1
0
Fork 0
mirror of https://github.com/RetroShare/RetroShare.git synced 2024-10-01 02:35:48 -04:00
Code Issues Actions Packages Projects Releases Wiki Activity

2nd attempt at fixing tcponudp bug. To be tested.

Browse Source 
git-svn-id: http://svn.code.sf.net/p/retroshare/code/trunk@7740 b45a01b8-16f6-495d-af2f-9b41ad6348cc
This commit is contained in:
csoler 2014-12-08 22:17:06 +00:00
parent d8d5fdd24c
commit 71cd1e0030
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
libretroshare/src/pqi/pqithreadstreamer.cc
View File

@ -46,7 +46,8 @@ bool pqithreadstreamer::RecvItem(RsItem *item)
int pqithreadstreamer::tick()
{
tick_bio();
RsStackMutex stack(mThreadMutex);
tick_bio();
return 0;
}
@ -82,8 +83,8 @@ void pqithreadstreamer::run()
mRunning = false;
return;
}
}
data_tick();
}
data_tick();
}
}
@ -146,7 +147,10 @@ int pqithreadstreamer::data_tick()
//std::cerr << "pqithreadstream::data_tick() tick_recv";
//std::cerr << std::endl;
tick_recv(recv_timeout);
{
RsStackMutex stack(mThreadMutex);
tick_recv(recv_timeout);
}
// Push Items, Outside of Mutex.
RsItem *incoming = NULL;
@ -158,7 +162,10 @@ int pqithreadstreamer::data_tick()
//std::cerr << "pqithreadstream::data_tick() tick_send";
//std::cerr << std::endl;
tick_send(0);
{
RsStackMutex stack(mThreadMutex);
tick_send(0);
}
if (sleep_period)
{