Revision f9b7ce06
| src/connection.cpp | ||
|---|---|---|
| 39 | 39 |
tuned(false), retuning(false), |
| 40 | 40 |
tm(tm), removeMe(false), |
| 41 | 41 |
stopTime(0), |
| 42 |
interrupted(false) |
|
| 42 |
interrupted(false), |
|
| 43 |
lostPacket(false) |
|
| 43 | 44 |
{
|
| 44 | 45 |
if (debugLevel > 1) |
| 45 | 46 |
std::cerr << "New client connection" << std::endl; |
| 46 | 47 |
|
| 47 |
dataOutput = new OutputBuffer(dataFD, 16384, 65536);
|
|
| 48 |
dataOutput = new OutputBuffer(dataFD, 16384, 262144);
|
|
| 48 | 49 |
} |
| 49 | 50 |
|
| 50 | 51 |
Connection::~Connection() |
| ... | ... | |
| 216 | 217 |
setPriority(p); |
| 217 | 218 |
tuned = true; |
| 218 | 219 |
interrupted = false; |
| 220 |
lostPacket = false; |
|
| 219 | 221 |
return result; |
| 220 | 222 |
} |
| 221 | 223 |
|
| ... | ... | |
| 244 | 246 |
{
|
| 245 | 247 |
// Receive data from the Demuxers and forward it to the clients |
| 246 | 248 |
if (!dataOutput->write((char *) data, size)) {
|
| 247 |
std::cerr << "Client not reading data connection" << std::endl; |
|
| 248 |
removeMe = true; |
|
| 249 |
if (!lostPacket) {
|
|
| 250 |
std::cerr << "Warning: client not reading data connection fast enough (dropping packets)" << std::endl; |
|
| 251 |
lostPacket = true; |
|
| 252 |
} |
|
| 249 | 253 |
} |
| 250 | 254 |
} |
| 251 | 255 |
|
| src/connection.h | ||
|---|---|---|
| 84 | 84 |
bool removeMe; |
| 85 | 85 |
time_t stopTime; |
| 86 | 86 |
bool interrupted; |
| 87 |
bool lostPacket; |
|
| 87 | 88 |
}; |
| 88 | 89 |
|
| 89 | 90 |
|
Also available in: Unified diff