src/camera/drivers/isp/mali-009/stream_impl.h

// Copyright 2019 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#ifndef SRC_CAMERA_DRIVERS_ISP_MALI_009_STREAM_IMPL_H_
#define SRC_CAMERA_DRIVERS_ISP_MALI_009_STREAM_IMPL_H_

#include <fuchsia/camera2/cpp/fidl.h>
#include <fuchsia/sysmem/c/fidl.h>
#include <lib/async-loop/cpp/loop.h>
#include <lib/fidl/cpp/binding.h>
#include <zircon/types.h>

#include <unordered_set>

namespace camera {

class StreamImpl : public fuchsia::camera2::Stream {
 public:
  StreamImpl() : binding_(this){};
  static zx_status_t Create(zx::channel channel, async_dispatcher_t* dispatcher,
                            std::unique_ptr<StreamImpl>* stream_out);

  void FrameAvailable(uint32_t id);

  bool IsBound() { return binding_.is_bound(); }

  const std::unordered_set<uint32_t>& GetOutstandingBuffers() { return outstanding_buffers_; }

  // |fuchsia::camera2::Stream|
  virtual void Start() override;
  virtual void Stop() override;
  virtual void ReleaseFrame(uint32_t buffer_id) override;
  void AcknowledgeFrameError() override { binding_.Close(ZX_ERR_UNAVAILABLE); }
  void SetRegionOfInterest(float x_min, float y_min, float x_max, float y_max,
                           SetRegionOfInterestCallback callback) override {
    binding_.Close(ZX_ERR_UNAVAILABLE);
  }
  void SetImageFormat(uint32_t image_format_index, SetImageFormatCallback callback) override {
    binding_.Close(ZX_ERR_UNAVAILABLE);
  }
  void GetImageFormats(GetImageFormatsCallback callback) override {
    binding_.Close(ZX_ERR_UNAVAILABLE);
  }

 private:
  fidl::Binding<fuchsia::camera2::Stream> binding_;
  std::unordered_set<uint32_t> outstanding_buffers_;
  bool streaming_ = false;
};

}  // namespace camera

#endif  // SRC_CAMERA_DRIVERS_ISP_MALI_009_STREAM_IMPL_H_