wip debug

1 files changed, 52 insertions, 7 deletions

diff --git a/modules/io_codec/c++/io_peer.tmpl.hpp b/modules/io_codec/c++/io_peer.tmpl.hpp
index a9f942d..967a8ab 100644
--- a/modules/io_codec/c++/io_peer.tmpl.hpp
+++ b/modules/io_codec/c++/io_peer.tmpl.hpp
@@ -1,5 +1,10 @@
 namespace saw {
 
+}
+#include <iostream>
+namespace saw {
+
+
 template <typename Incoming, typename Outgoing, typename TransportEncoding, typename ContentEncoding,
 		  typename BufferT>
 streaming_io_peer<Incoming, Outgoing, TransportEncoding, ContentEncoding,
@@ -7,23 +12,46 @@ streaming_io_peer<Incoming, Outgoing, TransportEncoding, ContentEncoding,
 	streaming_io_peer(
 		own<conveyor_feeder<data<Incoming, ContentEncoding>>> feed,
 		own<async_io_stream> str)
-	: streaming_io_peer{std::move(feed), std::move(str), {}, {}, {}} {}
+	: streaming_io_peer{std::move(feed), std::move(str), {}} {}
 
 template <typename Incoming, typename Outgoing, typename TransportEncoding, typename ContentEncoding, typename BufferT>
 streaming_io_peer<Incoming, Outgoing, TransportEncoding, ContentEncoding,
 				  BufferT>::
 	streaming_io_peer(
 		own<conveyor_feeder<data<Incoming, ContentEncoding>>> feed,
-		own<async_io_stream> stream, transport<TransportEncoding> in_codec, BufferT in, BufferT out)
+		own<async_io_stream> stream, transport<TransportEncoding> in_codec)
 	: incoming_feeder_{std::move(feed)},
 	  io_stream_{std::move(stream)}, 
 		in_codec_{std::move(in_codec)},
-	  in_buffer_{std::move(in)}, out_buffer_{std::move(out)},
+	  in_buffer_{},
+		out_buffer_{},
 	  sink_read_{
 		  io_stream_->read_done()
 			  .then([this](size_t bytes) -> error_or<void> {
+
+					std::cout<<"Read done start: "<<bytes<<std::endl;
 				  in_buffer_.write_advance(bytes);
 
+					std::cout<<"buff state: ";
+					std::cout<<in_buffer_.read_composite_length();
+					std::cout<<" ";
+					std::cout<<in_buffer_.read_segment_length();
+					std::cout<<" ";
+					std::cout<<in_buffer_.write_composite_length();
+					std::cout<<" ";
+					std::cout<<in_buffer_.write_segment_length();
+					std::cout<<std::endl;
+					
+					std::cout<<"buff state: ";
+					std::cout<<out_buffer_.read_composite_length();
+					std::cout<<" ";
+					std::cout<<out_buffer_.read_segment_length();
+					std::cout<<" ";
+					std::cout<<out_buffer_.write_composite_length();
+					std::cout<<" ";
+					std::cout<<out_buffer_.write_segment_length();
+					std::cout<<std::endl;
+
 				  if (in_buffer_.write_segment_length() == 0) {
 					  return make_error<err::critical>("Message too long");
 				  }
@@ -51,8 +79,28 @@ streaming_io_peer<Incoming, Outgoing, TransportEncoding, ContentEncoding,
 							return std::move(eo_len.get_error());
 						}
 						auto& len_val = eo_len.get_value();
-						in_buffer_.write_advance(len_val);
+						in_buffer_.read_advance(len_val);
 						in_buff->write_advance(len_val);
+					
+						std::cout<<"read buff state: ";
+						std::cout<<in_buffer_.read_composite_length();
+						std::cout<<" ";
+						std::cout<<in_buffer_.read_segment_length();
+						std::cout<<" ";
+						std::cout<<in_buffer_.write_composite_length();
+						std::cout<<" ";
+						std::cout<<in_buffer_.write_segment_length();
+						std::cout<<std::endl;
+						
+						std::cout<<"write buff state: ";
+						std::cout<<out_buffer_.read_composite_length();
+						std::cout<<" ";
+						std::cout<<out_buffer_.read_segment_length();
+						std::cout<<" ";
+						std::cout<<out_buffer_.write_composite_length();
+						std::cout<<" ";
+						std::cout<<out_buffer_.write_segment_length();
+						std::cout<<std::endl;
 
 						data<Incoming, ContentEncoding> in_data{std::move(in_buff)};
 						incoming_feeder_->feed(std::move(in_data));
@@ -85,9 +133,6 @@ streaming_io_peer<Incoming, Outgoing, TransportEncoding, ContentEncoding,
 	io_stream_->read(&in_buffer_.write(), 1, in_buffer_.write_segment_length());
 }
 
-}
-#include <iostream>
-namespace saw {
 
 template <typename Incoming, typename Outgoing, typename TransportEncoding,
 		  typename ContentEncoding, typename BufferT>