buffereddatastream.cpp   buffereddatastream.cpp 
skipping to change at line 96 skipping to change at line 96
} }
return QIODevice::timerEvent(event); return QIODevice::timerEvent(event);
} }
void BufferedDataStream::incomingDataReady() void BufferedDataStream::incomingDataReady()
{ {
Q_D(BufferedDataStream); Q_D(BufferedDataStream);
int bytes = device()->bytesAvailable(); int bytes = device()->bytesAvailable();
d->ensureSize(bytes); d->ensureSize(bytes);
device()->read(d->buffer.data() + d->offset + d->len, bytes); device()->read(d->buffer.data() + d->offset + d->len, bytes);
// qDebug("< \"%s\"", QByteArray(d->buffer.constData() + d->offset + d- >len, bytes).constData()); // Logger::debug("< \"%s\"", QByteArray(d->buffer.constData() + d->offs et + d->len, bytes).constData());
d->len += bytes; d->len += bytes;
emit readyRead(); emit readyRead();
} }
qint64 BufferedDataStream::writeData(const char *data, qint64 len) qint64 BufferedDataStream::writeData(const char *data, qint64 len)
{ {
Q_D(BufferedDataStream); Q_D(BufferedDataStream);
if (len <= 0) if (len <= 0)
return 0; return 0;
d->outBuffer.append(data, len); d->outBuffer.append(data, len);
skipping to change at line 118 skipping to change at line 118
d->timer.start(0, this); d->timer.start(0, this);
return len; return len;
} }
void BufferedDataStream::flush() void BufferedDataStream::flush()
{ {
Q_D(BufferedDataStream); Q_D(BufferedDataStream);
foreach (XmlStreamHandler *handler, *d->handlers) foreach (XmlStreamHandler *handler, *d->handlers)
handler->handleOutgoingData(d->outBuffer.constData(), d->out Buffer.size()); handler->handleOutgoingData(d->outBuffer.constData(), d->out Buffer.size());
device()->write(d->outBuffer.constData(), d->outBuffer.size()); device()->write(d->outBuffer.constData(), d->outBuffer.size());
// qDebug("> \"%s\"", d->outBuffer.constData()); // Logger::debug("> \"%s\"", d->outBuffer.constData());
d->outBuffer.clear(); d->outBuffer.clear();
} }
qint64 BufferedDataStream::readData(char *data, qint64 maxlen) qint64 BufferedDataStream::readData(char *data, qint64 maxlen)
{ {
Q_D(BufferedDataStream); Q_D(BufferedDataStream);
int len = qMin<int>(maxlen, d->len); int len = qMin<int>(maxlen, d->len);
qMemCopy(data, d->buffer.data() + d->offset, len); qMemCopy(data, d->buffer.data() + d->offset, len);
// foreach (XmlStreamHandler *handler, *d->handlers) // foreach (XmlStreamHandler *handler, *d->handlers)
// handler->handleIncomingData(d->buffer.data() + d->offset, le n); // handler->handleIncomingData(d->buffer.data() + d->offset, le n);
 End of changes. 2 change blocks. 
2 lines changed or deleted 2 lines changed or added

This html diff was produced by rfcdiff 1.41. The latest version is available from http://tools.ietf.org/tools/rfcdiff/