From a07f5a525d7dfa00dee8099678fdf1197466a02b Mon Sep 17 00:00:00 2001 From: Guillaume Belanger Date: Thu, 17 Oct 2024 07:49:44 -0400 Subject: [PATCH] fix: return created PDRs Signed-off-by: Guillaume Belanger --- pfcpiface/session_pdr.go | 41 +++++++++++++++++++--------------------- 1 file changed, 19 insertions(+), 22 deletions(-) diff --git a/pfcpiface/session_pdr.go b/pfcpiface/session_pdr.go index 4e1d94484..174de3a1f 100644 --- a/pfcpiface/session_pdr.go +++ b/pfcpiface/session_pdr.go @@ -30,30 +30,27 @@ func addPdrInfo(msg *message.SessionEstablishmentResponse, session *PFCPSession) logger.PfcpLog.Infoln("add PDRs with UPF alloc IPs to Establishment response") for _, pdr := range session.pdrs { - if (pdr.allocIPFlag) && (pdr.srcIface == core) { - logger.PfcpLog.Debugln("pdrID:", pdr.pdrID) - - var ( - flags uint8 = 0x02 - ueIP net.IP = int2ip(pdr.ueAddress) - ) - - if ueIP != nil { - logger.PfcpLog.Debugln("ueIP:", ueIP.String()) - msg.CreatedPDR = append(msg.CreatedPDR, - ie.NewCreatedPDR( - ie.NewPDRID(uint16(pdr.pdrID)), - ie.NewUEIPAddress(flags, ueIP.String(), "", 0, 0), - )) - } else { - msg.CreatedPDR = append(msg.CreatedPDR, - ie.NewCreatedPDR( - ie.NewPDRID(uint16(pdr.pdrID)), - ie.NewFTEID(0x01, pdr.tunnelTEID, int2ip(pdr.tunnelIP4Dst), nil, 0), - )) - } + var ( + flags uint8 = 0x02 + ueIP net.IP = int2ip(pdr.ueAddress) + ) + logger.PfcpLog.Debugln("Adding PDR ID:", pdr.pdrID) + if ueIP != nil { + logger.PfcpLog.Debugln("ueIP:", ueIP.String()) + msg.CreatedPDR = append(msg.CreatedPDR, + ie.NewCreatedPDR( + ie.NewPDRID(uint16(pdr.pdrID)), + ie.NewUEIPAddress(flags, ueIP.String(), "", 0, 0), + )) + } else { + msg.CreatedPDR = append(msg.CreatedPDR, + ie.NewCreatedPDR( + ie.NewPDRID(uint16(pdr.pdrID)), + ie.NewFTEID(0x01, pdr.tunnelTEID, int2ip(pdr.tunnelIP4Dst), nil, 0), + )) } + } }