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

// 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.

#include "stream_impl.h"

#include <ddktl/protocol/isp.h>
#include <fbl/auto_lock.h>
#include <src/lib/fxl/logging.h>

namespace camera {

zx_status_t StreamImpl::Create(zx::channel channel, async_dispatcher_t* dispatcher,
                               std::unique_ptr<StreamImpl>* stream_out) {
  auto stream = std::make_unique<StreamImpl>();
  zx_status_t status = stream->binding_.Bind(
      fidl::InterfaceRequest<fuchsia::camera::common::Stream>(std::move(channel)), dispatcher);
  if (status != ZX_OK) {
    FXL_PLOG(ERROR, status) << "Failed to bind stream";
    return status;
  }

  stream->binding_.set_error_handler(
      [](zx_status_t status) { FXL_PLOG(ERROR, status) << "Client disconnected"; });

  *stream_out = std::move(stream);
  return ZX_OK;
}

void StreamImpl::FrameAvailable(uint32_t id) {
  if (!streaming_) {
    return;
  }
  fuchsia::camera::common::FrameAvailableEvent event{};
  event.frame_status = fuchsia::camera::common::FrameStatus::OK;
  event.buffer_id = id;
  binding_.events().OnFrameAvailable(event);
  outstanding_buffers_.insert(id);
}

void StreamImpl::Start() {
  if (streaming_) {
    FXL_LOG(ERROR) << "It is invalid to call Start on a stream that is already streaming.";
    binding_.Close(ZX_ERR_INVALID_ARGS);
    return;
  }
  streaming_ = true;
}

void StreamImpl::Stop() {
  if (!streaming_) {
    FXL_LOG(ERROR) << "It is invalid to call Stop on a stream that is stopped.";
    binding_.Close(ZX_ERR_INVALID_ARGS);
    return;
  }
  streaming_ = false;
}

void StreamImpl::ReleaseFrame(uint32_t buffer_id) {
  auto it = outstanding_buffers_.find(buffer_id);
  if (it == outstanding_buffers_.end()) {
    FXL_LOG(ERROR) << "Client attempted to release buffer " << buffer_id
                   << " but it was not previously held.";
    binding_.Close(ZX_ERR_INVALID_ARGS);
    return;
  }
  outstanding_buffers_.erase(it);
}

}  // namespace camera