Skip to content
Open
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions source/drivers/MessageBus.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -263,6 +263,10 @@ int MessageBus::deleteMarkedListeners()
Listener *t = l;
l = l->next;

// If notification of deletion has been requested, invoke the listener deletion callback.
if (listener_deletion_callback)
listener_deletion_callback(t);

delete t;
removed++;

Expand Down Expand Up @@ -520,10 +524,6 @@ int MessageBus::remove(Listener *listener)
{
if ((listener->id == DEVICE_ID_ANY || listener->id == l->id) && (listener->value == DEVICE_EVT_ANY || listener->value == l->value))
{
// If notification of deletion has been requested, invoke the listener deletion callback.
if (listener_deletion_callback)
listener_deletion_callback(l);

// Found a match. mark this to be removed from the list.
l->flags |= MESSAGE_BUS_LISTENER_DELETING;
removed++;
Expand Down