diff options
Diffstat (limited to 'libtransport/src/protocols/reassembly.h')
-rw-r--r-- | libtransport/src/protocols/reassembly.h | 67 |
1 files changed, 67 insertions, 0 deletions
diff --git a/libtransport/src/protocols/reassembly.h b/libtransport/src/protocols/reassembly.h new file mode 100644 index 000000000..fdc9f2a05 --- /dev/null +++ b/libtransport/src/protocols/reassembly.h @@ -0,0 +1,67 @@ +/* + * Copyright (c) 2017-2019 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. + */ + +#pragma once + +#include <core/facade.h> + +namespace transport { + +namespace implementation { +class ConsumerReadCallback; +class ConsumerSocket; +} // namespace implementation + +namespace protocol { + +class TransportProtocol; +class Indexer; + +// Forward Declaration +class ManifestManager; + +class Reassembly { + public: + class ContentReassembledCallback { + public: + virtual void onContentReassembled(std::error_code ec) = 0; + }; + + Reassembly(implementation::ConsumerSocket *icn_socket, + TransportProtocol *transport_protocol) + : reassembly_consumer_socket_(icn_socket), + transport_protocol_(transport_protocol) {} + + virtual ~Reassembly() = default; + + virtual void reassemble(core::ContentObject::Ptr &&content_object) = 0; + virtual void reassemble( + std::unique_ptr<core::ContentObjectManifest> &&manifest) = 0; + virtual void reInitialize() = 0; + virtual void setIndexer(Indexer *indexer) { index_manager_ = indexer; } + + protected: + virtual void notifyApplication(); + + protected: + implementation::ConsumerSocket *reassembly_consumer_socket_; + TransportProtocol *transport_protocol_; + Indexer *index_manager_; + std::unique_ptr<utils::MemBuf> read_buffer_; +}; + +} // namespace protocol + +} // end namespace transport |