Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
O
OpenXG-UDR
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-UDR
Commits
9fab36a0
Commit
9fab36a0
authored
Jan 20, 2021
by
yangjian
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
update UDR
parent
0031f439
Changes
3
Expand all
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
101 additions
and
110 deletions
+101
-110
impl/AMF3GPPAccessRegistrationDocumentApiImpl.cpp
impl/AMF3GPPAccessRegistrationDocumentApiImpl.cpp
+56
-64
impl/AuthenticationStatusDocumentApiImpl.cpp
impl/AuthenticationStatusDocumentApiImpl.cpp
+13
-13
impl/SMFRegistrationDocumentApiImpl.cpp
impl/SMFRegistrationDocumentApiImpl.cpp
+32
-33
No files found.
impl/AMF3GPPAccessRegistrationDocumentApiImpl.cpp
View file @
9fab36a0
This diff is collapsed.
Click to expand it.
impl/AuthenticationStatusDocumentApiImpl.cpp
View file @
9fab36a0
...
...
@@ -47,25 +47,25 @@ void AuthenticationStatusDocumentApiImpl::create_authentication_status(const std
}
if
(
mysql_num_rows
(
res
))
{
query
=
"update AuthenticationStatus set nfInstanceId='"
+
authEvent
.
getNfInstanceId
()
+
"'
,
"
+
\
"
success="
+
(
authEvent
.
isSuccess
()
?
"1"
:
"0"
)
+
","
+
\
"
timeStamp='"
+
authEvent
.
getTimeStamp
()
+
"',
"
+
\
"
servingNetworkName='"
+
authEvent
.
getServingNetworkName
()
+
"',
"
+
\
(
authEvent
.
authRemovalIndIsSet
()
?
(
authEvent
.
isAuthRemovalInd
()
?
"
authRemovalInd=1,"
:
"authRemovalInd=0,
"
)
:
""
);
query
=
"update AuthenticationStatus set nfInstanceId='"
+
authEvent
.
getNfInstanceId
()
+
"'"
+
\
"
,success="
+
(
authEvent
.
isSuccess
()
?
"1"
:
"0"
)
+
\
"
,timeStamp='"
+
authEvent
.
getTimeStamp
()
+
"'
"
+
\
"
,servingNetworkName='"
+
authEvent
.
getServingNetworkName
()
+
"'
"
+
\
(
authEvent
.
authRemovalIndIsSet
()
?
(
authEvent
.
isAuthRemovalInd
()
?
"
,authRemovalInd=1"
:
",authRemovalInd=0
"
)
:
""
);
to_json
(
j
,
authEvent
.
getAuthType
());
query
+=
"authType='"
+
j
.
dump
()
+
"'"
;
query
+=
"
,
authType='"
+
j
.
dump
()
+
"'"
;
query
+=
" where ueid="
+
ueId
;
}
else
{
query
=
"insert into AuthenticationStatus set ueid="
+
ueId
+
","
\
"
nfInstanceId='"
+
authEvent
.
getNfInstanceId
()
+
"',
"
+
\
"
success="
+
(
authEvent
.
isSuccess
()
?
"1"
:
"0"
)
+
","
+
\
"
timeStamp='"
+
authEvent
.
getTimeStamp
()
+
"',
"
+
\
"
servingNetworkName='"
+
authEvent
.
getServingNetworkName
()
+
"',
"
+
\
(
authEvent
.
authRemovalIndIsSet
()
?
(
authEvent
.
isAuthRemovalInd
()
?
"
authRemovalInd=1,"
:
"authRemovalInd=0,
"
)
:
""
);
query
=
"insert into AuthenticationStatus set ueid="
+
ueId
+
\
"
,nfInstanceId='"
+
authEvent
.
getNfInstanceId
()
+
"'
"
+
\
"
,success="
+
(
authEvent
.
isSuccess
()
?
"1"
:
"0"
)
+
\
"
,timeStamp='"
+
authEvent
.
getTimeStamp
()
+
"'
"
+
\
"
,servingNetworkName='"
+
authEvent
.
getServingNetworkName
()
+
"'
"
+
\
(
authEvent
.
authRemovalIndIsSet
()
?
(
authEvent
.
isAuthRemovalInd
()
?
"
,authRemovalInd=1"
:
",authRemovalInd=0
"
)
:
""
);
to_json
(
j
,
authEvent
.
getAuthType
());
query
+=
"authType='"
+
j
.
dump
()
+
"'"
;
query
+=
"
,
authType='"
+
j
.
dump
()
+
"'"
;
}
mysql_free_result
(
res
);
...
...
impl/SMFRegistrationDocumentApiImpl.cpp
View file @
9fab36a0
...
...
@@ -46,67 +46,66 @@ void SMFRegistrationDocumentApiImpl::create_smf_context_non3gpp(const std::strin
}
if
(
mysql_num_rows
(
res
))
{
query
=
"update SmfRegistrations set smfInstanceId='"
+
smfRegistration
.
getSmfInstanceId
()
+
"'
,
"
+
\
"
pduSessionId="
+
std
::
to_string
(
smfRegistration
.
getPduSessionId
())
+
"',"
+
\
(
smfRegistration
.
smfSetIdIsSet
()
?
"
smfSetId='"
+
smfRegistration
.
getSmfSetId
()
+
"',
"
:
""
)
+
\
(
smfRegistration
.
supportedFeaturesIsSet
()
?
"
supportedFeatures='"
+
smfRegistration
.
getSupportedFeatures
()
+
"',
"
:
""
)
+
\
(
smfRegistration
.
dnnIsSet
()
?
"
dnn='"
+
smfRegistration
.
getDnn
()
+
"',
"
:
""
)
+
\
(
smfRegistration
.
emergencyServicesIsSet
()
?
(
smfRegistration
.
isEmergencyServices
()
?
"
emergencyServices=1,"
:
"emergencyServices=0,
"
)
:
""
)
+
\
(
smfRegistration
.
pcscfRestorationCallbackUriIsSet
()
?
"
pcscfRestorationCallbackUri='"
+
smfRegistration
.
getPcscfRestorationCallbackUri
()
+
"',
"
:
""
)
+
\
(
smfRegistration
.
pgwFqdnIsSet
()
?
"
pgwFqdn='"
+
smfRegistration
.
getPgwFqdn
()
+
"',
"
:
""
)
+
\
(
smfRegistration
.
epdgIndIsSet
()
?
(
smfRegistration
.
isEpdgInd
()
?
"
epdgInd=1,"
:
"epdgInd=0,
"
)
:
""
)
+
\
(
smfRegistration
.
deregCallbackUriIsSet
()
?
"
deregCallbackUri='"
+
smfRegistration
.
getDeregCallbackUri
()
+
"',
"
:
""
)
+
\
(
smfRegistration
.
registrationTimeIsSet
()
?
"
registrationTime='"
+
smfRegistration
.
getRegistrationTime
()
+
"',
"
:
""
);
query
=
"update SmfRegistrations set smfInstanceId='"
+
smfRegistration
.
getSmfInstanceId
()
+
"'"
+
\
"
,pduSessionId="
+
std
::
to_string
(
smfRegistration
.
getPduSessionId
())
+
\
(
smfRegistration
.
smfSetIdIsSet
()
?
"
,smfSetId='"
+
smfRegistration
.
getSmfSetId
()
+
"'
"
:
""
)
+
\
(
smfRegistration
.
supportedFeaturesIsSet
()
?
"
,supportedFeatures='"
+
smfRegistration
.
getSupportedFeatures
()
+
"'
"
:
""
)
+
\
(
smfRegistration
.
dnnIsSet
()
?
"
,dnn='"
+
smfRegistration
.
getDnn
()
+
"'
"
:
""
)
+
\
(
smfRegistration
.
emergencyServicesIsSet
()
?
(
smfRegistration
.
isEmergencyServices
()
?
"
,emergencyServices=1"
:
",emergencyServices=0
"
)
:
""
)
+
\
(
smfRegistration
.
pcscfRestorationCallbackUriIsSet
()
?
"
,pcscfRestorationCallbackUri='"
+
smfRegistration
.
getPcscfRestorationCallbackUri
()
+
"'
"
:
""
)
+
\
(
smfRegistration
.
pgwFqdnIsSet
()
?
"
,pgwFqdn='"
+
smfRegistration
.
getPgwFqdn
()
+
"'
"
:
""
)
+
\
(
smfRegistration
.
epdgIndIsSet
()
?
(
smfRegistration
.
isEpdgInd
()
?
"
,epdgInd=1"
:
",epdgInd=0
"
)
:
""
)
+
\
(
smfRegistration
.
deregCallbackUriIsSet
()
?
"
,deregCallbackUri='"
+
smfRegistration
.
getDeregCallbackUri
()
+
"'
"
:
""
)
+
\
(
smfRegistration
.
registrationTimeIsSet
()
?
"
,registrationTime='"
+
smfRegistration
.
getRegistrationTime
()
+
"'
"
:
""
);
if
(
smfRegistration
.
registrationReasonIsSet
())
{
to_json
(
j
,
smfRegistration
.
getRegistrationReason
());
query
+=
"
registrationReason='"
+
j
.
dump
()
+
"',
"
;
query
+=
"
,registrationReason='"
+
j
.
dump
()
+
"'
"
;
}
if
(
smfRegistration
.
contextInfoIsSet
())
{
to_json
(
j
,
smfRegistration
.
getContextInfo
());
query
+=
"
contextInfo='"
+
j
.
dump
()
+
"',
"
;
query
+=
"
,contextInfo='"
+
j
.
dump
()
+
"'
"
;
}
to_json
(
j
,
smfRegistration
.
getSingleNssai
());
query
+=
"
singleNssai='"
+
j
.
dump
()
+
"',
"
;
query
+=
"
,singleNssai='"
+
j
.
dump
()
+
"'
"
;
to_json
(
j
,
smfRegistration
.
getPlmnId
());
query
+=
"plmnId='"
+
j
.
dump
()
+
"'"
;
query
+=
"
,
plmnId='"
+
j
.
dump
()
+
"'"
;
query
+=
" where ueid="
+
ueId
+
" AND subpduSessionId="
+
std
::
to_string
(
pduSessionId
);
}
else
{
query
=
"insert into SmfRegistrations set ueid="
+
ueId
+
","
+
\
"subpduSessionId="
+
std
::
to_string
(
pduSessionId
)
+
","
+
\
"pduSessionId="
+
std
::
to_string
(
smfRegistration
.
getPduSessionId
())
+
"',"
+
\
"smfInstanceId='"
+
smfRegistration
.
getSmfInstanceId
()
+
"',"
+
\
(
smfRegistration
.
smfSetIdIsSet
()
?
"smfSetId='"
+
smfRegistration
.
getSmfSetId
()
+
"',"
:
""
)
+
\
(
smfRegistration
.
supportedFeaturesIsSet
()
?
"supportedFeatures='"
+
smfRegistration
.
getSupportedFeatures
()
+
"',"
:
""
)
+
\
(
smfRegistration
.
dnnIsSet
()
?
"dnn='"
+
smfRegistration
.
getDnn
()
+
"',"
:
""
)
+
\
(
smfRegistration
.
emergencyServicesIsSet
()
?
(
smfRegistration
.
isEmergencyServices
()
?
"emergencyServices=1,"
:
"emergencyServices=0,"
)
:
""
)
+
\
(
smfRegistration
.
pcscfRestorationCallbackUriIsSet
()
?
"pcscfRestorationCallbackUri='"
+
smfRegistration
.
getPcscfRestorationCallbackUri
()
+
"',"
:
""
)
+
\
(
smfRegistration
.
pgwFqdnIsSet
()
?
"pgwFqdn='"
+
smfRegistration
.
getPgwFqdn
()
+
"',"
:
""
)
+
\
(
smfRegistration
.
epdgIndIsSet
()
?
(
smfRegistration
.
isEpdgInd
()
?
"epdgInd=1,"
:
"epdgInd=0,"
)
:
""
)
+
\
(
smfRegistration
.
deregCallbackUriIsSet
()
?
"deregCallbackUri='"
+
smfRegistration
.
getDeregCallbackUri
()
+
"',"
:
""
)
+
\
(
smfRegistration
.
deregCallbackUriIsSet
()
?
"deregCallbackUri='"
+
smfRegistration
.
getDeregCallbackUri
()
+
"',"
:
""
)
+
\
(
smfRegistration
.
registrationTimeIsSet
()
?
"registrationTime='"
+
smfRegistration
.
getRegistrationTime
()
+
"',"
:
""
);
query
=
"insert into SmfRegistrations set ueid="
+
ueId
+
\
",subpduSessionId="
+
std
::
to_string
(
pduSessionId
)
+
\
",pduSessionId="
+
std
::
to_string
(
smfRegistration
.
getPduSessionId
())
+
\
",smfInstanceId='"
+
smfRegistration
.
getSmfInstanceId
()
+
"'"
+
\
(
smfRegistration
.
smfSetIdIsSet
()
?
",smfSetId='"
+
smfRegistration
.
getSmfSetId
()
+
"'"
:
""
)
+
\
(
smfRegistration
.
supportedFeaturesIsSet
()
?
",supportedFeatures='"
+
smfRegistration
.
getSupportedFeatures
()
+
"'"
:
""
)
+
\
(
smfRegistration
.
dnnIsSet
()
?
",dnn='"
+
smfRegistration
.
getDnn
()
+
"'"
:
""
)
+
\
(
smfRegistration
.
emergencyServicesIsSet
()
?
(
smfRegistration
.
isEmergencyServices
()
?
",emergencyServices=1"
:
",emergencyServices=0"
)
:
""
)
+
\
(
smfRegistration
.
pcscfRestorationCallbackUriIsSet
()
?
",pcscfRestorationCallbackUri='"
+
smfRegistration
.
getPcscfRestorationCallbackUri
()
+
"'"
:
""
)
+
\
(
smfRegistration
.
pgwFqdnIsSet
()
?
",pgwFqdn='"
+
smfRegistration
.
getPgwFqdn
()
+
"'"
:
""
)
+
\
(
smfRegistration
.
epdgIndIsSet
()
?
(
smfRegistration
.
isEpdgInd
()
?
",epdgInd=1"
:
",epdgInd=0"
)
:
""
)
+
\
(
smfRegistration
.
deregCallbackUriIsSet
()
?
",deregCallbackUri='"
+
smfRegistration
.
getDeregCallbackUri
()
+
"'"
:
""
)
+
\
(
smfRegistration
.
registrationTimeIsSet
()
?
",registrationTime='"
+
smfRegistration
.
getRegistrationTime
()
+
"'"
:
""
);
if
(
smfRegistration
.
registrationReasonIsSet
())
{
to_json
(
j
,
smfRegistration
.
getRegistrationReason
());
query
+=
"
registrationReason='"
+
j
.
dump
()
+
"',
"
;
query
+=
"
,registrationReason='"
+
j
.
dump
()
+
"'
"
;
}
if
(
smfRegistration
.
contextInfoIsSet
())
{
to_json
(
j
,
smfRegistration
.
getContextInfo
());
query
+=
"
contextInfo='"
+
j
.
dump
()
+
"',
"
;
query
+=
"
,contextInfo='"
+
j
.
dump
()
+
"'
"
;
}
to_json
(
j
,
smfRegistration
.
getSingleNssai
());
query
+=
"
singleNssai='"
+
j
.
dump
()
+
"',
"
;
query
+=
"
,singleNssai='"
+
j
.
dump
()
+
"'
"
;
to_json
(
j
,
smfRegistration
.
getPlmnId
());
query
+=
"plmnId='"
+
j
.
dump
()
+
"'"
;
query
+=
"
,
plmnId='"
+
j
.
dump
()
+
"'"
;
}
mysql_free_result
(
res
);
...
...
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