mirrors/recycled-ni-neutrino
1
0
Fork 0
mirror of https://github.com/tuxbox-fork-migrations/recycled-ni-neutrino.git synced 2025-08-28 16:01:10 +02:00
Code Issues Packages Projects Releases Wiki Activity

streamts.cpp StreamInstance::Send: do not block neutrino by faulty stream

Browse Source 
Origin commit data
------------------
Commit: c170b03b9a
Author: Jacek Jendrzej <overx300@gmail.com>
Date: 2014-04-07 (Mon, 07 Apr 2014)
This commit is contained in:
Jacek Jendrzej
2014-04-07 16:01:27 +02:00
parent c1f695680a
commit b5ad1dc8b1
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/driver/streamts.cpp
View File

@@ -113,11 +113,15 @@ bool CStreamInstance::Stop()
bool CStreamInstance::Send(ssize_t r)
{
OpenThreads::ScopedLock<OpenThreads::Mutex> m_lock(mutex);
//OpenThreads::ScopedLock<OpenThreads::Mutex> m_lock(mutex);
stream_fds_t cfds;
mutex.lock();
cfds = fds;
mutex.unlock();
int flags = 0;
if (fds.size() > 1)
if (cfds.size() > 1)
flags = MSG_DONTWAIT;
for (stream_fds_t::iterator it = fds.begin(); it != fds.end(); ++it) {
for (stream_fds_t::iterator it = cfds.begin(); it != cfds.end(); ++it) {
int i = 10;
unsigned char *b = buf;
ssize_t count = r;