diff options
| author |   michele papalini <micpapal@cisco.com> | 2019-04-03 18:28:04 +0200 |
|---|---|---|
| committer | michele papalini <micpapal@cisco.com> | 2019-04-03 18:28:04 +0200 |
| commit | 41878be65785063472c3a69139347efe3952492a (patch) | |
| tree | 45f0cff9fa58ec7a30ea2a9e31010eda415d2d21 /libtransport/src/hicn/transport/protocols/rtc.cc | |
| parent | 972197fdf017efd69656ab435191f2b8b4feec13 (diff) | |
[HICN-96] add callbacks in RTC
Change-Id: Ide96e5798ab57f057de6a6f91078a5082f69e313
Signed-off-by: michele papalini <micpapal@cisco.com>
Diffstat (limited to 'libtransport/src/hicn/transport/protocols/rtc.cc')
| -rw-r--r-- | libtransport/src/hicn/transport/protocols/rtc.cc | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/libtransport/src/hicn/transport/protocols/rtc.cc b/libtransport/src/hicn/transport/protocols/rtc.cc index e3dcbbdbd..13c688d00 100644 --- a/libtransport/src/hicn/transport/protocols/rtc.cc +++ b/libtransport/src/hicn/transport/protocols/rtc.cc @@ -558,6 +558,13 @@ void RTCTransportProtocol::onContentObject( uint32_t pkt = segmentNumber & modMask_; bool schedule_next_interest = true; + ConsumerContentObjectCallback *callback_content_object = nullptr; + socket_->getSocketOption(ConsumerCallbacksOptions::CONTENT_OBJECT_INPUT, + &callback_content_object); + if (*callback_content_object != VOID_HANDLER) { + (*callback_content_object)(*socket_, *content_object); + } + if (payload_size == HICN_NACK_HEADER_SIZE) { // Nacks always come form the producer, so we set the producerPathLabel_; producerPathLabel_ = content_object->getPathLabel(); |