Searched refs:readHead (Results 1 – 3 of 3) sorted by relevance
| /packages/modules/Connectivity/staticlibs/testutils/hostdevice/com/android/net/module/util/ |
| D | TrackRecord.kt | 214 private var readHead = 0 in newReadHead() variable
223 get() = checkThread { readHead } in newReadHead()
228 readHead = v in newReadHead()
268 pollMark = readHead in newReadHead()
271 val index = pollForIndexReadLocked(timeoutMs, readHead, predicate) in newReadHead()
272 readHead = if (index < 0) size else index + 1 in newReadHead()
306 fun peek(): E? = checkThread { getOrNull(readHead) } in newReadHead()
|
| /packages/modules/Connectivity/staticlibs/tests/unit/src/com/android/net/module/util/ |
| D | TrackRecordTest.kt | 190 val readHead = ArrayTrackRecord<Int>().newReadHead() in <lambda>() constant
195 readHead.poll(LONG_TIMEOUT) in <lambda>()
199 readHead.add(0) in <lambda>()
204 readHead.poll(LONG_TIMEOUT) in <lambda>()
208 readHead.add(0) in <lambda>()
|
| /packages/modules/Connectivity/tests/unit/java/com/android/server/ |
| D | ConnectivityServiceTest.java | 10733 final ArrayTrackRecord<ReportedInterfaces>.ReadHead readHead =
10735 assertNotNull(readHead.poll(TIMEOUT_MS, ri -> ri.contentEquals(mServiceContext,
10744 assertNotNull(readHead.poll(TIMEOUT_MS, ri -> ri.contentEquals(mServiceContext,
10755 assertNotNull(readHead.poll(TIMEOUT_MS, ri -> ri.contentEquals(mServiceContext,
10922 final ArrayTrackRecord<ReportedInterfaces>.ReadHead readHead =
10924 assertNotNull(readHead.poll(TIMEOUT_MS, ri -> ri.contentEquals(mServiceContext,
10945 assertNull(readHead.poll(0 /* timeout */, ri -> mServiceContext.equals(ri.context)
11000 assertNotNull(readHead.poll(TIMEOUT_MS, ri -> ri.contentEquals(mServiceContext,
18461 final ArrayTrackRecord<Pair<String, Long>>.ReadHead readHead =
18467 assertNotNull(readHead.poll(TIMEOUT_MS, it -> it.first == wifiLp.getInterfaceName()
[all …]
|