diff options
Diffstat (limited to 'emu-radio/ns3-patch/epc-tft-classifier.cc')
| -rw-r--r-- | emu-radio/ns3-patch/epc-tft-classifier.cc | 181 |
1 files changed, 181 insertions, 0 deletions
diff --git a/emu-radio/ns3-patch/epc-tft-classifier.cc b/emu-radio/ns3-patch/epc-tft-classifier.cc new file mode 100644 index 00000000..5c501b8d --- /dev/null +++ b/emu-radio/ns3-patch/epc-tft-classifier.cc @@ -0,0 +1,181 @@ +/* -*- Mode: C++; c-file-style: "gnu"; indent-tabs-mode:nil; -*- */ +/* + * Copyright (c) 2011 CTTC + * Copyright (c) 2010 TELEMATICS LAB, DEE - Politecnico di Bari + * Copyright (c) 2017 Irt Systemx and/or its affiliates. + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 2 as + * published by the Free Software Foundation; + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + * + * Authors: + * Nicola Baldo <nbaldo@cttc.es> (the EpcTftClassifier class) + * Giuseppe Piro <g.piro@poliba.it> (part of the code in EpcTftClassifier::Classify () + * which comes from RrcEntity::Classify of the GSoC 2010 LTE module) + * + */ + +#include "epc-tft-classifier.h" +#include "epc-tft.h" +#include "ns3/log.h" +#include "ns3/packet.h" +#include "ns3/ipv4-header.h" +#include "ns3/udp-header.h" +#include "ns3/tcp-header.h" +#include "ns3/udp-l4-protocol.h" +#include "ns3/tcp-l4-protocol.h" + +#ifndef PING_ENABLED +#define PING_ENABLED 1 +#endif + +#ifdef PING_ENABLED +#include "ns3/icmpv4-l4-protocol.h" +#endif + +namespace ns3 { + +NS_LOG_COMPONENT_DEFINE ("EpcTftClassifier"); + +EpcTftClassifier::EpcTftClassifier () +{ + NS_LOG_FUNCTION (this); +} + +void +EpcTftClassifier::Add (Ptr<EpcTft> tft, uint32_t id) +{ + NS_LOG_FUNCTION (this << tft); + + m_tftMap[id] = tft; + + // simple sanity check: there shouldn't be more than 16 bearers (hence TFTs) per UE + NS_ASSERT (m_tftMap.size () <= 16); +} + +void +EpcTftClassifier::Delete (uint32_t id) +{ + NS_LOG_FUNCTION (this << id); + m_tftMap.erase (id); +} + + +uint32_t +EpcTftClassifier::Classify (Ptr<Packet> p, EpcTft::Direction direction) +{ + NS_LOG_FUNCTION (this << p << direction); + + Ptr<Packet> pCopy = p->Copy (); + + Ipv4Header ipv4Header; + pCopy->RemoveHeader (ipv4Header); + + Ipv4Address localAddress; + Ipv4Address remoteAddress; + + + if (direction == EpcTft::UPLINK) + { + localAddress = ipv4Header.GetSource (); + remoteAddress = ipv4Header.GetDestination (); + } + else + { + NS_ASSERT (direction == EpcTft::DOWNLINK); + remoteAddress = ipv4Header.GetSource (); + localAddress = ipv4Header.GetDestination (); + } + + uint8_t protocol = ipv4Header.GetProtocol (); + + uint8_t tos = ipv4Header.GetTos (); + + uint16_t localPort = 0; + uint16_t remotePort = 0; + + if (protocol == UdpL4Protocol::PROT_NUMBER) + { + UdpHeader udpHeader; + pCopy->RemoveHeader (udpHeader); + + if (direction == EpcTft::UPLINK) + { + localPort = udpHeader.GetSourcePort (); + remotePort = udpHeader.GetDestinationPort (); + } + else + { + remotePort = udpHeader.GetSourcePort (); + localPort = udpHeader.GetDestinationPort (); + } + } + else if (protocol == TcpL4Protocol::PROT_NUMBER) + { + TcpHeader tcpHeader; + pCopy->RemoveHeader (tcpHeader); + if (direction == EpcTft::UPLINK) + { + localPort = tcpHeader.GetSourcePort (); + remotePort = tcpHeader.GetDestinationPort (); + } + else + { + remotePort = tcpHeader.GetSourcePort (); + localPort = tcpHeader.GetDestinationPort (); + } + } +#ifdef PING_ENABLED + else if (protocol == Icmpv4L4Protocol::PROT_NUMBER) //for ICMP(ping, and etc) protocol, use the default bearer always, added by zeng + { + NS_LOG_DEBUG("ICMP protocol, like ping is assigned the default bearer"); + + remotePort=0; + localPort=0; + } +#endif + else + { + NS_LOG_INFO ("Unknown protocol: " << protocol); + return 0; // no match + } + + NS_LOG_INFO ("Classifing packet:" + << " localAddr=" << localAddress + << " remoteAddr=" << remoteAddress + << " localPort=" << localPort + << " remotePort=" << remotePort + << " tos=0x" << (uint16_t) tos ); + + // now it is possible to classify the packet! + // we use a reverse iterator since filter priority is not implemented properly. + // This way, since the default bearer is expected to be added first, it will be evaluated last. + std::map <uint32_t, Ptr<EpcTft> >::const_reverse_iterator it; + NS_LOG_LOGIC ("TFT MAP size: " << m_tftMap.size ()); + + for (it = m_tftMap.rbegin (); it != m_tftMap.rend (); ++it) + { + NS_LOG_LOGIC ("TFT id: " << it->first ); + NS_LOG_LOGIC (" Ptr<EpcTft>: " << it->second); + Ptr<EpcTft> tft = it->second; + if (tft->Matches (direction, remoteAddress, localAddress, remotePort, localPort, tos)) + { + NS_LOG_LOGIC ("matches with TFT ID = " << it->first); + return it->first; // the id of the matching TFT + } + } + NS_LOG_LOGIC ("no match"); + return 0; // no match +} + + +} // namespace ns3 |