diff options
Diffstat (limited to 'src/4a-internals-hal/4a-internals-hal-cb.c')
| -rw-r--r-- | src/4a-internals-hal/4a-internals-hal-cb.c | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/src/4a-internals-hal/4a-internals-hal-cb.c b/src/4a-internals-hal/4a-internals-hal-cb.c index 07bad11..199fc5a 100644 --- a/src/4a-internals-hal/4a-internals-hal-cb.c +++ b/src/4a-internals-hal/4a-internals-hal-cb.c @@ -1079,7 +1079,7 @@ void InternalHalInfo(afb_req_t request) } streamsArray = HalUtlGetJsonArrayForAllMixersData(apiHandle, - ¤tHalData->internalHalData->streamsData); + ¤tHalData->internalHalData->streamsDataListHead); if(! streamsArray) { afb_req_fail(request, "streams_data", "Didn't succeed to generate streams data array"); return; @@ -1214,10 +1214,9 @@ void InternalHalSubscribeUnsubscribe(afb_req_t request, enum SubscribeUnsubscrib subscriptionDoneNb++; } - currentStreamData = currentHalData->internalHalData->streamsData; - while(currentStreamData && - ! subscriptionFound) { - if(! strcasecmp(currentSubscriptionString, currentStreamData->verb)) { + cds_list_for_each_entry(currentStreamData, ¤tHalData->internalHalData->streamsDataListHead, node) { + if(! subscriptionFound && + ! strcasecmp(currentSubscriptionString, currentStreamData->verb)) { if(currentStreamData->event && subscribeUnsubscribeType == SUBSCRIPTION && afb_req_subscribe(request, currentStreamData->event)) { @@ -1241,8 +1240,6 @@ void InternalHalSubscribeUnsubscribe(afb_req_t request, enum SubscribeUnsubscrib subscriptionDoneNb++; break; } - - currentStreamData = currentStreamData->next; } searchIdx = 0; |