diff options
Diffstat (limited to 'apps/http-proxy/src')
| -rw-r--r-- | apps/http-proxy/src/ATSConnector.cc | 2 | ||||
| -rw-r--r-- | apps/http-proxy/src/IcnReceiver.cc | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/apps/http-proxy/src/ATSConnector.cc b/apps/http-proxy/src/ATSConnector.cc index 81f7a776a..2a2f73c3e 100644 --- a/apps/http-proxy/src/ATSConnector.cc +++ b/apps/http-proxy/src/ATSConnector.cc @@ -161,7 +161,7 @@ void ATSConnector::tryReconnection() { is_reconnection_ = true; io_service_.post([this]() { if (socket_.is_open()) { - socket_.shutdown(asio::ip::tcp::socket::shutdown_type::shutdown_both); + // socket_.shutdown(asio::ip::tcp::socket::shutdown_type::shutdown_both); socket_.close(); } startConnectionTimer(); diff --git a/apps/http-proxy/src/IcnReceiver.cc b/apps/http-proxy/src/IcnReceiver.cc index ee8ef0823..76e2bd10b 100644 --- a/apps/http-proxy/src/IcnReceiver.cc +++ b/apps/http-proxy/src/IcnReceiver.cc @@ -130,7 +130,7 @@ void AsyncConsumerProducer::manageIncomingInterest( HTTPMessageFastParser::isMpdRequest(payload->data(), payload->length()); chunk_number_map_.emplace(name, 0); - response_name_queue_.emplace(std::move(name), is_mpd ? 500 : 10000); + response_name_queue_.emplace(std::move(name), is_mpd ? 1000 : 10000); connector_.send(payload, [packet = std::move(packet)]() {}); } |