Searched refs:mSubscribers (Results 1 – 3 of 3) sorted by relevance
75 private final ArrayMap<QueryParam, ArrayList<DataSubscriber>> mSubscribers = new ArrayMap<>(); field in ConnectivityPublisher109 mSubscribers.put(QueryParam.build(transport, oemType), new ArrayList<>()); in ConnectivityPublisher()125 for (int i = 0; i < mSubscribers.size(); i++) { in handleSessionStateChange()126 if (mSubscribers.valueAt(i).isEmpty()) { in handleSessionStateChange()130 PersistableBundle bundle = pullNetstatsAndCalculateDiff(mSubscribers.keyAt(i)); in handleSessionStateChange()135 resultsToStore.putPersistableBundle(mSubscribers.keyAt(i).toString(), bundle); in handleSessionStateChange()149 mSubscribers.get(QueryParam.forSubscriber(subscriber)).add(subscriber); in addDataSubscriber()154 mSubscribers.get(QueryParam.forSubscriber(subscriber)).remove(subscriber); in removeDataSubscriber()159 for (int i = 0; i < mSubscribers.size(); i++) { in removeAllDataSubscribers()160 mSubscribers.valueAt(i).clear(); in removeAllDataSubscribers()[all …]
78 private final Map<Integer, List<IVehicleCallback>> mSubscribers = new HashMap<>(); field in HidlMockedVehicleHal105 while (mSubscribers.get(propId) == null) { in waitForSubscriber()110 return mSubscribers.get(propId) != null; in waitForSubscriber()120 List<IVehicleCallback> callbacks = mSubscribers.get(value.prop); in injectEvent()152 List<IVehicleCallback> callbacks = mSubscribers.get(propertyId); in injectError()238 List<IVehicleCallback> subscribers = mSubscribers.get(opt.propId); in subscribe()241 mSubscribers.put(opt.propId, subscribers); in subscribe()268 List<IVehicleCallback> subscribers = mSubscribers.get(propId); in unsubscribe()272 mSubscribers.remove(propId); in unsubscribe()
101 private final SparseArray<List<IVehicleCallback>> mSubscribers = new SparseArray<>(); field in AidlMockedVehicleHal124 while (mSubscribers.get(propId) == null) { in waitForSubscriber()130 return mSubscribers.get(propId) != null; in waitForSubscriber()139 List<IVehicleCallback> callbacks = mSubscribers.get(value.prop); in injectEvent()172 List<IVehicleCallback> callbacks = mSubscribers.get(propertyId); in injectError()298 if (generateEvent && mSubscribers.get(propId) != null) { in setValues()299 for (IVehicleCallback subCallback: mSubscribers.get(propId)) { in setValues()345 List<IVehicleCallback> subscribers = mSubscribers.get(opt.propId); in subscribe()348 mSubscribers.put(opt.propId, subscribers); in subscribe()377 List<IVehicleCallback> subscribers = mSubscribers.get(propId); in unsubscribe()[all …]