Home
last modified time | relevance | path

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

/aosp12/packages/apps/Camera2/src/com/android/camera/one/v2/initialization/
H A DInitializedOneCameraFactory.java25 import com.android.camera.async.ConcurrentState;
95 final ConcurrentState<Float> zoomState = new ConcurrentState<>(1.0f); in InitializedOneCameraFactory()
96 final ConcurrentState<Integer> afState = new ConcurrentState<>( in InitializedOneCameraFactory()
98 final ConcurrentState<OneCamera.FocusState> focusState = new ConcurrentState<>(new in InitializedOneCameraFactory()
100 final ConcurrentState<Integer> afMode = new ConcurrentState<>(CaptureResult in InitializedOneCameraFactory()
102 final ConcurrentState<Boolean> readyState = new ConcurrentState<>(false); in InitializedOneCameraFactory()
/aosp12/packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ringbuffer/
H A DAvailableTicketCounter.java19 import com.android.camera.async.ConcurrentState;
43 private final ConcurrentState<Integer> mCount;
48 mCount = new ConcurrentState<>(0); in AvailableTicketCounter()
H A DDynamicRingBuffer.java21 import com.android.camera.async.ConcurrentState;
67 private final ConcurrentState<Integer> mQueueSize;
74 mQueueSize = new ConcurrentState<>(0); in DynamicRingBuffer()
/aosp12/packages/apps/Camera2/src/com/android/camera/one/v2/core/
H A DObservableFrameServer.java21 import com.android.camera.async.ConcurrentState;
48 private final ConcurrentState<Boolean> mAvailability;
80 mAvailability = new ConcurrentState<>(true); in ObservableFrameServer()
/aosp12/packages/apps/Camera2/src/com/android/camera/one/v2/autofocus/
H A DManualAutoFocusFactory.java23 import com.android.camera.async.ConcurrentState;
79 ConcurrentState<MeteringParameters> currentMeteringParameters = new ConcurrentState<>( in create()
/aosp12/packages/apps/Camera2/src/com/android/camera/async/
H A DListenable.java26 private final ConcurrentState<T> mState;
32 public Listenable(ConcurrentState<T> state, MainThread mainThread) { in Listenable()
H A DConcurrentState.java32 public class ConcurrentState<T> implements Updatable<T>, Observable<T> { class
54 public ConcurrentState(T initialValue) { in ConcurrentState() method in ConcurrentState
H A DCountableBufferQueue.java63 public CountableBufferQueue(ConcurrentState<Integer> sizeCallback) { in CountableBufferQueue()
/aosp12/packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ticketpool/
H A DFiniteTicketPool.java19 import com.android.camera.async.ConcurrentState;
79 private final ConcurrentState<Integer> mAvailableTicketCount;
91 mAvailableTicketCount = new ConcurrentState<>(capacity); in FiniteTicketPool()
H A DReservableTicketPool.java19 import com.android.camera.async.ConcurrentState;
139 private final ConcurrentState<Integer> mAvailableTicketCount;
153 mAvailableTicketCount = new ConcurrentState<>(0); in ReservableTicketPool()