15#include "ns3/inet-socket-address.h"
16#include "ns3/ipv4-l3-protocol.h"
18#include "ns3/ipv6-header.h"
19#include "ns3/ipv6-l3-protocol.h"
22#include "ns3/mac48-address.h"
42 m_teidByBearerIdMap[bearerId] = teid;
43 return m_tftClassifier.Add(tft, teid);
50 auto it = m_teidByBearerIdMap.find(bearerId);
51 m_tftClassifier.Delete(it->second);
52 m_teidByBearerIdMap.erase(bearerId);
109 TypeId(
"ns3::EpcPgwApplication")
112 .AddTraceSource(
"RxFromTun",
113 "Receive data packets from internet in Tunnel NetDevice",
115 "ns3::EpcPgwApplication::RxTracedCallback")
116 .AddTraceSource(
"RxFromS1u",
117 "Receive data packets from S5 Socket",
119 "ns3::EpcPgwApplication::RxTracedCallback");
144 NS_LOG_FUNCTION(
this << tunDevice << s5Addr << s5uSocket << s5cSocket);
158 uint16_t protocolNumber)
160 NS_LOG_FUNCTION(
this << source << dest << protocolNumber << packet << packet->GetSize());
167 packet->PeekHeader(ipv4Header);
180 uint32_t teid = it->second->Classify(packet, protocolNumber);
194 packet->PeekHeader(ipv6Header);
207 uint32_t teid = it->second->Classify(packet, protocolNumber);
226 const bool succeeded =
true;
239 packet->RemoveHeader(gtpu);
252 packet->PeekHeader(header);
285 packet->RemoveHeader(msg);
303 pgwS5cFteid.
teid = sgwS5cFteid.
teid;
307 std::list<GtpcCreateSessionRequestMessage::BearerContextToBeCreated> bearerContexts =
309 NS_LOG_DEBUG(
"BearerContextsToBeCreated size = " << bearerContexts.size());
311 std::list<GtpcCreateSessionResponseMessage::BearerContextCreated> bearerContextsCreated;
312 for (
auto& bearerContext : bearerContexts)
314 uint32_t teid = bearerContext.sgwS5uFteid.teid;
315 NS_LOG_DEBUG(
"bearerId " << (uint16_t)bearerContext.epsBearerId <<
" SGW "
316 << bearerContext.sgwS5uFteid.addr <<
" TEID " << teid);
318 ueit->second->AddBearer(bearerContext.epsBearerId, teid, bearerContext.tft);
324 bearerContextOut.
epsBearerId = bearerContext.epsBearerId;
326 bearerContextOut.
tft = bearerContext.tft;
327 bearerContextsCreated.push_back(bearerContextOut);
330 NS_LOG_DEBUG(
"BearerContextsCreated size = " << bearerContextsCreated.size());
336 packetOut->AddHeader(msgOut);
347 packet->RemoveHeader(msg);
356 std::list<GtpcModifyBearerRequestMessage::BearerContextToBeModified> bearerContexts =
358 NS_LOG_DEBUG(
"BearerContextsToBeModified size = " << bearerContexts.size());
360 for (
auto& bearerContext : bearerContexts)
363 uint32_t teid = bearerContext.fteid.teid;
364 NS_LOG_DEBUG(
"bearerId " << (uint16_t)bearerContext.epsBearerId <<
" SGW " << sgwAddr
365 <<
" TEID " << teid);
374 packetOut->AddHeader(msgOut);
385 packet->RemoveHeader(msg);
387 std::list<uint8_t> epsBearerIds;
390 NS_LOG_DEBUG(
"ebid " << (uint16_t)bearerContext.m_epsBearerId);
391 epsBearerIds.push_back(bearerContext.m_epsBearerId);
400 packetOut->AddHeader(msgOut);
411 packet->RemoveHeader(msg);
420 NS_LOG_INFO(
"PGW removing bearer " << (uint16_t)epsBearerId <<
" of IMSI " << imsi);
421 ueit->second->RemoveBearer(epsBearerId);
429 NS_LOG_LOGIC(
"packet size: " << packet->GetSize() <<
" bytes");
432 packet->CopyData(&ipType, 1);
433 ipType = (ipType >> 4) & 0x0f;
435 uint16_t protocol = 0;
440 else if (ipType == 0x06)
466 packet->AddHeader(gtpu);
492 ueit->second->SetUeAddr(ueAddr);
503 ueit->second->SetUeAddr6(ueAddr);
a polymophic address class
Ipv6Address GetUeAddr6()
Get the IPv6 address of the UE.
uint32_t Classify(Ptr< Packet > p, uint16_t protocolNumber)
Classify the packet according to TFTs of this UE.
void SetUeAddr(Ipv4Address addr)
Set the IPv4 address of the UE.
Ipv4Address GetSgwAddr()
Get the address of the SGW to which the UE is connected.
void RemoveBearer(uint8_t bearerId)
Delete context of bearer for this UE on PGW side.
Ipv4Address GetUeAddr()
Get the IPv4 address of the UE.
void SetUeAddr6(Ipv6Address addr)
Set the IPv6 address of the UE.
void SetSgwAddr(Ipv4Address addr)
Set the address of the eNB to which the UE is connected.
void AddBearer(uint8_t bearerId, uint32_t teid, Ptr< EpcTft > tft)
Add a bearer for this UE on PGW side.
EpcPgwApplication(const Ptr< VirtualNetDevice > tunDevice, Ipv4Address s5Addr, const Ptr< Socket > s5uSocket, const Ptr< Socket > s5cSocket)
Constructor that binds the tap device to the callback methods.
void SendToS5uSocket(Ptr< Packet > packet, Ipv4Address sgwS5uAddress, uint32_t teid)
Send a data packet to the SGW via the S5-U interface.
void SetUeAddress6(uint64_t imsi, Ipv6Address ueAddr)
set the address of a previously added UE
void SendToTunDevice(Ptr< Packet > packet, uint32_t teid)
Send a data packet to the internet via the SGi interface of the PGW.
void AddSgw(Ipv4Address sgwS5Addr)
Let the PGW be aware of a new SGW.
TracedCallback< Ptr< Packet > > m_rxTunPktTrace
Callback to trace received data packets at Tun NetDevice from internet.
TracedCallback< Ptr< Packet > > m_rxS5PktTrace
Callback to trace received data packets from S5 socket.
std::map< Ipv6Address, Ptr< UeInfo > > m_ueInfoByAddrMap6
UeInfo stored by UE IPv6 address.
void RecvFromS5uSocket(Ptr< Socket > socket)
Method to be assigned to the receiver callback of the S5-U socket.
void DoRecvDeleteBearerResponse(Ptr< Packet > packet)
Process Delete Bearer Response message.
void RecvFromS5cSocket(Ptr< Socket > socket)
Method to be assigned to the receiver callback of the S5-C socket.
void DoRecvDeleteBearerCommand(Ptr< Packet > packet)
Process Delete Bearer Command message.
void AddUe(uint64_t imsi)
Let the PGW be aware of a new UE.
Ptr< Socket > m_s5uSocket
UDP socket to send/receive GTP-U packets to/from the S5 interface.
void DoDispose() override
Destructor implementation.
uint16_t m_gtpuUdpPort
UDP port to be used for GTP-U.
bool RecvFromTunDevice(Ptr< Packet > packet, const Address &source, const Address &dest, uint16_t protocolNumber)
Method to be assigned to the callback of the SGi TUN VirtualNetDevice.
std::map< uint64_t, Ptr< UeInfo > > m_ueInfoByImsiMap
UeInfo stored by IMSI.
Ipv4Address m_pgwS5Addr
PGW address of the S5 interface.
Ipv4Address m_sgwS5Addr
SGW address of the S5 interface.
~EpcPgwApplication() override
Destructor.
Ptr< VirtualNetDevice > m_tunDevice
TUN VirtualNetDevice used for tunneling/detunneling IP packets from/to the internet over GTP-U/UDP/IP...
void DoRecvModifyBearerRequest(Ptr< Packet > packet)
Process Modify Bearer Request message.
void DoRecvCreateSessionRequest(Ptr< Packet > packet)
Process Create Session Request message.
uint16_t m_gtpcUdpPort
UDP port to be used for GTPv2-C.
static TypeId GetTypeId()
Get the type ID.
Ptr< Socket > m_s5cSocket
UDP socket to send/receive GTPv2-C packets to/from the S5 interface.
std::map< Ipv4Address, Ptr< UeInfo > > m_ueInfoByAddrMap
UeInfo stored by UE IPv4 address.
void SetUeAddress(uint64_t imsi, Ipv4Address ueAddr)
Set the address of a previously added UE.
GTP-C Create Session Request Message.
uint64_t GetImsi() const
Get the IMSI.
GtpcHeader::Fteid_t GetSenderCpFteid() const
Get the Sender CpFteid.
uint32_t GetUliEcgi() const
Get the UliEcgi.
std::list< BearerContextToBeCreated > GetBearerContextsToBeCreated() const
Get the Bearer Contexts.
GTP-C Create Session Response Message.
void SetCause(Cause_t cause)
Set the Cause.
void SetBearerContextsCreated(std::list< BearerContextCreated > bearerContexts)
Set the Bearer Contexts.
void SetSenderCpFteid(GtpcHeader::Fteid_t fteid)
Set the Sender CpFteid.
GTP-C Delete Bearer Command Message.
std::list< BearerContext > GetBearerContexts() const
Get the Bearer contexts.
GTP-C Delete Bearer Request Message.
void SetEpsBearerIds(std::list< uint8_t > epsBearerIds)
Set the Bearers IDs.
GTP-C Delete Bearer Response Message.
std::list< uint8_t > GetEpsBearerIds() const
Get the Bearers IDs.
GTP-C Modify Bearer Request Message.
uint64_t GetImsi() const
Get the IMSI.
uint32_t GetUliEcgi() const
Get the UliEcgi.
std::list< BearerContextToBeModified > GetBearerContextsToBeModified() const
Get the Bearer Contexts.
GTP-C Modify Bearer Response Message.
void SetCause(Cause_t cause)
Set the Cause.
Ipv4 addresses are stored in host order in this class.
static const uint16_t PROT_NUMBER
Protocol number (0x0800)
Describes an IPv6 address.
static const uint16_t PROT_NUMBER
The protocol number for IPv6 (0x86DD).
@ PACKET_HOST
Packet addressed to us.
A base class which provides memory management and object aggregation.
Smart pointer class similar to boost::intrusive_ptr.
void SetRecvCallback(Callback< void, Ptr< Socket > > receivedData)
Notify application when new data is available to be read.
virtual int SendTo(Ptr< Packet > p, uint32_t flags, const Address &toAddress)=0
Send data to a specified peer.
a unique identifier for an interface.
TypeId SetParent(TypeId tid)
Set the parent TypeId.
#define NS_ASSERT(condition)
At runtime, in debugging builds, if this condition is not true, the program prints the source file,...
#define NS_ASSERT_MSG(condition, message)
At runtime, in debugging builds, if this condition is not true, the program prints the message to out...
Callback< R, Args... > MakeNullCallback()
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
#define NS_ABORT_MSG(msg)
Unconditional abnormal program termination with a message.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define NS_LOG_DEBUG(msg)
Use NS_LOG to output a message of level LOG_DEBUG.
#define NS_LOG_LOGIC(msg)
Use NS_LOG to output a message of level LOG_LOGIC.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
#define NS_LOG_WARN(msg)
Use NS_LOG to output a message of level LOG_WARN.
#define NS_LOG_INFO(msg)
Use NS_LOG to output a message of level LOG_INFO.
Ptr< T > Create(Ts &&... args)
Create class instances by constructors with varying numbers of arguments and return them by Ptr.
Ptr< const TraceSourceAccessor > MakeTraceSourceAccessor(T a)
Create a TraceSourceAccessor which will control access to the underlying trace source.
Every class exported by the ns3 library is enclosed in the ns3 namespace.
Callback< R, Args... > MakeCallback(R(T::*memPtr)(Args...), OBJ objPtr)
Build Callbacks for class method members which take varying numbers of arguments and potentially retu...
Bearer Context structure.
GtpcHeader::Fteid_t fteid
FTEID.
uint8_t epsBearerId
EPS bearer ID.
Ptr< EpcTft > tft
Bearer traffic flow template.
EpsBearer bearerLevelQos
Bearer QOS level.