Skip to content

Commit 79c6c36

Browse files
authored
ISSUE-1392: decrement delivery reference counter on action discard (skupperproject#1393)
1 parent 85b8d28 commit 79c6c36

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

src/router_core/delivery.c

+6-3
Original file line numberDiff line numberDiff line change
@@ -1226,13 +1226,16 @@ void qdr_delivery_continue_peers_CT(qdr_core_t *core, qdr_delivery_t *in_dlv, bo
12261226

12271227
static void qdr_delivery_continue_CT(qdr_core_t *core, qdr_action_t *action, bool discard)
12281228
{
1229-
if (discard)
1230-
return;
1231-
12321229
qdr_delivery_t *in_dlv = action->args.delivery.delivery;
12331230
bool more = action->args.delivery.more;
12341231
bool presettled = action->args.delivery.presettled;
12351232

1233+
1234+
if (discard) {
1235+
qdr_delivery_decref_CT(core, in_dlv, "qdr_delivery_continue_CT - remove from action to discard");
1236+
return;
1237+
}
1238+
12361239
//
12371240
// If the delivery is already pre-settled, don't do anything with the pre-settled flag.
12381241
//

0 commit comments

Comments
 (0)