diff options
author | Mauro Sardara <msardara+fdio@cisco.com> | 2017-02-22 23:24:21 +0100 |
---|---|---|
committer | Mauro Sardara <msardara+fdio@cisco.com> | 2017-02-22 23:24:21 +0100 |
commit | 975b5709addd72cba7184f94f2805f1c42e07dbe (patch) | |
tree | f89f813f04f6ba3f7558ba7bb9f07df1f9bdccef /http-server/icn_response.cc | |
parent | 9b30fc10fb1cbebe651e5a107e8ca5b24de54675 (diff) |
First commit: http-server
Change-Id: Ia527fe3065016404b0ea752ddc9e15c96288ed86
Signed-off-by: Mauro Sardara <msardara+fdio@cisco.com>
Diffstat (limited to 'http-server/icn_response.cc')
-rw-r--r-- | http-server/icn_response.cc | 44 |
1 files changed, 44 insertions, 0 deletions
diff --git a/http-server/icn_response.cc b/http-server/icn_response.cc new file mode 100644 index 00000000..6fe8b1e1 --- /dev/null +++ b/http-server/icn_response.cc @@ -0,0 +1,44 @@ +/* + * Copyright (c) 2017 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include "icn_response.h" + +namespace icn_httpserver { + +IcnResponse::IcnResponse(std::shared_ptr<icnet::ProducerSocket> producer, + std::string ndn_name, + std::string ndn_path, + int response_id) + : producer_(producer), ndn_name_(ndn_name), ndn_path_(ndn_path), response_id_(response_id) { +} + +void IcnResponse::send(const SendCallback &callback) { + std::size_t buffer_size = this->streambuf_.size(); + this->streambuf_.commit(this->streambuf_.size()); + + this->producer_->produce(icnet::Name(/*this->ndn_name*/), + boost::asio::buffer_cast<const uint8_t *>(this->streambuf_.data()), + buffer_size, + this->response_id_, + this->is_last_); + + this->streambuf_.consume(buffer_size); + + if (callback) { + callback(boost::system::error_code()); + } +} + +} // end namespace icn_httpserver |