Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
O
OpenXG-AMF
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
1
Issues
1
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Operations
Operations
Metrics
Environments
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
OpenXG
OpenXG-AMF
Commits
a746674b
Commit
a746674b
authored
Dec 19, 2023
by
liuyu
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
concourrence
parent
11529847
Changes
4
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
12 additions
and
12 deletions
+12
-12
etc/lyamf.conf
etc/lyamf.conf
+1
-1
src/amf-app/amf_sbi.cpp
src/amf-app/amf_sbi.cpp
+1
-1
src/ngap/ngapMsgs/PathSwitchRequest.cpp
src/ngap/ngapMsgs/PathSwitchRequest.cpp
+6
-6
src/ngap/ngap_app/udp.cpp
src/ngap/ngap_app/udp.cpp
+4
-4
No files found.
etc/lyamf.conf
View file @
a746674b
...
@@ -25,7 +25,7 @@ AMF =
...
@@ -25,7 +25,7 @@ AMF =
PID_DIRECTORY
=
"/var/run"
;
# /var/run is the default
PID_DIRECTORY
=
"/var/run"
;
# /var/run is the default
AMF_NAME
=
"AMF"
;
AMF_NAME
=
"AMF"
;
LOG_LEVEL
=
"
debug
"
LOG_LEVEL
=
"
off
"
RELATIVE_CAPACITY
=
30
;
RELATIVE_CAPACITY
=
30
;
# Display statistics about whole system (in seconds)
# Display statistics about whole system (in seconds)
STATISTICS_TIMER_INTERVAL
=
20
;
# YOUR CONFIG HERE
STATISTICS_TIMER_INTERVAL
=
20
;
# YOUR CONFIG HERE
...
...
src/amf-app/amf_sbi.cpp
View file @
a746674b
...
@@ -236,7 +236,7 @@ void amf_sbi::handle_itti_message(
...
@@ -236,7 +236,7 @@ void amf_sbi::handle_itti_message(
remote_uri
.
replace
(
found
,
ipv4ToReplace
.
length
(),
amf_cfg
.
smf_pool
[
0
].
ipv4
);
remote_uri
.
replace
(
found
,
ipv4ToReplace
.
length
(),
amf_cfg
.
smf_pool
[
0
].
ipv4
);
}
}
std
::
cout
<<
"modify smf url: "
<<
remote_uri
<<
std
::
endl
;
//
std::cout << "modify smf url: " << remote_uri << std::endl;
remote_uri
+=
NSMF_PDU_SESSION_MODIFY
;
remote_uri
+=
NSMF_PDU_SESSION_MODIFY
;
...
...
src/ngap/ngapMsgs/PathSwitchRequest.cpp
View file @
a746674b
...
@@ -277,7 +277,7 @@ namespace ngap {
...
@@ -277,7 +277,7 @@ namespace ngap {
.
choice
.
PathSwitchRequest
;
.
choice
.
PathSwitchRequest
;
}
}
else
{
else
{
cout
<<
"Check PathSwitchRequest message error!!!"
<<
endl
;
//
cout << "Check PathSwitchRequest message error!!!" << endl;
return
false
;
return
false
;
}
}
}
}
...
@@ -289,7 +289,7 @@ namespace ngap {
...
@@ -289,7 +289,7 @@ namespace ngap {
i
++
)
{
i
++
)
{
switch
(
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
->
id
)
{
switch
(
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
->
id
)
{
case
Ngap_ProtocolIE_ID_id_RAN_UE_NGAP_ID
:
{
case
Ngap_ProtocolIE_ID_id_RAN_UE_NGAP_ID
:
{
cout
<<
"decode ngap RAN_UE_NGAP_ID IE"
<<
endl
;
//
cout << "decode ngap RAN_UE_NGAP_ID IE" << endl;
if
(
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
if
(
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
->
criticality
==
Ngap_Criticality_reject
&&
->
criticality
==
Ngap_Criticality_reject
&&
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
...
@@ -309,7 +309,7 @@ namespace ngap {
...
@@ -309,7 +309,7 @@ namespace ngap {
}
}
}
break
;
}
break
;
case
Ngap_ProtocolIE_ID_id_SourceAMF_UE_NGAP_ID
:
{
case
Ngap_ProtocolIE_ID_id_SourceAMF_UE_NGAP_ID
:
{
cout
<<
"decod ngap SourceAMF_UE_NGAP_ID IE"
<<
endl
;
//
cout << "decod ngap SourceAMF_UE_NGAP_ID IE" << endl;
if
(
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
if
(
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
->
criticality
==
Ngap_Criticality_reject
&&
->
criticality
==
Ngap_Criticality_reject
&&
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
...
@@ -348,7 +348,7 @@ namespace ngap {
...
@@ -348,7 +348,7 @@ namespace ngap {
}
}
}
break
;
}
break
;
case
Ngap_ProtocolIE_ID_id_UESecurityCapabilities
:
{
case
Ngap_ProtocolIE_ID_id_UESecurityCapabilities
:
{
cout
<<
"decode NGAP UESecurityCapabilities IE"
<<
endl
;
//
cout << "decode NGAP UESecurityCapabilities IE" << endl;
if
(
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
if
(
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
->
criticality
==
Ngap_Criticality_ignore
&&
->
criticality
==
Ngap_Criticality_ignore
&&
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
...
@@ -368,8 +368,8 @@ namespace ngap {
...
@@ -368,8 +368,8 @@ namespace ngap {
}
}
}
break
;
}
break
;
case
Ngap_ProtocolIE_ID_id_PDUSessionResourceToBeSwitchedDLList
:
{
case
Ngap_ProtocolIE_ID_id_PDUSessionResourceToBeSwitchedDLList
:
{
cout
<<
"decode NGAP PDUSessionResourceToBeSwitchedDLList IE"
//
cout << "decode NGAP PDUSessionResourceToBeSwitchedDLList IE"
<<
endl
;
//
<< endl;
if
(
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
if
(
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
->
criticality
==
Ngap_Criticality_reject
&&
->
criticality
==
Ngap_Criticality_reject
&&
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
pathSwitchRequestIEs
->
protocolIEs
.
list
.
array
[
i
]
...
...
src/ngap/ngap_app/udp.cpp
View file @
a746674b
...
@@ -118,9 +118,9 @@ int udp_server::udp_read_from_socket() {
...
@@ -118,9 +118,9 @@ int udp_server::udp_read_from_socket() {
//bytes_received = recvfrom(serverSocket, udp_recv, UDP_RECV_BUFFER_SIZE , 0, (struct sockaddr*)&r_endpoint.addr_storage, &r_endpoint.addr_storage_len);
//bytes_received = recvfrom(serverSocket, udp_recv, UDP_RECV_BUFFER_SIZE , 0, (struct sockaddr*)&r_endpoint.addr_storage, &r_endpoint.addr_storage_len);
if
(
bytes_received
>
0
){
if
(
bytes_received
>
0
){
printf
(
"receive udp success
\n
"
);
//
printf("receive udp success\n");
gettimeofday
(
&
time
,
NULL
);
//
gettimeofday(&time, NULL);
std
::
cout
<<
"receive from plugin, ms: "
<<
(
time
.
tv_sec
*
1000
+
time
.
tv_usec
/
1000
)
<<
std
::
endl
;
//
std::cout<<"receive from plugin, ms: "<<(time.tv_sec*1000 + time.tv_usec/1000)<<std::endl;
// cout<<"bytes"<<bytes_received<<endl;
// cout<<"bytes"<<bytes_received<<endl;
// cout<<"content:"<<udp_recv<<endl;
// cout<<"content:"<<udp_recv<<endl;
// string udp_recv_str(&udp_recv[0],&udp_recv[strlen(udp_recv)]);
// string udp_recv_str(&udp_recv[0],&udp_recv[strlen(udp_recv)]);
...
@@ -273,7 +273,7 @@ void udp_server::handle_receive_udp(int r,uint8_t udp_recv[]){
...
@@ -273,7 +273,7 @@ void udp_server::handle_receive_udp(int r,uint8_t udp_recv[]){
}
}
// int _stream = udp_recv[r-2];
// int _stream = udp_recv[r-2];
stream
=
udp_recv
[
r
-
6
];
stream
=
udp_recv
[
r
-
5
];
uint32_t
_assoc_id
=
0
;
uint32_t
_assoc_id
=
0
;
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment