Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
O
OpenXG-SMF
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
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-SMF
Commits
d5860524
Commit
d5860524
authored
Jun 03, 2021
by
Tien-Thinh Nguyen
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Use curl multi instead of curl easy for SBI
parent
70cc3af1
Changes
2
Expand all
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
530 additions
and
769 deletions
+530
-769
src/smf_app/smf_sbi.cpp
src/smf_app/smf_sbi.cpp
+520
-741
src/smf_app/smf_sbi.hpp
src/smf_app/smf_sbi.hpp
+10
-28
No files found.
src/smf_app/smf_sbi.cpp
View file @
d5860524
This diff is collapsed.
Click to expand it.
src/smf_app/smf_sbi.hpp
View file @
d5860524
...
@@ -146,14 +146,6 @@ class smf_sbi {
...
@@ -146,14 +146,6 @@ class smf_sbi {
void
subscribe_upf_status_notify
(
void
subscribe_upf_status_notify
(
std
::
shared_ptr
<
itti_n11_subscribe_upf_status_notify
>
msg
);
std
::
shared_ptr
<
itti_n11_subscribe_upf_status_notify
>
msg
);
/*
* Create Curl handle for multi curl
* @param [event_notification&] ev_notif: content of the event notification
* @param [std::string *] data: data
* @return pointer to the created curl
*/
CURL
*
curl_create_handle
(
event_notification
&
ev_notif
,
std
::
string
*
data
);
/*
/*
* Get SM subscription data from UDM
* Get SM subscription data from UDM
* @param [const supi64_t &] supi
* @param [const supi64_t &] supi
...
@@ -184,22 +176,21 @@ class smf_sbi {
...
@@ -184,22 +176,21 @@ class smf_sbi {
*/
*/
CURL
*
curl_create_handle
(
CURL
*
curl_create_handle
(
const
std
::
string
&
uri
,
const
std
::
string
&
data
,
const
std
::
string
&
uri
,
const
std
::
string
&
data
,
std
::
string
&
response_data
);
std
::
string
&
response_data
,
const
std
::
string
&
method
);
CURL
*
curl_create_handle
(
CURL
*
curl_create_handle
(
const
std
::
string
&
uri
,
const
char
*
data
,
uint32_t
data_len
,
const
std
::
string
&
uri
,
const
char
*
data
,
uint32_t
data_len
,
std
::
string
&
response_data
,
uint32_t
*
promise_id
,
bool
is_multipart
);
std
::
string
&
response_data
,
uint32_t
*
promise_id
,
const
std
::
string
&
method
,
bool
is_multipart
);
/*
CURL
*
curl_create_handle
(
* Prepare to send a request using curl multi
* @param [const std::string &] uri: URI of the subscribed NF
* @param [std::string &] data: data to be sent
* @param [std::string &] response_data: response data
* @return void
*/
void
send_curl_multi
(
const
std
::
string
&
uri
,
const
std
::
string
&
data
,
const
std
::
string
&
uri
,
const
std
::
string
&
data
,
std
::
string
&
response_data
);
std
::
string
&
response_data
,
uint32_t
*
promise_id
,
const
std
::
string
&
method
);
CURL
*
curl_create_handle
(
const
std
::
string
&
uri
,
std
::
string
&
response_data
,
uint32_t
*
promise_id
,
const
std
::
string
&
method
);
/*
/*
* Perform curl multi to actually process the available data
* Perform curl multi to actually process the available data
...
@@ -208,21 +199,12 @@ class smf_sbi {
...
@@ -208,21 +199,12 @@ class smf_sbi {
*/
*/
void
perform_curl_multi
(
uint64_t
ms
);
void
perform_curl_multi
(
uint64_t
ms
);
/*
* Finish all the curl transfers
* @param void
* @return void
*/
void
wait_curl_end
();
/*
/*
* Release all the handles
* Release all the handles
* @param void
* @param void
* @return void
* @return void
*/
*/
void
curl_release_handles
();
void
curl_release_handles
();
void
send_n1n2_message_transfer_request_curl_multi
(
std
::
shared_ptr
<
itti_n11_create_sm_context_response
>
sm_context_res
);
void
add_promise
(
void
add_promise
(
uint32_t
pid
,
boost
::
shared_ptr
<
boost
::
promise
<
uint32_t
>>&
p
);
uint32_t
pid
,
boost
::
shared_ptr
<
boost
::
promise
<
uint32_t
>>&
p
);
...
...
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