Skip to content
This repository was archived by the owner on Dec 20, 2023. It is now read-only.

Commit f65c034

Browse files
author
Jay Logue
authored
Merge pull request #456 from openweave/feature/wdm-con-support-and-clean-up
Support for WDM subscriptions and update over connections
2 parents 82493b7 + 9ff3a98 commit f65c034

File tree

77 files changed

+725
-642
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

77 files changed

+725
-642
lines changed

src/lib/profiles/data-management/Current/NotificationEngine.cpp

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1122,13 +1122,17 @@ WEAVE_ERROR NotificationEngine::SendNotify(PacketBuffer * aBuffer, SubscriptionH
11221122
{
11231123
WEAVE_ERROR err = WEAVE_NO_ERROR;
11241124

1125-
err = aSubHandler->SendNotificationRequest(aBuffer);
1126-
SuccessOrExit(err);
1127-
11281125
// We can only have 1 notify in flight for any given subscription - increment and break out.
11291126
mNumNotifiesInFlight++;
11301127

1128+
err = aSubHandler->SendNotificationRequest(aBuffer);
1129+
SuccessOrExit(err);
1130+
11311131
exit:
1132+
if (err != WEAVE_NO_ERROR)
1133+
{
1134+
mNumNotifiesInFlight--;
1135+
}
11321136
return err;
11331137
}
11341138

@@ -1584,7 +1588,7 @@ WEAVE_ERROR NotificationEngine::BuildSingleNotifyRequest(SubscriptionHandler * a
15841588
{
15851589
// abort subscription, squash error, signal to upper
15861590
// layers that the subscription is done
1587-
aSubHandler->HandleSubscriptionTerminated(err, NULL);
1591+
aSubHandler->TerminateSubscription(err, NULL, false);
15881592

15891593
aSubscriptionHandled = true;
15901594
err = WEAVE_NO_ERROR;

0 commit comments

Comments
 (0)