Commit 0cc88221 authored by Michael Davis's avatar Michael Davis
Browse files

[ssi_stream] Instruments IStreamBuffer::Push

parent 4ac4a805
......@@ -148,6 +148,7 @@ std::cerr << "[2] " << msg_len << std::endl;
// Get pointer to next record
if(!input_stream.GetDirectBufferPointer(reinterpret_cast<const void**>(&buf_ptr), &buf_len)) break;
std::cerr << "[3] buf_len = " << buf_len;
if(buf_len < static_cast<int>(sizeof(uint32_t))) {
// Size field is split across the boundary, save the partial field and finish
......@@ -158,7 +159,7 @@ std::cerr << "[2] " << msg_len << std::endl;
// Get size of next item on the stream
input_stream.ReadLittleEndian32(&msg_len);
std::cerr << "[3] " << msg_len << std::endl;
std::cerr << ", msg_len = " << msg_len << std::endl;
} while(popRecord(msg_len, input_stream));
}
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment