Loading libstats/pull/stats_pull_atom_callback.cpp +5 −1 Original line number Diff line number Diff line Loading @@ -131,7 +131,11 @@ class StatsPullAtomCallbackInternal : public BnPullAtomCallback { parcels.push_back(std::move(p)); } resultReceiver->pullFinished(atomTag, success, parcels); Status status = resultReceiver->pullFinished(atomTag, success, parcels); if (!status.isOk()) { std::vector<StatsEventParcel> emptyParcels; resultReceiver->pullFinished(atomTag, /*success=*/false, emptyParcels); } for (int i = 0; i < statsEventList.data.size(); i++) { AStatsEvent_release(statsEventList.data[i]); } Loading Loading
libstats/pull/stats_pull_atom_callback.cpp +5 −1 Original line number Diff line number Diff line Loading @@ -131,7 +131,11 @@ class StatsPullAtomCallbackInternal : public BnPullAtomCallback { parcels.push_back(std::move(p)); } resultReceiver->pullFinished(atomTag, success, parcels); Status status = resultReceiver->pullFinished(atomTag, success, parcels); if (!status.isOk()) { std::vector<StatsEventParcel> emptyParcels; resultReceiver->pullFinished(atomTag, /*success=*/false, emptyParcels); } for (int i = 0; i < statsEventList.data.size(); i++) { AStatsEvent_release(statsEventList.data[i]); } Loading