From a81921f0fd4296f8def24665174062782b3480be Mon Sep 17 00:00:00 2001 From: Mauro Sardara Date: Fri, 16 Feb 2018 17:53:36 +0100 Subject: Added reverse proxy (TCP --> ICN) functionality Change-Id: I2305aa11aea4a37d3d63c6399c49389f78dfd91c Signed-off-by: Mauro Sardara --- http-server/icn_response.cc | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) (limited to 'http-server/icn_response.cc') diff --git a/http-server/icn_response.cc b/http-server/icn_response.cc index 9741556b..630ee001 100644 --- a/http-server/icn_response.cc +++ b/http-server/icn_response.cc @@ -25,14 +25,13 @@ IcnResponse::IcnResponse(std::shared_ptr publi } void IcnResponse::send(const SendCallback &callback) { + std::size_t buffer_size = this->streambuf_.size(); this->streambuf_.commit(this->streambuf_.size()); - std::cout << "Rrsponse Id " << response_id_ << std::endl; - this->publisher_->publishContent(boost::asio::buffer_cast(this->streambuf_.data()), buffer_size, - this->response_lifetime_, + std::chrono::milliseconds(100000), this->response_id_, this->is_last_); @@ -43,4 +42,9 @@ void IcnResponse::send(const SendCallback &callback) { } } +void IcnResponse::setResponseLifetime(const std::chrono::milliseconds &response_lifetime) { + this->publisher_->setTimeout(response_lifetime, true); + Response::setResponseLifetime(response_lifetime); +} + } // end namespace icn_httpserver -- cgit 1.2.3-korg