Home
last modified time | relevance | path

Searched refs:mBatches (Results 1 – 10 of 10) sorted by relevance

/frameworks/base/services/devicepolicy/java/com/android/server/devicepolicy/
DNetworkLoggingHandler.java106 private final LongSparseArray<ArrayList<NetworkEvent>> mBatches = field in NetworkLoggingHandler
209 if (mBatches.size() > 0 && mLastRetrievedBatchToken != mCurrentBatchToken) { in resume()
220 mBatches.clear(); in discardLogs()
242 if (mBatches.size() >= MAX_BATCHES) { in finalizeBatchAndBuildAdminMessageLocked()
244 mBatches.removeAt(0); in finalizeBatchAndBuildAdminMessageLocked()
247 mBatches.append(mCurrentBatchToken, mNetworkEvents); in finalizeBatchAndBuildAdminMessageLocked()
268 final int lastBatchSize = mBatches.valueAt(mBatches.size() - 1).size(); in buildAdminMessageLocked()
289 final int index = mBatches.indexOfKey(batchToken); in retrieveFullLogBatch()
301 while (mBatches.size() > 0 && mBatches.keyAt(0) <= batchToken) { in retrieveFullLogBatch()
302 mBatches.removeAt(0); in retrieveFullLogBatch()
[all …]
/frameworks/base/packages/SystemUI/src/com/android/systemui/statusbar/notification/collection/coalescer/
DGroupCoalescer.java80 private final Map<String, EventBatch> mBatches = new ArrayMap<>(); field in GroupCoalescer
184 final EventBatch batch = mBatches.get(sbn.getGroupKey()); in maybeEmitBatch()
229 EventBatch batch = mBatches.get(groupKey); in getOrBuildBatch()
232 mBatches.put(groupKey, batch); in getOrBuildBatch()
251 if (batch != mBatches.get(batch.mGroupKey)) { in emitBatch()
262 mBatches.remove(batch.mGroupKey); in emitBatch()
307 for (EventBatch batch : mBatches.values()) { in dump()
/frameworks/native/libs/input/
DInputConsumer.cpp280 Batch& batch = mBatches[batchIndex]; in consume()
296 mBatches.erase(mBatches.begin() + batchIndex); in consume()
303 mBatches.erase(mBatches.begin() + batchIndex); in consume()
320 mBatches.push_back(batch); in consume()
397 for (size_t i = mBatches.size(); i > 0;) { in consumeBatch()
399 Batch& batch = mBatches[i]; in consumeBatch()
402 mBatches.erase(mBatches.begin() + i); in consumeBatch()
418 mBatches.erase(mBatches.begin() + i); in consumeBatch()
800 return !mBatches.empty(); in hasPendingBatch()
804 if (mBatches.empty()) { in getPendingBatchSource()
[all …]
DInputConsumerNoResampling.cpp281 return (!mBatches.empty()) || mChannel->probablyHasInput(); in probablyHasInput()
326 mBatches[deviceId].emplace(msg); in handleMessages()
347 for (const auto& [_, pendingMessages] : mBatches) { in handleMessages()
353 std::any_of(mBatches.begin(), mBatches.end(), [=](const auto& pair) { in handleMessages()
455 for (auto& [deviceId, messages] : mBatches) { in consumeBatchedInputEvents()
489 std::erase_if(mBatches, [](const auto& pair) { return pair.second.empty(); }); in consumeBatchedInputEvents()
516 if (mBatches.empty()) { in dump()
520 for (const auto& [deviceId, messages] : mBatches) { in dump()
/frameworks/rs/cpu_ref/
DrsCpuScriptGroup2.cpp180 mBatches.push_back(batch); in CpuScriptGroup2Impl()
191 mBatches.push_back(batch); in CpuScriptGroup2Impl()
196 for (Batch* batch : mBatches) { in CpuScriptGroup2Impl()
214 for (Batch* batch : mBatches) { in ~CpuScriptGroup2Impl()
372 for (const Batch* b : mBatches) in compile()
415 for (const auto& batch : mBatches) { in compile()
574 for (auto batch : mBatches) { in execute()
DrsCpuScriptGroup2.h76 List<Batch*> mBatches; variable
/frameworks/native/include/input/
DInputConsumerNoResampling.h183 std::map<DeviceId, std::queue<InputMessage>> mBatches; variable
DInputConsumer.h130 std::vector<Batch> mBatches; variable
/frameworks/base/services/tests/mockingservicestests/src/com/android/server/job/
DJobSchedulerServiceTest.java1897 assertNull(maybeQueueFunctor.mBatches.get(null)); in testConnectivityJobBatching()
1898 assertEquals(i + 1, maybeQueueFunctor.mBatches.get(network).size()); in testConnectivityJobBatching()
1918 assertNull(maybeQueueFunctor.mBatches.get(null)); in testConnectivityJobBatching()
1919 assertEquals(i + 1, maybeQueueFunctor.mBatches.get(network).size()); in testConnectivityJobBatching()
1942 assertEquals(i + 1, maybeQueueFunctor.mBatches.get(network).size()); in testConnectivityJobBatching()
1969 assertEquals(i + 1, maybeQueueFunctor.mBatches.get(network).size()); in testConnectivityJobBatching()
1994 assertEquals(i + 1, maybeQueueFunctor.mBatches.get(network).size()); in testConnectivityJobBatching()
2016 assertEquals(1, maybeQueueFunctor.mBatches.get(network).size()); in testConnectivityJobBatching()
2047 assertEquals(i + 1, maybeQueueFunctor.mBatches.get(null).size()); in testActiveJobBatching_activeBatchingEnabled()
2062 assertEquals(i + 1, maybeQueueFunctor.mBatches.get(null).size()); in testActiveJobBatching_activeBatchingEnabled()
[all …]
/frameworks/base/apex/jobscheduler/service/java/com/android/server/job/
DJobSchedulerService.java3598 final ArrayMap<Network, ArraySet<JobStatus>> mBatches = new ArrayMap<>();
3710 ArraySet<JobStatus> batch = mBatches.get(network);
3713 mBatches.put(network, batch);
3778 for (int n = mBatches.size() - 1; n >= 0; --n) {
3779 final Network network = mBatches.keyAt(n);
3797 final ArraySet<JobStatus> batchedJobs = mBatches.valueAt(n);
3834 final ArraySet<JobStatus> batchedNonNetworkedJobs = mBatches.get(null);
3909 mBatches.clear();