Skip to content
Snippets Groups Projects
Commit 8240bb02 authored by Michael Davis's avatar Michael Davis
Browse files

[ssi_stream] Removes IStreamBuffer instrumentation

parent e5d4e2a4
No related branches found
No related tags found
No related merge requests found
......@@ -18,7 +18,6 @@
#pragma once
#include <iostream> // delete me
#include <google/protobuf/io/coded_stream.h>
#include "XrdSsiPbException.hpp"
......@@ -121,7 +120,6 @@ void IStreamBuffer<DataType>::Push(const char *buf_ptr, int buf_len)
input_stream.Skip(bytes_to_copy);
google::protobuf::io::CodedInputStream::ReadLittleEndian32FromArray(m_split_buffer.get(), &msg_len);
std::cerr << "[1] " << msg_len << std::endl;
popRecord(msg_len, input_stream);
} else {
// The payload is split across the boundary, copy the entire record
......@@ -136,7 +134,6 @@ std::cerr << "[1] " << msg_len << std::endl;
input_stream.Skip(bytes_to_copy);
google::protobuf::io::CodedInputStream split_stream(reinterpret_cast<const uint8_t*>(m_split_buffer.get() + sizeof(uint32_t)), msg_len);
std::cerr << "[2] " << msg_len << std::endl;
popRecord(msg_len, split_stream);
}
......@@ -150,7 +147,6 @@ 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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment