Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(260)

Unified Diff: media/capture/service/stream_impl.cc

Issue 1699553002: Mojo Video Capture service in media/capture (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: perkj@s and magjed@s comments Created 4 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « media/capture/service/stream_impl.h ('k') | media/capture/service/stream_impl_unittest.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: media/capture/service/stream_impl.cc
diff --git a/media/capture/service/stream_impl.cc b/media/capture/service/stream_impl.cc
new file mode 100644
index 0000000000000000000000000000000000000000..5d185a652673b2eef490b5cb4dd7ee272d0da3ba
--- /dev/null
+++ b/media/capture/service/stream_impl.cc
@@ -0,0 +1,114 @@
+// Copyright 2016 The Chromium 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 "media/capture/service/stream_impl.h"
+
+#include "base/bind.h"
+#include "base/callback.h"
+#include "base/thread_task_runner_handle.h"
+#include "base/time/time.h"
+#include "media/base/bind_to_current_loop.h"
+#include "media/capture/interfaces/video_capture.mojom.h"
+#include "media/capture/service/mojo_video_frame.h"
+#include "mojo/converters/geometry/geometry_type_converters.h"
+
+namespace media {
+
+StreamImpl::StreamImpl(
+ mojo::InterfaceRequest<mojom::VideoCaptureStream> request,
+ const base::Closure& start_callback,
+ const base::Closure& close_callback,
+ const base::Closure& error_callback)
+ : binding_(this, std::move(request)),
+ start_callback_(start_callback),
+ close_callback_(close_callback),
+ error_callback_(error_callback),
+ task_runner_(base::ThreadTaskRunnerHandle::Get()),
+ weak_factory_(this) {
+ binding_.set_connection_error_handler(error_callback_);
+}
+
+StreamImpl::~StreamImpl() {
+ DCHECK(task_runner_->BelongsToCurrentThread());
+}
+
+void StreamImpl::Start(mojom::VideoCaptureStreamClientPtr client) {
+ DCHECK(task_runner_->BelongsToCurrentThread());
+ DCHECK(!client_) << "Start() should not be called several times.";
+ client_ = std::move(client);
+ client_.set_connection_error_handler(error_callback_);
+ start_callback_.Run();
+}
+
+void StreamImpl::Stop() {
+ DCHECK(task_runner_->BelongsToCurrentThread());
+ DCHECK(client_);
+ close_callback_.Run();
+}
+
+void StreamImpl::OnFrame(const scoped_refptr<MojoVideoFrame>& frame,
+ const base::TimeTicks& timestamp) {
+ task_runner_->PostTask(
+ FROM_HERE, base::Bind(&StreamImpl::NotifyOnFrameAvailable,
+ weak_factory_.GetWeakPtr(), frame, timestamp));
+}
+
+void StreamImpl::OnError(const std::string& reason) {
+ DLOG(ERROR) << __FUNCTION__ << " " << reason;
+ task_runner_->PostTask(
+ FROM_HERE,
+ base::Bind(&StreamImpl::NotifyError, weak_factory_.GetWeakPtr(), reason));
+}
+
+void StreamImpl::NotifyOnFrameAvailable(
+ const scoped_refptr<MojoVideoFrame>& frame,
+ const base::TimeTicks& timestamp) {
+ DCHECK(task_runner_->BelongsToCurrentThread());
+ DCHECK(client_);
+
+ const int32_t buffer_id = running_buffer_id_++;
+
+ mojom::FrameInfoPtr frame_info = mojom::FrameInfo::New();
+
+ // We duplicate the handle immediately to avoid passing around the primordial
+ // handle. While it's OK for someone to continue using the buffer after the
+ // pool drops ownership, it's not OK to dupe the primordial handle once it's
+ // been invalidated.
+ mojo::ScopedSharedBufferHandle handle;
+ MojoResult rv = mojo::DuplicateBuffer(frame->handle(), nullptr, &handle);
+ DLOG_IF(ERROR, rv != MOJO_RESULT_OK) << "Error duplicating handle";
+ if (rv != MOJO_RESULT_OK)
+ return;
+ frame_info->storage_handle = std::move(handle);
+ frame_info->storage_size = frame->mapped_size();
+
+ frame_info->pixel_format =
+ static_cast<media::interfaces::VideoFormat>(frame->format());
+ frame_info->coded_size = mojo::Size::From(frame->coded_size());
+ frame_info->visible_rect = mojo::Rect::From(frame->visible_rect());
+ frame_info->timestamp = timestamp.ToInternalValue();
+
+ in_use_video_frames_.emplace(buffer_id, frame);
mcasas 2016/03/04 22:00:27 Some builders still fail with "../../media/captu
+ client_->OnFrameAvailable(std::move(frame_info),
+ base::Bind(&StreamImpl::OnFrameConsumed,
+ weak_factory_.GetWeakPtr(), buffer_id));
+}
+
+void StreamImpl::NotifyError(const mojo::String& error) {
+ DCHECK(task_runner_->BelongsToCurrentThread());
+ // A device may notify of error(s) before Start() registers a |client_|.
+ if (client_)
+ client_->OnError(error);
+ error_callback_.Run();
+}
+
+void StreamImpl::OnFrameConsumed(int32_t buffer_id) {
+ DCHECK(task_runner_->BelongsToCurrentThread());
+ const auto video_frame = in_use_video_frames_.find(buffer_id);
+ DCHECK(video_frame != in_use_video_frames_.end()) << "Buffer id " << buffer_id
+ << " not found!";
+ in_use_video_frames_.erase(video_frame);
+}
+
+} // namespace media
« no previous file with comments | « media/capture/service/stream_impl.h ('k') | media/capture/service/stream_impl_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698