Changes of Revision 14
commit_a99a76d916c35453bb837fa07cd943c8508fcf10.txt
Added
commit_e9aaceee98f89c86ad593e09c3f4892d0cfde268.txt
Deleted
open5gs_2.4.11.9.e9aac.dsc -> open5gs_2.4.11.10.a99a7.dsc
Changed
x
1
2
Source: open5gs3
Binary: open5gs-common, open5gs-mme, open5gs-sgwc, open5gs-smf, open5gs-amf, open5gs-sgwu, open5gs-upf, open5gs-hss, open5gs-pcrf, open5gs-nrf, open5gs-ausf, open5gs-udm, open5gs-pcf, open5gs-nssf, open5gs-bsf, open5gs-udr, open5gs, open5gs-dbg4
Architecture: any5
-Version: 2.4.11.9.e9aac6
+Version: 2.4.11.10.a99a77
Maintainer: Harald Welte <laforge@gnumonks.org>8
Uploaders: Sukchan Lee <acetcom@gmail.com>9
Homepage: https://open5gs.org10
11
open5gs-udr deb net optional arch=any12
open5gs-upf deb net optional arch=any13
Checksums-Sha1:14
- 158fb595a4cee23f7fbe36d9cb9475fe25b5f7e2 11469960 open5gs_2.4.11.9.e9aac.tar.xz15
+ d0f70edd732b8c32b7f668bba1826358a9cd1197 11471160 open5gs_2.4.11.10.a99a7.tar.xz16
Checksums-Sha256:17
- 12402e7c1f0c80b4efeabd5b37b30015df7e4065b48a7b36f4fc01be7dd53616 11469960 open5gs_2.4.11.9.e9aac.tar.xz18
+ 7f423f0cc2e22dd7298ed91c5620441b13e15f5177836544190bfd01fdb79d35 11471160 open5gs_2.4.11.10.a99a7.tar.xz19
Files:20
- 4d2cf87b37c17fced69ce074c163be76 11469960 open5gs_2.4.11.9.e9aac.tar.xz21
+ 3cba8fb47cdd8e6199ee87efbc11ccd3 11471160 open5gs_2.4.11.10.a99a7.tar.xz22
open5gs_2.4.11.9.e9aac.tar.xz/.tarball-version -> open5gs_2.4.11.10.a99a7.tar.xz/.tarball-version
Changed
4
1
2
-2.4.11.9-e9aac3
+2.4.11.10-a99a74
open5gs_2.4.11.9.e9aac.tar.xz/debian/changelog -> open5gs_2.4.11.10.a99a7.tar.xz/debian/changelog
Changed
12
1
2
-open5gs (2.4.11.9.e9aac) unstable; urgency=medium3
+open5gs (2.4.11.10.a99a7) unstable; urgency=medium4
5
* Automatically generated changelog entry for building the Osmocom master feed6
7
- -- Osmocom OBS scripts <info@osmocom.org> Thu, 06 Oct 2022 02:01:42 +00008
+ -- Osmocom OBS scripts <info@osmocom.org> Thu, 06 Oct 2022 12:27:23 +00009
10
open5gs (2.4.11) unstable; urgency=medium11
12
open5gs_2.4.11.9.e9aac.tar.xz/lib/sbi/message.c -> open5gs_2.4.11.10.a99a7.tar.xz/lib/sbi/message.c
Changed
60
1
2
OpenAPI_termination_notification_free(message->TerminationNotification);3
if (message->DeregistrationData)4
OpenAPI_deregistration_data_free(message->DeregistrationData);5
+ if (message->SDMSubscription)6
+ OpenAPI_sdm_subscription_free(message->SDMSubscription);7
+ if (message->ModificationNotification)8
+ OpenAPI_modification_notification_free(message->ModificationNotification);9
10
/* HTTP Part */11
for (i = 0; i < message->num_of_part; i++) {12
13
item = OpenAPI_deregistration_data_convertToJSON(14
message->DeregistrationData);15
ogs_assert(item);16
+ } else if (message->SDMSubscription) {17
+ item = OpenAPI_sdm_subscription_convertToJSON(18
+ message->SDMSubscription);19
+ ogs_assert(item);20
+ }21
+ else if (message->ModificationNotification) {22
+ item = OpenAPI_modification_notification_convertToJSON(23
+ message->ModificationNotification);24
+ ogs_assert(item);25
}26
27
if (item) {28
29
}30
break;31
32
+ CASE(OGS_SBI_RESOURCE_NAME_SDM_SUBSCRIPTIONS)33
+ message->SDMSubscription =34
+ OpenAPI_sdm_subscription_parseFromJSON(item);35
+ if (!message->SDMSubscription) {36
+ rv = OGS_ERROR;37
+ ogs_error("JSON parse error");38
+ }39
+ break;40
+41
DEFAULT42
rv = OGS_ERROR;43
ogs_error("Unknown resource name %s",44
45
rv = OGS_ERROR;46
ogs_error("JSON parse error");47
}48
+ break;49
+50
+ CASE(OGS_SBI_RESOURCE_NAME_SDMSUBSCRIPTION_NOTIFY)51
+ message->ModificationNotification =52
+ OpenAPI_modification_notification_parseFromJSON(item);53
+ if (!message->ModificationNotification) {54
+ rv = OGS_ERROR;55
+ ogs_error("JSON parse error");56
+ }57
break;58
59
DEFAULT60
open5gs_2.4.11.9.e9aac.tar.xz/lib/sbi/message.h -> open5gs_2.4.11.10.a99a7.tar.xz/lib/sbi/message.h
Changed
27
1
2
#define OGS_SBI_RESOURCE_NAME_UE_CONTEXT_IN_SMF_DATA "ue-context-in-smf-data"3
#define OGS_SBI_RESOURCE_NAME_SMF_SELECTION_SUBSCRIPTION_DATA \4
"smf-selection-subscription-data"5
+#define OGS_SBI_RESOURCE_NAME_SDM_SUBSCRIPTIONS "sdm-subscriptions"6
7
#define OGS_SBI_RESOURCE_NAME_SECURITY_INFORMATION "security-information"8
#define OGS_SBI_RESOURCE_NAME_GENERATE_AUTH_DATA "generate-auth-data"9
10
#define OGS_SBI_RESOURCE_NAME_SM_CONTEXT_STATUS "sm-context-status"11
#define OGS_SBI_RESOURCE_NAME_AM_POLICY_NOTIFY "am-policy-notify"12
#define OGS_SBI_RESOURCE_NAME_DEREG_NOTIFY "dereg-notify"13
+#define OGS_SBI_RESOURCE_NAME_SDMSUBSCRIPTION_NOTIFY \14
+ "sdmsubscription-notify"15
16
#define OGS_SBI_RESOURCE_NAME_POLICIES "policies"17
#define OGS_SBI_RESOURCE_NAME_SM_POLICIES "sm-policies"18
19
OpenAPI_sm_policy_notification_t *SmPolicyNotification;20
OpenAPI_termination_notification_t *TerminationNotification;21
OpenAPI_deregistration_data_t *DeregistrationData;22
+ OpenAPI_sdm_subscription_t *SDMSubscription;23
+ OpenAPI_modification_notification_t *ModificationNotification;24
25
ogs_sbi_links_t *links;26
27
open5gs_2.4.11.9.e9aac.tar.xz/lib/sbi/ogs-sbi.h -> open5gs_2.4.11.10.a99a7.tar.xz/lib/sbi/ogs-sbi.h
Changed
10
1
2
#include "model/sm_policy_notification.h"3
#include "model/termination_notification.h"4
#include "model/deregistration_data.h"5
+#include "model/sdm_subscription.h"6
+#include "model/modification_notification.h"7
8
#include "custom/links.h"9
#include "custom/ue_authentication_ctx.h"10
open5gs_2.4.11.9.e9aac.tar.xz/src/amf/amf-sm.c -> open5gs_2.4.11.10.a99a7.tar.xz/src/amf/amf-sm.c
Changed
13
1
2
amf_namf_callback_handle_dereg_notify(stream, &sbi_message);3
break;4
5
+ CASE(OGS_SBI_RESOURCE_NAME_SDMSUBSCRIPTION_NOTIFY)6
+ amf_namf_callback_handle_sdm_data_change_notify(7
+ stream, &sbi_message);8
+ break;9
+10
CASE(OGS_SBI_RESOURCE_NAME_AM_POLICY_NOTIFY)11
ogs_assert(true == ogs_sbi_send_http_status_no_content(stream));12
break;13
open5gs_2.4.11.9.e9aac.tar.xz/src/amf/context.c -> open5gs_2.4.11.10.a99a7.tar.xz/src/amf/context.c
Changed
10
1
2
3
if (amf_ue->policy_association_id)4
ogs_free(amf_ue->policy_association_id);5
+ if (amf_ue->data_change_subscription_id)6
+ ogs_free(amf_ue->data_change_subscription_id);7
8
if (amf_ue->confirmation_url_for_5g_aka)9
ogs_free(amf_ue->confirmation_url_for_5g_aka);10
open5gs_2.4.11.9.e9aac.tar.xz/src/amf/context.h -> open5gs_2.4.11.10.a99a7.tar.xz/src/amf/context.h
Changed
11
1
2
/* Network Initiated De-Registration */3
bool network_initiated_de_reg;4
5
+ /* SubscriptionId of Subscription to Data Change Notification to UDM */6
+ char *data_change_subscription_id;7
+8
ogs_list_t sess_list;9
};10
11
open5gs_2.4.11.9.e9aac.tar.xz/src/amf/gmm-sm.c -> open5gs_2.4.11.10.a99a7.tar.xz/src/amf/gmm-sm.c
Changed
20
1
2
SWITCH(sbi_message->h.resource.component1)3
CASE(OGS_SBI_RESOURCE_NAME_REGISTRATIONS)4
if (sbi_message->res_status != OGS_SBI_HTTP_STATUS_CREATED &&5
+ sbi_message->res_status != OGS_SBI_HTTP_STATUS_NO_CONTENT &&6
sbi_message->res_status != OGS_SBI_HTTP_STATUS_OK) {7
ogs_error("%s HTTP response error %d",8
amf_ue->supi, sbi_message->res_status);9
10
CASE(OGS_SBI_RESOURCE_NAME_AM_DATA)11
CASE(OGS_SBI_RESOURCE_NAME_SMF_SELECT_DATA)12
CASE(OGS_SBI_RESOURCE_NAME_UE_CONTEXT_IN_SMF_DATA)13
- if (sbi_message->res_status != OGS_SBI_HTTP_STATUS_OK) {14
+ CASE(OGS_SBI_RESOURCE_NAME_SDM_SUBSCRIPTIONS)15
+ if ((sbi_message->res_status != OGS_SBI_HTTP_STATUS_OK) &&16
+ (sbi_message->res_status != OGS_SBI_HTTP_STATUS_CREATED)) {17
ogs_error("%s HTTP response error %d",18
amf_ue->supi, sbi_message->res_status);19
ogs_assert(OGS_OK ==20
open5gs_2.4.11.9.e9aac.tar.xz/src/amf/namf-handler.c -> open5gs_2.4.11.10.a99a7.tar.xz/src/amf/namf-handler.c
Changed
116
1
2
3
return OGS_OK;4
}5
+6
+int amf_namf_callback_handle_sdm_data_change_notify(7
+ ogs_sbi_stream_t *stream, ogs_sbi_message_t *recvmsg)8
+{9
+ int status = OGS_SBI_HTTP_STATUS_NO_CONTENT;10
+11
+ amf_ue_t *amf_ue = NULL;12
+13
+ ogs_sbi_message_t sendmsg;14
+ ogs_sbi_response_t *response = NULL;15
+16
+ OpenAPI_modification_notification_t *ModificationNotification;17
+ OpenAPI_lnode_t *node;18
+19
+ char *ueid = NULL;20
+ char *res_name = NULL;21
+22
+ ogs_assert(stream);23
+ ogs_assert(recvmsg);24
+25
+ ModificationNotification = recvmsg->ModificationNotification;26
+ if (!ModificationNotification) {27
+ status = OGS_SBI_HTTP_STATUS_BAD_REQUEST;28
+ ogs_error("%s No ModificationNotification", amf_ue->supi);29
+ goto cleanup;30
+ }31
+32
+33
+ OpenAPI_list_for_each(ModificationNotification->notify_items, node)34
+ {35
+ OpenAPI_notify_item_t *item = node->data;36
+37
+ char *saveptr = NULL;38
+39
+ ueid = ogs_sbi_parse_uri(item->resource_id, "/", &saveptr);40
+ if (!ueid) {41
+ status = OGS_SBI_HTTP_STATUS_BAD_REQUEST;42
+ ogs_error("%s No UeId", item->resource_id);43
+ goto cleanup;44
+ }45
+46
+ amf_ue = amf_ue_find_by_supi(ueid);47
+ if (!amf_ue) {48
+ status = OGS_SBI_HTTP_STATUS_NOT_FOUND;49
+ ogs_error("Cannot find SUPI %s", ueid);50
+ goto cleanup;51
+ }52
+53
+ res_name = ogs_sbi_parse_uri(NULL, "/", &saveptr);54
+ if (!res_name) {55
+ status = OGS_SBI_HTTP_STATUS_BAD_REQUEST;56
+ ogs_error("%s No Resource Name", item->resource_id);57
+ goto cleanup;58
+ }59
+60
+ SWITCH(res_name)61
+ CASE(OGS_SBI_RESOURCE_NAME_AM_DATA)62
+ OpenAPI_lnode_t *node_ci;63
+64
+ OpenAPI_list_for_each(item->changes, node_ci)65
+ {66
+ /*67
+ OpenAPI_change_item_t *item_change = node_ci->data;68
+ item_change->path;69
+ item_change->from;70
+ item_change->new_value;71
+ item_change->orig_value;72
+ */73
+ /*74
+ switch (item_change->op) {75
+ case OpenAPI_change_type_ADD:76
+ break;77
+ case OpenAPI_change_type_MOVE:78
+ break;79
+ case OpenAPI_change_type__REMOVE:80
+ break;81
+ case OpenAPI_change_type_REPLACE:82
+ break;83
+ default:84
+ break;85
+ }86
+ */87
+ }88
+ break;89
+ DEFAULT90
+ status = OGS_SBI_HTTP_STATUS_BAD_REQUEST;91
+ ogs_error("Unknown Resource Name: %s", res_name);92
+ goto cleanup;93
+ END94
+95
+ ogs_free(ueid);96
+ ogs_free(res_name);97
+98
+ ueid = NULL;99
+ res_name = NULL;100
+ }101
+102
+cleanup:103
+ if (ueid)104
+ ogs_free(ueid);105
+ if (res_name)106
+ ogs_free(res_name);107
+108
+ memset(&sendmsg, 0, sizeof(sendmsg));109
+110
+ response = ogs_sbi_build_response(&sendmsg, status);111
+ ogs_assert(response);112
+ ogs_assert(true == ogs_sbi_server_send_response(stream, response));113
+114
+ return OGS_OK;115
+}116
open5gs_2.4.11.9.e9aac.tar.xz/src/amf/namf-handler.h -> open5gs_2.4.11.10.a99a7.tar.xz/src/amf/namf-handler.h
Changed
10
1
2
ogs_sbi_stream_t *stream, ogs_sbi_message_t *recvmsg);3
int amf_namf_callback_handle_dereg_notify(4
ogs_sbi_stream_t *stream, ogs_sbi_message_t *recvmsg);5
+int amf_namf_callback_handle_sdm_data_change_notify(6
+ ogs_sbi_stream_t *stream, ogs_sbi_message_t *recvmsg);7
8
#ifdef __cplusplus9
}10
open5gs_2.4.11.9.e9aac.tar.xz/src/amf/nudm-build.c -> open5gs_2.4.11.10.a99a7.tar.xz/src/amf/nudm-build.c
Changed
65
1
2
3
return request;4
}5
+6
+ogs_sbi_request_t *amf_nudm_sdm_build_subscription(amf_ue_t *amf_ue, void *data)7
+{8
+ ogs_sbi_message_t message;9
+ ogs_sbi_header_t header;10
+ ogs_sbi_request_t *request = NULL;11
+ ogs_sbi_server_t *server = NULL;12
+13
+ OpenAPI_sdm_subscription_t SDMSubscription;14
+15
+ char *monres = NULL;16
+17
+ ogs_assert(amf_ue);18
+ ogs_assert(amf_ue->supi);19
+ ogs_assert(data);20
+21
+ memset(&message, 0, sizeof(message));22
+ message.h.method = (char *)OGS_SBI_HTTP_METHOD_POST;23
+ message.h.service.name = (char *)OGS_SBI_SERVICE_NAME_NUDM_SDM;24
+ message.h.api.version = (char *)OGS_SBI_API_V2;25
+ message.h.resource.component0 = amf_ue->supi;26
+ message.h.resource.component1 =27
+ (char *)OGS_SBI_RESOURCE_NAME_SDM_SUBSCRIPTIONS;28
+29
+ memset(&SDMSubscription, 0, sizeof(SDMSubscription));30
+31
+ SDMSubscription.nf_instance_id = ogs_sbi_self()->nf_instance->id;32
+33
+ server = ogs_list_first(&ogs_sbi_self()->server_list);34
+ ogs_assert(server);35
+36
+ memset(&header, 0, sizeof(header));37
+ header.service.name = (char *)OGS_SBI_SERVICE_NAME_NAMF_CALLBACK;38
+ header.api.version = (char *)OGS_SBI_API_V1;39
+ header.resource.component0 = amf_ue->supi;40
+ header.resource.component1 =41
+ (char *)OGS_SBI_RESOURCE_NAME_SDMSUBSCRIPTION_NOTIFY;42
+ SDMSubscription.callback_reference =43
+ ogs_sbi_server_uri(server, &header);44
+ ogs_assert(SDMSubscription.callback_reference);45
+46
+ SDMSubscription.monitored_resource_uris = OpenAPI_list_create();47
+48
+ monres = ogs_msprintf("%s/%s", amf_ue->supi, (char *)data);49
+ ogs_assert(monres);50
+51
+ OpenAPI_list_add(SDMSubscription.monitored_resource_uris, monres);52
+ SDMSubscription.implicit_unsubscribe = 1;53
+54
+ message.SDMSubscription = &SDMSubscription;55
+56
+ request = ogs_sbi_build_request(&message);57
+ ogs_assert(request);58
+59
+ ogs_free(monres);60
+ OpenAPI_list_free(SDMSubscription.monitored_resource_uris);61
+ ogs_free(SDMSubscription.callback_reference);62
+63
+ return request;64
+}65
open5gs_2.4.11.9.e9aac.tar.xz/src/amf/nudm-build.h -> open5gs_2.4.11.10.a99a7.tar.xz/src/amf/nudm-build.h
Changed
10
1
2
ogs_sbi_request_t *amf_nudm_uecm_build_registration_delete(3
amf_ue_t *amf_ue, void *data);4
ogs_sbi_request_t *amf_nudm_sdm_build_get(amf_ue_t *amf_ue, void *data);5
+ogs_sbi_request_t *amf_nudm_sdm_build_subscription(6
+ amf_ue_t *amf_ue, void *data);7
8
#ifdef __cplusplus9
}10
open5gs_2.4.11.9.e9aac.tar.xz/src/amf/nudm-handler.c -> open5gs_2.4.11.10.a99a7.tar.xz/src/amf/nudm-handler.c
Changed
71
1
2
break;3
4
CASE(OGS_SBI_RESOURCE_NAME_UE_CONTEXT_IN_SMF_DATA)5
+6
+ if (amf_ue->data_change_subscription_id) {7
+ /* we already have a SDM subscription to UDM; continue without8
+ * subscribing again */9
+ ogs_assert(true ==10
+ amf_ue_sbi_discover_and_send(11
+ OGS_SBI_SERVICE_TYPE_NPCF_AM_POLICY_CONTROL, NULL,12
+ amf_npcf_am_policy_control_build_create, amf_ue, NULL));13
+ }14
+ else {15
+ ogs_assert(true ==16
+ amf_ue_sbi_discover_and_send(17
+ OGS_SBI_SERVICE_TYPE_NUDM_SDM, NULL,18
+ amf_nudm_sdm_build_subscription, amf_ue,19
+ (char *)OGS_SBI_RESOURCE_NAME_AM_DATA));20
+ }21
+ break;22
+23
+ CASE(OGS_SBI_RESOURCE_NAME_SDM_SUBSCRIPTIONS)24
+25
+ int rv;26
+ ogs_sbi_message_t message;27
+ ogs_sbi_header_t header;28
+29
+ if (!recvmsg->http.location) {30
+ ogs_error("%s No http.location", amf_ue->supi);31
+ ogs_assert(OGS_OK ==32
+ nas_5gs_send_gmm_reject_from_sbi(33
+ amf_ue, OGS_SBI_HTTP_STATUS_INTERNAL_SERVER_ERROR));34
+ return OGS_ERROR;35
+ }36
+37
+ memset(&header, 0, sizeof(header));38
+ header.uri = recvmsg->http.location;39
+40
+ rv = ogs_sbi_parse_header(&message, &header);41
+ if (rv != OGS_OK) {42
+ ogs_error("%s Cannot parse http.location %s",43
+ amf_ue->supi, recvmsg->http.location);44
+ ogs_assert(OGS_OK ==45
+ nas_5gs_send_gmm_reject_from_sbi(46
+ amf_ue, OGS_SBI_HTTP_STATUS_INTERNAL_SERVER_ERROR));47
+ return OGS_ERROR;48
+ }49
+50
+ if (!message.h.resource.component2) {51
+ ogs_error("%s No Subscription ID %s",52
+ amf_ue->supi, recvmsg->http.location);53
+54
+ ogs_sbi_header_free(&header);55
+ ogs_assert(OGS_OK ==56
+ nas_5gs_send_gmm_reject_from_sbi(57
+ amf_ue, OGS_SBI_HTTP_STATUS_INTERNAL_SERVER_ERROR));58
+ return OGS_ERROR;59
+ }60
+61
+ if (amf_ue->data_change_subscription_id)62
+ ogs_free(amf_ue->data_change_subscription_id);63
+ amf_ue->data_change_subscription_id =64
+ ogs_strdup(message.h.resource.component2);65
+66
+ ogs_sbi_header_free(&header);67
+68
ogs_assert(true ==69
amf_ue_sbi_discover_and_send(70
OGS_SBI_SERVICE_TYPE_NPCF_AM_POLICY_CONTROL, NULL,71
open5gs_2.4.11.9.e9aac.tar.xz/src/udm/context.c -> open5gs_2.4.11.10.a99a7.tar.xz/src/udm/context.c
Changed
10
1
2
ogs_free(udm_ue->amf_instance_id);3
if (udm_ue->dereg_callback_uri)4
ogs_free(udm_ue->dereg_callback_uri);5
+ if (udm_ue->data_change_callback_uri)6
+ ogs_free(udm_ue->data_change_callback_uri);7
8
ogs_pool_free(&udm_ue_pool, udm_ue);9
}10
open5gs_2.4.11.9.e9aac.tar.xz/src/udm/context.h -> open5gs_2.4.11.10.a99a7.tar.xz/src/udm/context.h
Changed
9
1
2
char *amf_instance_id;3
4
char *dereg_callback_uri;5
+ char *data_change_callback_uri;6
7
uint8_t kOGS_KEY_LEN;8
uint8_t opcOGS_KEY_LEN;9
open5gs_2.4.11.9.e9aac.tar.xz/src/udm/nudm-handler.c -> open5gs_2.4.11.10.a99a7.tar.xz/src/udm/nudm-handler.c
Changed
87
1
2
3
return true;4
}5
+6
+bool udm_nudm_sdm_handle_subscription_create(7
+ udm_ue_t *udm_ue, ogs_sbi_stream_t *stream, ogs_sbi_message_t *recvmsg)8
+{9
+ ogs_sbi_message_t sendmsg;10
+ ogs_sbi_response_t *response = NULL;11
+ ogs_sbi_server_t *server = NULL;12
+ ogs_sbi_header_t header;13
+14
+ OpenAPI_sdm_subscription_t *SDMSubscription = NULL;15
+16
+ ogs_assert(udm_ue);17
+ ogs_assert(stream);18
+ ogs_assert(recvmsg);19
+20
+ SDMSubscription = recvmsg->SDMSubscription;21
+ if (!SDMSubscription) {22
+ ogs_error("%s No SDMSubscription", udm_ue->supi);23
+ ogs_assert(true ==24
+ ogs_sbi_server_send_error(stream, OGS_SBI_HTTP_STATUS_BAD_REQUEST,25
+ recvmsg, "No SDMSubscription", udm_ue->supi));26
+ return false;27
+ }28
+29
+ if (!SDMSubscription->nf_instance_id) {30
+ ogs_error("%s No nfInstanceId", udm_ue->supi);31
+ ogs_assert(true ==32
+ ogs_sbi_server_send_error(stream, OGS_SBI_HTTP_STATUS_BAD_REQUEST,33
+ recvmsg, "No nfInstanceId", udm_ue->supi));34
+ return false;35
+ }36
+37
+ if (!SDMSubscription->callback_reference) {38
+ ogs_error("%s No callbackReference", udm_ue->supi);39
+ ogs_assert(true ==40
+ ogs_sbi_server_send_error(stream, OGS_SBI_HTTP_STATUS_BAD_REQUEST,41
+ recvmsg, "No callbackReference", udm_ue->supi));42
+ return false;43
+ }44
+45
+ if ((!SDMSubscription->monitored_resource_uris) &&46
+ (!SDMSubscription->monitored_resource_uris->count)) {47
+ ogs_error("%s No monitoredResourceUris", udm_ue->supi);48
+ ogs_assert(true ==49
+ ogs_sbi_server_send_error(stream, OGS_SBI_HTTP_STATUS_BAD_REQUEST,50
+ recvmsg, "No monitoredResourceUris", udm_ue->supi));51
+ return false;52
+ }53
+54
+ if (udm_ue->data_change_callback_uri)55
+ ogs_free(udm_ue->data_change_callback_uri);56
+ udm_ue->data_change_callback_uri =57
+ ogs_strdup(SDMSubscription->callback_reference);58
+59
+60
+ server = ogs_sbi_server_from_stream(stream);61
+ ogs_assert(server);62
+63
+ memset(&header, 0, sizeof(header));64
+ header.service.name = (char *)OGS_SBI_SERVICE_NAME_NUDM_SDM;65
+ header.api.version = (char *)OGS_SBI_API_V2;66
+ header.resource.component0 = udm_ue->supi;67
+ header.resource.component1 =68
+ (char *)OGS_SBI_RESOURCE_NAME_SDM_SUBSCRIPTIONS;69
+ /* TODO: subscription id */70
+ header.resource.component2 = udm_ue->ctx_id;71
+72
+ memset(&sendmsg, 0, sizeof(sendmsg));73
+ sendmsg.http.location = ogs_sbi_server_uri(server, &header);74
+75
+ sendmsg.SDMSubscription = OpenAPI_sdm_subscription_copy(76
+ sendmsg.SDMSubscription, SDMSubscription);77
+78
+ response = ogs_sbi_build_response(&sendmsg, OGS_SBI_HTTP_STATUS_CREATED);79
+ ogs_assert(response);80
+ ogs_sbi_server_send_response(stream, response);81
+82
+ ogs_free(sendmsg.http.location);83
+ OpenAPI_sdm_subscription_free(sendmsg.SDMSubscription);84
+85
+ return true;86
+}87
open5gs_2.4.11.9.e9aac.tar.xz/src/udm/nudm-handler.h -> open5gs_2.4.11.10.a99a7.tar.xz/src/udm/nudm-handler.h
Changed
10
1
2
3
bool udm_nudm_sdm_handle_subscription_provisioned(4
udm_ue_t *udm_ue, ogs_sbi_stream_t *stream, ogs_sbi_message_t *recvmsg);5
+bool udm_nudm_sdm_handle_subscription_create(6
+ udm_ue_t *udm_ue, ogs_sbi_stream_t *stream, ogs_sbi_message_t *recvmsg);7
8
#ifdef __cplusplus9
}10
open5gs_2.4.11.9.e9aac.tar.xz/src/udm/ue-sm.c -> open5gs_2.4.11.10.a99a7.tar.xz/src/udm/ue-sm.c
Changed
25
1
2
"Invalid resource name", message->h.method));3
END4
break;5
+6
+ CASE(OGS_SBI_HTTP_METHOD_POST)7
+ SWITCH(message->h.resource.component1)8
+ CASE(OGS_SBI_RESOURCE_NAME_SDM_SUBSCRIPTIONS)9
+ udm_nudm_sdm_handle_subscription_create(10
+ udm_ue, stream, message);11
+ break;12
+13
+ DEFAULT14
+ ogs_error("%s Invalid resource name %s",15
+ udm_ue->suci, message->h.resource.component1);16
+ ogs_assert(true ==17
+ ogs_sbi_server_send_error(stream,18
+ OGS_SBI_HTTP_STATUS_BAD_REQUEST, message,19
+ "Invalid resource name", message->h.method));20
+ END21
+ break;22
DEFAULT23
ogs_error("%s Invalid HTTP method %s",24
udm_ue->supi, message->h.method);25