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
fec32776
Commit
fec32776
authored
Nov 16, 2020
by
Tien-Thinh Nguyen
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Bugfix for PDU Session Release Cmd
parent
71b15f0f
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
9 additions
and
9 deletions
+9
-9
src/amf-app/amf_n11.cpp
src/amf-app/amf_n11.cpp
+9
-9
No files found.
src/amf-app/amf_n11.cpp
View file @
fec32776
...
@@ -105,14 +105,14 @@ void amf_n11_task(void*) {
...
@@ -105,14 +105,14 @@ void amf_n11_task(void*) {
auto
*
msg
=
shared_msg
.
get
();
auto
*
msg
=
shared_msg
.
get
();
switch
(
msg
->
msg_type
)
{
switch
(
msg
->
msg_type
)
{
case
SMF_SERVICES_CONSUMER
:
{
case
SMF_SERVICES_CONSUMER
:
{
Logger
::
amf_n1
().
info
(
"Running SMF_SERVICES_CONSUMER"
);
Logger
::
amf_n1
1
().
info
(
"Running SMF_SERVICES_CONSUMER"
);
itti_smf_services_consumer
*
m
=
itti_smf_services_consumer
*
m
=
dynamic_cast
<
itti_smf_services_consumer
*>
(
msg
);
dynamic_cast
<
itti_smf_services_consumer
*>
(
msg
);
amf_n11_inst
->
handle_itti_message
(
ref
(
*
m
));
amf_n11_inst
->
handle_itti_message
(
ref
(
*
m
));
}
}
break
;
break
;
case
NSMF_PDU_SESSION_UPDATE_SM_CTX
:
{
case
NSMF_PDU_SESSION_UPDATE_SM_CTX
:
{
Logger
::
amf_n1
().
info
(
Logger
::
amf_n1
1
().
info
(
"Receive Nsmf_PDUSessionUpdateSMContext, handling ..."
);
"Receive Nsmf_PDUSessionUpdateSMContext, handling ..."
);
itti_nsmf_pdusession_update_sm_context
*
m
=
itti_nsmf_pdusession_update_sm_context
*
m
=
dynamic_cast
<
itti_nsmf_pdusession_update_sm_context
*>
(
msg
);
dynamic_cast
<
itti_nsmf_pdusession_update_sm_context
*>
(
msg
);
...
@@ -120,7 +120,7 @@ void amf_n11_task(void*) {
...
@@ -120,7 +120,7 @@ void amf_n11_task(void*) {
}
}
break
;
break
;
default:
{
default:
{
Logger
::
amf_n1
().
info
(
Logger
::
amf_n1
1
().
info
(
"Receive unknown message type %d"
,
msg
->
msg_type
);
"Receive unknown message type %d"
,
msg
->
msg_type
);
}
}
}
}
...
@@ -133,8 +133,8 @@ amf_n11::amf_n11() {
...
@@ -133,8 +133,8 @@ amf_n11::amf_n11() {
Logger
::
amf_n11
().
error
(
"Cannot create task TASK_AMF_N1"
);
Logger
::
amf_n11
().
error
(
"Cannot create task TASK_AMF_N1"
);
throw
std
::
runtime_error
(
"Cannot create task TASK_AMF_N1"
);
throw
std
::
runtime_error
(
"Cannot create task TASK_AMF_N1"
);
}
}
Logger
::
amf_n1
().
startup
(
"Started"
);
Logger
::
amf_n1
1
().
startup
(
"Started"
);
Logger
::
amf_n1
().
debug
(
"Construct amf_n1 successfully"
);
Logger
::
amf_n1
1
().
debug
(
"Construct amf_n1 successfully"
);
}
}
//------------------------------------------------------------------------------
//------------------------------------------------------------------------------
...
@@ -397,7 +397,7 @@ void amf_n11::handle_post_sm_context_response_error(long code,
...
@@ -397,7 +397,7 @@ void amf_n11::handle_post_sm_context_response_error(long code,
<
itti_n1n2_message_transfer_request
>
(
itti_msg
);
<
itti_n1n2_message_transfer_request
>
(
itti_msg
);
int
ret
=
itti_inst
->
send_msg
(
i
);
int
ret
=
itti_inst
->
send_msg
(
i
);
if
(
0
!=
ret
)
{
if
(
0
!=
ret
)
{
Logger
::
amf_n1
().
error
(
Logger
::
amf_n1
1
().
error
(
"Could not send ITTI message %s to task TASK_AMF_APP"
,
"Could not send ITTI message %s to task TASK_AMF_APP"
,
i
->
get_msg_name
());
i
->
get_msg_name
());
}
}
...
@@ -578,11 +578,11 @@ void amf_n11::curl_http_client(std::string remoteUri, std::string jsonData,
...
@@ -578,11 +578,11 @@ void amf_n11::curl_http_client(std::string remoteUri, std::string jsonData,
}
}
if
(
n2sm
.
size
()
>
0
)
{
if
(
n2sm
.
size
()
>
0
)
{
msg_str_2_msg_hex
(
n2sm
,
n2sm_hex
);
msg_str_2_msg_hex
(
n2sm
,
n2sm_hex
);
print_buffer
(
"amf_n11"
,
"Get response n
1
sm:"
,
print_buffer
(
"amf_n11"
,
"Get response n
2
sm:"
,
(
uint8_t
*
)
bdata
(
n2sm_hex
),
blength
(
n2sm_hex
));
(
uint8_t
*
)
bdata
(
n2sm_hex
),
blength
(
n2sm_hex
));
itti_msg
->
n2sm
=
n2sm_hex
;
itti_msg
->
n2sm
=
n2sm_hex
;
itti_msg
->
is_n2sm_set
=
true
;
itti_msg
->
is_n2sm_set
=
true
;
itti_msg
->
n2sm_info_type
=
response_data
[
"n2InfoContainer"
][
"smInfo"
][
"n2InfoContent"
][
"ngapIeType"
];
itti_msg
->
n2sm_info_type
=
response_data
[
"n2
SmInfoType"
];
//response_data["n2
InfoContainer"]["smInfo"]["n2InfoContent"]["ngapIeType"];
}
}
itti_msg
->
supi
=
supi
;
itti_msg
->
supi
=
supi
;
...
@@ -591,7 +591,7 @@ void amf_n11::curl_http_client(std::string remoteUri, std::string jsonData,
...
@@ -591,7 +591,7 @@ void amf_n11::curl_http_client(std::string remoteUri, std::string jsonData,
<
itti_n1n2_message_transfer_request
>
(
itti_msg
);
<
itti_n1n2_message_transfer_request
>
(
itti_msg
);
int
ret
=
itti_inst
->
send_msg
(
i
);
int
ret
=
itti_inst
->
send_msg
(
i
);
if
(
0
!=
ret
)
{
if
(
0
!=
ret
)
{
Logger
::
amf_n1
().
error
(
Logger
::
amf_n1
1
().
error
(
"Could not send ITTI message %s to task TASK_AMF_APP"
,
"Could not send ITTI message %s to task TASK_AMF_APP"
,
i
->
get_msg_name
());
i
->
get_msg_name
());
}
}
...
...
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