diff --git a/xroot_ssi_pb/XrdSsiPbIStreamBuffer.hpp b/xroot_ssi_pb/XrdSsiPbIStreamBuffer.hpp index 602da930734a26433ce25e07a700344f3ac6554b..89baf3c0b7b7dfc32bfb87dd5098d79e5e0367cd 100644 --- a/xroot_ssi_pb/XrdSsiPbIStreamBuffer.hpp +++ b/xroot_ssi_pb/XrdSsiPbIStreamBuffer.hpp @@ -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