void HTTPInput::process_data(char *ptr, size_t bytes)
{
- pending_data.insert(pending_data.end(), ptr, ptr + bytes);
{
MutexLock mutex(&stats_mutex);
stats.bytes_received += bytes;
}
assert(encoding == Input::INPUT_ENCODING_METACUBE);
+ pending_data.insert(pending_data.end(), ptr, ptr + bytes);
for ( ;; ) {
// If we don't have enough data (yet) for even the Metacube header, just return.