1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
// Copyright (c) 2012 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 "content/renderer/media/rtc_video_capturer.h"
#include "base/bind.h"
RtcVideoCapturer::RtcVideoCapturer(
const media::VideoCaptureSessionId id,
VideoCaptureImplManager* vc_manager,
bool is_screencast)
: is_screencast_(is_screencast),
delegate_(new RtcVideoCaptureDelegate(id, vc_manager)),
state_(video_capture::kStopped) {
}
RtcVideoCapturer::~RtcVideoCapturer() {
DCHECK(video_capture::kStopped);
DVLOG(3) << " RtcVideoCapturer::dtor";
}
cricket::CaptureState RtcVideoCapturer::Start(
const cricket::VideoFormat& capture_format) {
DVLOG(3) << " RtcVideoCapturer::Start ";
if (state_ == video_capture::kStarted) {
DVLOG(1) << "Got a StartCapture when already started!!! ";
return cricket::CS_FAILED;
}
media::VideoCaptureCapability cap;
cap.width = capture_format.width;
cap.height = capture_format.height;
cap.frame_rate = capture_format.framerate();
cap.color = media::VideoCaptureCapability::kI420;
state_ = video_capture::kStarted;
start_time_ = base::Time::Now();
delegate_->StartCapture(cap,
base::Bind(&RtcVideoCapturer::OnFrameCaptured, base::Unretained(this)),
base::Bind(&RtcVideoCapturer::OnStateChange, base::Unretained(this)));
return cricket::CS_STARTING;
}
void RtcVideoCapturer::Stop() {
DVLOG(3) << " RtcVideoCapturer::Stop ";
if (state_ == video_capture::kStopped) {
DVLOG(1) << "Got a StopCapture while not started.";
return;
}
state_ = video_capture::kStopped;
delegate_->StopCapture();
SignalStateChange(this, cricket::CS_STOPPED);
}
bool RtcVideoCapturer::IsRunning() {
return state_ == video_capture::kStarted;
}
bool RtcVideoCapturer::GetPreferredFourccs(std::vector<uint32>* fourccs) {
if (!fourccs)
return false;
fourccs->push_back(cricket::FOURCC_I420);
return true;
}
bool RtcVideoCapturer::IsScreencast() {
return is_screencast_;
}
bool RtcVideoCapturer::GetBestCaptureFormat(const cricket::VideoFormat& desired,
cricket::VideoFormat* best_format) {
if (!best_format) {
return false;
}
// Chrome does not support capability enumeration.
// Use the desired format as the best format.
best_format->width = desired.width;
best_format->height = desired.height;
best_format->fourcc = cricket::FOURCC_I420;
best_format->interval = desired.interval;
return true;
}
void RtcVideoCapturer::OnFrameCaptured(
const media::VideoCapture::VideoFrameBuffer& buf) {
// Currently, |fourcc| is always I420.
cricket::CapturedFrame frame;
frame.width = buf.width;
frame.height = buf.height;
frame.fourcc = cricket::FOURCC_I420;
frame.data_size = buf.buffer_size;
// cricket::CapturedFrame time is in nanoseconds.
frame.elapsed_time = (buf.timestamp - start_time_).InMicroseconds() *
base::Time::kNanosecondsPerMicrosecond;
frame.time_stamp = frame.elapsed_time;
frame.data = buf.memory_pointer;
frame.pixel_height = 1;
frame.pixel_width = 1;
// This signals to libJingle that a new VideoFrame is available.
// libJingle have no assumptions on what thread this signal come from.
SignalFrameCaptured(this, &frame);
}
void RtcVideoCapturer::OnStateChange(
RtcVideoCaptureDelegate::CaptureState state) {
cricket::CaptureState converted_state = cricket::CS_FAILED;
switch (state) {
case RtcVideoCaptureDelegate::CAPTURE_STOPPED:
converted_state = cricket::CS_STOPPED;
break;
case RtcVideoCaptureDelegate::CAPTURE_RUNNING:
converted_state = cricket::CS_RUNNING;
break;
case RtcVideoCaptureDelegate::CAPTURE_FAILED:
converted_state = cricket::CS_FAILED;
break;
default:
NOTREACHED();
break;
}
SignalStateChange(this, converted_state);
}
|
