| /aosp12/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/ |
| H A D | SampleChunkIoHelper.java | 100 private final ConditionVariable conditionVariable; field in SampleChunkIoHelper.IoParams
107 ConditionVariable conditionVariable, in IoParams() argument
112 this.conditionVariable = conditionVariable; in IoParams()
258 conditionVariable.close(); in writeSample()
259 IoParams params = new IoParams(index, 0, sample, conditionVariable, null); in writeSample()
312 ConditionVariable conditionVariable = new ConditionVariable(); in release() local
313 mIoHandler.sendMessage(mIoHandler.obtainMessage(MSG_RELEASE, conditionVariable)); in release()
314 conditionVariable.block(); in release()
541 params.conditionVariable.open(); in doWrite()
560 private void doRelease(ConditionVariable conditionVariable) { in doRelease() argument
[all …]
|
| H A D | RecordingSampleBuffer.java | 183 public void writeSample(int index, SampleHolder sample, ConditionVariable conditionVariable) in writeSample() argument
185 mSampleChunkIoHelper.writeSample(index, sample, conditionVariable); in writeSample()
187 if (!conditionVariable.block(BUFFER_WRITE_TIMEOUT_MS)) { in writeSample()
189 conditionVariable.block(); in writeSample()
|
| H A D | SimpleSampleBuffer.java | 123 public void writeSample(int index, SampleHolder sample, ConditionVariable conditionVariable) in writeSample() argument
|
| H A D | BufferManager.java | 126 void writeSample(int index, SampleHolder sample, ConditionVariable conditionVariable) in writeSample() argument
|
| /aosp12/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer2/buffer/ |
| H A D | SampleChunkIoHelper.java | 102 private final ConditionVariable conditionVariable; field in SampleChunkIoHelper.IoParams
109 ConditionVariable conditionVariable, in IoParams() argument
114 this.conditionVariable = conditionVariable; in IoParams()
298 ConditionVariable conditionVariable) throws IOException { in writeSample() argument
302 conditionVariable.close(); in writeSample()
303 IoParams params = new IoParams(index, 0, sample, conditionVariable, null); in writeSample()
356 ConditionVariable conditionVariable = new ConditionVariable(); in release() local
358 conditionVariable.block(); in release()
586 params.conditionVariable.open(); in doWrite()
605 private void doRelease(ConditionVariable conditionVariable) { in doRelease() argument
[all …]
|
| H A D | RecordingSampleBuffer.java | 184 ConditionVariable conditionVariable) throws IOException { in writeSample() argument
185 mSampleChunkIoHelper.writeSample(index, sample, conditionVariable); in writeSample()
187 if (!conditionVariable.block(BUFFER_WRITE_TIMEOUT_MS)) { in writeSample()
189 conditionVariable.block(); in writeSample()
|
| H A D | MemorySampleBuffer.java | 97 int index, DecoderInputBuffer sample, ConditionVariable conditionVariable) { in writeSample() argument
|
| H A D | BufferManager.java | 132 void writeSample(int index, DecoderInputBuffer sample, ConditionVariable conditionVariable) in writeSample() argument
|
| /aosp12/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer2/ |
| H A D | ExoPlayerSampleExtractor.java | 284 ConditionVariable conditionVariable = new ConditionVariable(); in handleMessage() local
288 && C.RESULT_NOTHING_READ != fetchSample(i, conditionVariable)) { in handleMessage()
323 private int fetchSample(int track, ConditionVariable conditionVariable) { in fetchSample() argument
345 queueSample(track, conditionVariable); in fetchSample()
367 private void queueSample(int index, ConditionVariable conditionVariable) in queueSample() argument
393 mSampleBuffer.writeSample(pair.first, pair.second, conditionVariable); in queueSample()
416 mSampleBuffer.writeSample(index, mDecoderInputBufferDuplicate, conditionVariable); in queueSample()
|
| /aosp12/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/ |
| H A D | ExoPlayerSampleExtractor.java | 328 ConditionVariable conditionVariable = new ConditionVariable(); in handleMessage() local
332 && C.RESULT_NOTHING_READ != fetchSample(i, conditionVariable)) { in handleMessage()
367 private int fetchSample(int track, ConditionVariable conditionVariable) { in fetchSample() argument
389 queueSample(track, conditionVariable); in fetchSample()
411 private void queueSample(int index, ConditionVariable conditionVariable) in queueSample() argument
446 mSampleBuffer.writeSample(pair.first, pair.second, conditionVariable); in queueSample()
473 mSampleBuffer.writeSample(index, mSampleHolder, conditionVariable); in queueSample()
|
| /aosp12/frameworks/av/media/libaaudio/tests/ |
| H A D | test_various.cpp | 773 conditionVariable.notify_one(); in wakeOther()
778 conditionVariable.wait(aLock, [=] { return finished; }); in waitForFinished()
783 std::condition_variable conditionVariable; member
|
| /aosp12/packages/modules/Connectivity/tests/unit/java/com/android/server/ |
| H A D | ConnectivityServiceTest.java | 1561 static private void waitFor(ConditionVariable conditionVariable) { in waitFor() argument
1562 if (conditionVariable.block(TIMEOUT_MS)) { in waitFor()
|