diff options
Diffstat (limited to 'apps/http-proxy')
| -rw-r--r-- | apps/http-proxy/src/forwarder_interface.cc | 3 | ||||
| -rw-r--r-- | apps/http-proxy/src/http_proxy.cc | 1 | ||||
| -rw-r--r-- | apps/http-proxy/src/icn_receiver.cc | 2 |
3 files changed, 3 insertions, 3 deletions
diff --git a/apps/http-proxy/src/forwarder_interface.cc b/apps/http-proxy/src/forwarder_interface.cc index d80939b8b..7d8235ac6 100644 --- a/apps/http-proxy/src/forwarder_interface.cc +++ b/apps/http-proxy/src/forwarder_interface.cc @@ -13,9 +13,8 @@ * limitations under the License. */ -#include <hicn/http-proxy/forwarder_interface.h> - #include <arpa/inet.h> +#include <hicn/http-proxy/forwarder_interface.h> #include <hicn/transport/utils/log.h> #include <chrono> diff --git a/apps/http-proxy/src/http_proxy.cc b/apps/http-proxy/src/http_proxy.cc index 262fcb8e1..c252afe88 100644 --- a/apps/http-proxy/src/http_proxy.cc +++ b/apps/http-proxy/src/http_proxy.cc @@ -225,6 +225,7 @@ class HTTPClientConnectionCallback : interface::ConsumerSocket::ReadCallback { const char* reply = nullptr; if (result) { reply = HTTPMessageFastParser::http_ok; + prefix_hash_ = configured_prefix; } else { reply = HTTPMessageFastParser::http_failed; } diff --git a/apps/http-proxy/src/icn_receiver.cc b/apps/http-proxy/src/icn_receiver.cc index 8823907dc..23e5b5623 100644 --- a/apps/http-proxy/src/icn_receiver.cc +++ b/apps/http-proxy/src/icn_receiver.cc @@ -189,7 +189,7 @@ void AsyncConsumerProducer::publishContent(const uint8_t* data, } it->second.first += - producer_socket_.produce(name, data, size, is_last, start_suffix); + producer_socket_.produceStream(name, data, size, is_last, start_suffix); if (is_last) { it->second.second = false; |