1 files changed, 164 insertions, 0 deletions
diff --git a/camera2/public/src/com/android/ex/camera2/blocking/BlockingCaptureCallback.java b/camera2/public/src/com/android/ex/camera2/blocking/BlockingCaptureCallback.java
new file mode 100644
index 0000000..f55437f
--- /dev/null
+++ b/camera2/public/src/com/android/ex/camera2/blocking/BlockingCaptureCallback.java
@@ -0,0 +1,164 @@
+/*
+ * Copyright 2014 The Android Open Source Project
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.android.ex.camera2.blocking;
+
+import android.hardware.camera2.CameraCaptureSession;
+import android.hardware.camera2.CaptureFailure;
+import android.hardware.camera2.CaptureRequest;
+import android.hardware.camera2.CaptureResult;
+import android.hardware.camera2.TotalCaptureResult;
+import android.util.Log;
+
+import com.android.ex.camera2.utils.StateChangeListener;
+import com.android.ex.camera2.utils.StateWaiter;
+
+/**
+ * A camera capture listener that implements blocking operations on state changes for a
+ * particular capture request.
+ *
+ * <p>Provides a waiter that can be used to block until the next unobserved state of the
+ * requested type arrives.</p>
+ *
+ * <p>Pass-through all StateListener changes to the proxy.</p>
+ *
+ * @see #getStateWaiter
+ */
+public class BlockingCaptureCallback extends CameraCaptureSession.CaptureCallback {
+
+    /**
+     * {@link #onCaptureStarted} has been called.
+     */
+    public static final int CAPTURE_STARTED = 0;
+
+    /**
+     * {@link #onCaptureProgressed} has been
+     * called.
+     */
+    public static final int CAPTURE_PROGRESSED = 1;
+
+    /**
+     * {@link #onCaptureCompleted} has
+     * been called.
+     */
+    public static final int CAPTURE_COMPLETED = 2;
+
+    /**
+     * {@link #onCaptureFailed} has been
+     * called.
+     */
+    public static final int CAPTURE_FAILED = 3;
+
+    /**
+     * {@link #onCaptureSequenceCompleted} has been called.
+     */
+    public static final int CAPTURE_SEQUENCE_COMPLETED = 4;
+
+    /**
+     * {@link #onCaptureSequenceAborted} has been called.
+     */
+    public static final int CAPTURE_SEQUENCE_ABORTED = 5;
+
+    private static final String[] sStateNames = {
+            "CAPTURE_STARTED",
+            "CAPTURE_PROGRESSED",
+            "CAPTURE_COMPLETED",
+            "CAPTURE_FAILED",
+            "CAPTURE_SEQUENCE_COMPLETED",
+            "CAPTURE_SEQUENCE_ABORTED"
+    };
+
+    private static final String TAG = "BlockingCaptureCallback";
+    private static final boolean VERBOSE = Log.isLoggable(TAG, Log.VERBOSE);
+
+    private final CameraCaptureSession.CaptureCallback mProxy;
+
+    private final StateWaiter mStateWaiter = new StateWaiter(sStateNames);
+    private final StateChangeListener mStateChangeListener = mStateWaiter.getListener();
+
+    /**
+     * Create a blocking capture listener without forwarding the capture listener invocations
+     * to another capture listener.
+     */
+    public BlockingCaptureCallback() {
+        mProxy = null;
+    }
+
+    /**
+     * Create a blocking capture listener; forward original listener invocations
+     * into {@code listener}.
+     *
+     * @param listener a non-{@code null} listener to forward invocations into
+     *
+     * @throws NullPointerException if {@code listener} was {@code null}
+     */
+    public BlockingCaptureCallback(CameraCaptureSession.CaptureCallback listener) {
+        if (listener == null) {
+            throw new NullPointerException("listener must not be null");
+        }
+        mProxy = listener;
+    }
+
+    /**
+     * Acquire the state waiter; can be used to block until a set of state transitions have
+     * been reached.
+     *
+     * <p>Only one thread should wait at a time.</p>
+     */
+    public StateWaiter getStateWaiter() {
+        return mStateWaiter;
+    }
+
+    @Override
+    public void onCaptureStarted(CameraCaptureSession session, CaptureRequest request,
+                                 long timestamp, long frameNumber) {
+        if (mProxy != null) mProxy.onCaptureStarted(session, request, timestamp, frameNumber);
+        mStateChangeListener.onStateChanged(CAPTURE_STARTED);
+    }
+
+    @Override
+    public void onCaptureProgressed(CameraCaptureSession session, CaptureRequest request,
+                                    CaptureResult partialResult) {
+        if (mProxy != null) mProxy.onCaptureProgressed(session, request, partialResult);
+        mStateChangeListener.onStateChanged(CAPTURE_PROGRESSED);
+    }
+
+    @Override
+    public void onCaptureCompleted(CameraCaptureSession session, CaptureRequest request,
+                                   TotalCaptureResult result) {
+        if (mProxy != null) mProxy.onCaptureCompleted(session, request, result);
+        mStateChangeListener.onStateChanged(CAPTURE_COMPLETED);
+    }
+
+    @Override
+    public void onCaptureFailed(CameraCaptureSession session, CaptureRequest request,
+                                CaptureFailure failure) {
+        if (mProxy != null) mProxy.onCaptureFailed(session, request, failure);
+        mStateChangeListener.onStateChanged(CAPTURE_FAILED);
+    }
+
+    @Override
+    public void onCaptureSequenceCompleted(CameraCaptureSession session, int sequenceId,
+                                           long frameNumber) {
+        if (mProxy != null) mProxy.onCaptureSequenceCompleted(session, sequenceId, frameNumber);
+        mStateChangeListener.onStateChanged(CAPTURE_SEQUENCE_COMPLETED);
+    }
+
+    @Override
+    public void onCaptureSequenceAborted(CameraCaptureSession session, int sequenceId) {
+        if (mProxy != null) mProxy.onCaptureSequenceAborted(session, sequenceId);
+        mStateChangeListener.onStateChanged(CAPTURE_SEQUENCE_ABORTED);
+    }
+}