blob: c3d7e95a4ce413315a25d4f49c76780f754f500a [file] [log] [blame]
Giulio Grassi624f6c62014-02-18 19:42:14 +01001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/**
Alexander Afanasyevcd591e12014-06-18 16:35:16 -07003 * Copyright (c) 2014, Regents of the University of California,
4 * Arizona Board of Regents,
5 * Colorado State University,
6 * University Pierre & Marie Curie, Sorbonne University,
7 * Washington University in St. Louis,
8 * Beijing Institute of Technology,
9 * The University of Memphis
Alexander Afanasyev9bcbc7c2014-04-06 19:37:37 -070010 *
11 * This file is part of NFD (Named Data Networking Forwarding Daemon).
12 * See AUTHORS.md for complete list of NFD authors and contributors.
13 *
14 * NFD is free software: you can redistribute it and/or modify it under the terms
15 * of the GNU General Public License as published by the Free Software Foundation,
16 * either version 3 of the License, or (at your option) any later version.
17 *
18 * NFD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
19 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
20 * PURPOSE. See the GNU General Public License for more details.
21 *
22 * You should have received a copy of the GNU General Public License along with
23 * NFD, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
Alexander Afanasyevcd591e12014-06-18 16:35:16 -070024 */
Giulio Grassi624f6c62014-02-18 19:42:14 +010025
26#include "multicast-udp-face.hpp"
27
28namespace nfd {
29
Alexander Afanasyevcd591e12014-06-18 16:35:16 -070030NFD_LOG_INCLASS_2TEMPLATE_SPECIALIZATION_DEFINE(DatagramFace,
31 MulticastUdpFace::protocol, Multicast,
32 "MulticastUdpFace");
Giulio Grassi624f6c62014-02-18 19:42:14 +010033
Alexander Afanasyevdc017002014-06-18 16:37:54 -070034MulticastUdpFace::MulticastUdpFace(const shared_ptr<MulticastUdpFace::protocol::socket>& recvSocket,
35 const shared_ptr<MulticastUdpFace::protocol::socket>& sendSocket,
36 const MulticastUdpFace::protocol::endpoint& localEndpoint,
37 const MulticastUdpFace::protocol::endpoint& multicastEndpoint)
38 : DatagramFace<protocol, Multicast>(FaceUri(multicastEndpoint),
Alexander Afanasyevcd591e12014-06-18 16:35:16 -070039 FaceUri(localEndpoint),
Alexander Afanasyevdc017002014-06-18 16:37:54 -070040 recvSocket, false)
41 , m_multicastGroup(multicastEndpoint)
42 , m_sendSocket(sendSocket)
Giulio Grassi624f6c62014-02-18 19:42:14 +010043{
Davide Pesaventod8d4d982014-03-21 18:47:58 +010044 NFD_LOG_INFO("Creating multicast UDP face for group " << m_multicastGroup);
Giulio Grassi624f6c62014-02-18 19:42:14 +010045}
46
Davide Pesaventod8d4d982014-03-21 18:47:58 +010047const MulticastUdpFace::protocol::endpoint&
Giulio Grassi624f6c62014-02-18 19:42:14 +010048MulticastUdpFace::getMulticastGroup() const
49{
50 return m_multicastGroup;
51}
52
53void
Alexander Afanasyevcd591e12014-06-18 16:35:16 -070054MulticastUdpFace::sendBlock(const Block& block)
55{
Alexander Afanasyevdc017002014-06-18 16:37:54 -070056 m_sendSocket->async_send_to(boost::asio::buffer(block.wire(), block.size()),
57 m_multicastGroup,
58 bind(&DatagramFace<protocol, Multicast>::handleSend,
59 this, _1, block));
Alexander Afanasyevcd591e12014-06-18 16:35:16 -070060}
61
62void
Giulio Grassi624f6c62014-02-18 19:42:14 +010063MulticastUdpFace::sendInterest(const Interest& interest)
64{
Alexander Afanasyev7e698e62014-03-07 16:48:35 +000065 onSendInterest(interest);
66
Giulio Grassi624f6c62014-02-18 19:42:14 +010067 NFD_LOG_DEBUG("Sending interest");
Alexander Afanasyevcd591e12014-06-18 16:35:16 -070068 sendBlock(interest.wireEncode());
Giulio Grassi624f6c62014-02-18 19:42:14 +010069}
70
71void
72MulticastUdpFace::sendData(const Data& data)
73{
Alexander Afanasyev7e698e62014-03-07 16:48:35 +000074 /// \todo After this method implements duplicate suppression, onSendData event should
75 /// be triggered only when data is actually sent out
76 onSendData(data);
77
Giulio Grassi624f6c62014-02-18 19:42:14 +010078 NFD_LOG_DEBUG("Sending data");
Alexander Afanasyevcd591e12014-06-18 16:35:16 -070079 sendBlock(data.wireEncode());
Giulio Grassi624f6c62014-02-18 19:42:14 +010080}
Davide Pesaventod8d4d982014-03-21 18:47:58 +010081
Giulio Grassi624f6c62014-02-18 19:42:14 +010082bool
83MulticastUdpFace::isMultiAccess() const
84{
85 return true;
86}
87
88} // namespace nfd