Revision f9b7ce06 src/connection.cpp

View differences:

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

  

Also available in: Unified diff