- if(_buffer) {
- _messageBuffer << msglist;
- _buffersWaiting.remove(bufferId);
- if(_buffersWaiting.isEmpty()) {
- _buffer = false;
- clock_t start_t = clock();
- qSort(_messageBuffer);
- Client::messageProcessor()->process(_messageBuffer);
- clock_t end_t = clock();
- qDebug() << "Processed" << _messageBuffer.count() << "Messages in" << (float)(end_t - start_t) / CLOCKS_PER_SEC << "seconds ==" << end_t - start_t << "clocks.";
- _messageBuffer.clear();
+ if(isBuffering()) {
+ if(!_requester->buffer(bufferId, msglist)) {
+ // this was the last part to buffer
+ stopBuffering();