| Index: content/renderer/media/media_stream_impl.cc
|
| diff --git a/content/renderer/media/media_stream_impl.cc b/content/renderer/media/media_stream_impl.cc
|
| index d576a68edc4a9248a610ed2162f530d0efef0d73..8bb9fd540ba4fc45dd189fa617717c0961c62cfc 100644
|
| --- a/content/renderer/media/media_stream_impl.cc
|
| +++ b/content/renderer/media/media_stream_impl.cc
|
| @@ -6,7 +6,9 @@
|
|
|
| #include <utility>
|
|
|
| +#include "base/hash.h"
|
| #include "base/logging.h"
|
| +#include "base/strings/string_number_conversions.h"
|
| #include "base/strings/string_util.h"
|
| #include "base/strings/stringprintf.h"
|
| #include "base/strings/utf_string_conversions.h"
|
| @@ -57,20 +59,26 @@ static int g_next_request_id = 0;
|
| struct MediaStreamImpl::MediaDevicesRequestInfo {
|
| MediaDevicesRequestInfo(const blink::WebMediaDevicesRequest& request,
|
| int audio_input_request_id,
|
| - int video_input_request_id)
|
| + int video_input_request_id,
|
| + int audio_output_request_id)
|
| : request(request),
|
| audio_input_request_id(audio_input_request_id),
|
| video_input_request_id(video_input_request_id),
|
| + audio_output_request_id(audio_output_request_id),
|
| has_audio_input_returned(false),
|
| - has_video_input_returned(false) {}
|
| + has_video_input_returned(false),
|
| + has_audio_output_returned(false) {}
|
|
|
| blink::WebMediaDevicesRequest request;
|
| int audio_input_request_id;
|
| int video_input_request_id;
|
| + int audio_output_request_id;
|
| bool has_audio_input_returned;
|
| bool has_video_input_returned;
|
| + bool has_audio_output_returned;
|
| StreamDeviceInfoArray audio_input_devices;
|
| StreamDeviceInfoArray video_input_devices;
|
| + StreamDeviceInfoArray audio_output_devices;
|
| };
|
|
|
| MediaStreamImpl::MediaStreamImpl(
|
| @@ -197,6 +205,7 @@ void MediaStreamImpl::requestMediaDevices(
|
|
|
| int audio_input_request_id = g_next_request_id++;
|
| int video_input_request_id = g_next_request_id++;
|
| + int audio_output_request_id = g_next_request_id++;
|
|
|
| // |media_devices_request| can't be mocked, so in tests it will be empty (the
|
| // underlying pointer is null). In order to use this function in a test we
|
| @@ -206,11 +215,14 @@ void MediaStreamImpl::requestMediaDevices(
|
| security_origin = GURL(media_devices_request.securityOrigin().toString());
|
|
|
| DVLOG(1) << "MediaStreamImpl::requestMediaDevices(" << audio_input_request_id
|
| - << ", " << video_input_request_id << ", "
|
| - << security_origin.spec() << ")";
|
| + << ", " << video_input_request_id << ", " << audio_output_request_id
|
| + << ", " << security_origin.spec() << ")";
|
|
|
| media_devices_requests_.push_back(new MediaDevicesRequestInfo(
|
| - media_devices_request, audio_input_request_id, video_input_request_id));
|
| + media_devices_request,
|
| + audio_input_request_id,
|
| + video_input_request_id,
|
| + audio_output_request_id));
|
|
|
| media_stream_dispatcher_->EnumerateDevices(
|
| audio_input_request_id,
|
| @@ -223,6 +235,12 @@ void MediaStreamImpl::requestMediaDevices(
|
| AsWeakPtr(),
|
| MEDIA_DEVICE_VIDEO_CAPTURE,
|
| security_origin);
|
| +
|
| + media_stream_dispatcher_->EnumerateDevices(
|
| + audio_output_request_id,
|
| + AsWeakPtr(),
|
| + MEDIA_DEVICE_AUDIO_OUTPUT,
|
| + security_origin);
|
| }
|
|
|
| void MediaStreamImpl::cancelMediaDevicesRequest(
|
| @@ -240,6 +258,9 @@ void MediaStreamImpl::cancelMediaDevicesRequest(
|
| media_stream_dispatcher_->StopEnumerateDevices(
|
| request->video_input_request_id,
|
| AsWeakPtr());
|
| + media_stream_dispatcher_->StopEnumerateDevices(
|
| + request->audio_output_request_id,
|
| + AsWeakPtr());
|
| DeleteMediaDevicesRequestInfo(request);
|
| }
|
|
|
| @@ -500,42 +521,65 @@ void MediaStreamImpl::OnDevicesEnumerated(
|
| request->has_audio_input_returned = true;
|
| DCHECK(request->audio_input_devices.empty());
|
| request->audio_input_devices = device_array;
|
| - } else {
|
| - DCHECK(request_id == request->video_input_request_id);
|
| + } else if (request_id == request->video_input_request_id) {
|
| request->has_video_input_returned = true;
|
| DCHECK(request->video_input_devices.empty());
|
| request->video_input_devices = device_array;
|
| + } else {
|
| + DCHECK_EQ(request->audio_output_request_id, request_id);
|
| + request->has_audio_output_returned = true;
|
| + DCHECK(request->audio_output_devices.empty());
|
| + request->audio_output_devices = device_array;
|
| }
|
|
|
| if (!request->has_audio_input_returned ||
|
| - !request->has_video_input_returned) {
|
| + !request->has_video_input_returned ||
|
| + !request->has_audio_output_returned) {
|
| // Wait for the rest of the devices to complete.
|
| return;
|
| }
|
|
|
| - // Both audio and video devices are ready for copying.
|
| - // TODO(grunell): Add support for output devices and group id.
|
| + // All devices are ready for copying. We use a hashed audio output device id
|
| + // as the group id for input and output audio devices. If an input device
|
| + // doesn't have an associated output device, we use the input device's own id.
|
| + // We don't support group id for video devices, that's left empty.
|
| blink::WebVector<blink::WebMediaDeviceInfo>
|
| devices(request->audio_input_devices.size() +
|
| - request->video_input_devices.size());
|
| + request->video_input_devices.size() +
|
| + request->audio_output_devices.size());
|
| for (size_t i = 0; i < request->audio_input_devices.size(); ++i) {
|
| const MediaStreamDevice& device = request->audio_input_devices[i].device;
|
| DCHECK_EQ(device.type, MEDIA_DEVICE_AUDIO_CAPTURE);
|
| - devices[i].initialize(blink::WebString::fromUTF8(device.id),
|
| - blink::WebMediaDeviceInfo::MediaDeviceKindAudioInput,
|
| - blink::WebString::fromUTF8(device.name),
|
| - blink::WebString());
|
| + std::string group_id = base::UintToString(base::Hash(
|
| + !device.matched_output_device_id.empty() ?
|
| + device.matched_output_device_id :
|
| + device.id));
|
| + devices[i].initialize(
|
| + blink::WebString::fromUTF8(device.id),
|
| + blink::WebMediaDeviceInfo::MediaDeviceKindAudioInput,
|
| + blink::WebString::fromUTF8(device.name),
|
| + blink::WebString::fromUTF8(group_id));
|
| }
|
| - size_t audio_size = request->audio_input_devices.size();
|
| + size_t offset = request->audio_input_devices.size();
|
| for (size_t i = 0; i < request->video_input_devices.size(); ++i) {
|
| const MediaStreamDevice& device = request->video_input_devices[i].device;
|
| DCHECK_EQ(device.type, MEDIA_DEVICE_VIDEO_CAPTURE);
|
| - devices[audio_size + i].initialize(
|
| + devices[offset + i].initialize(
|
| blink::WebString::fromUTF8(device.id),
|
| blink::WebMediaDeviceInfo::MediaDeviceKindVideoInput,
|
| blink::WebString::fromUTF8(device.name),
|
| blink::WebString());
|
| }
|
| + offset += request->video_input_devices.size();
|
| + for (size_t i = 0; i < request->audio_output_devices.size(); ++i) {
|
| + const MediaStreamDevice& device = request->audio_output_devices[i].device;
|
| + DCHECK_EQ(device.type, MEDIA_DEVICE_AUDIO_OUTPUT);
|
| + devices[offset + i].initialize(
|
| + blink::WebString::fromUTF8(device.id),
|
| + blink::WebMediaDeviceInfo::MediaDeviceKindAudioOutput,
|
| + blink::WebString::fromUTF8(device.name),
|
| + blink::WebString::fromUTF8(base::UintToString(base::Hash(device.id))));
|
| + }
|
|
|
| EnumerateDevicesSucceded(&request->request, devices);
|
|
|
| @@ -546,6 +590,9 @@ void MediaStreamImpl::OnDevicesEnumerated(
|
| media_stream_dispatcher_->StopEnumerateDevices(
|
| request->video_input_request_id,
|
| AsWeakPtr());
|
| + media_stream_dispatcher_->StopEnumerateDevices(
|
| + request->audio_output_request_id,
|
| + AsWeakPtr());
|
|
|
| DeleteMediaDevicesRequestInfo(request);
|
| }
|
| @@ -673,7 +720,8 @@ MediaStreamImpl::FindMediaDevicesRequestInfo(
|
| MediaDevicesRequests::iterator it = media_devices_requests_.begin();
|
| for (; it != media_devices_requests_.end(); ++it) {
|
| if ((*it)->audio_input_request_id == request_id ||
|
| - (*it)->video_input_request_id == request_id) {
|
| + (*it)->video_input_request_id == request_id ||
|
| + (*it)->audio_output_request_id == request_id) {
|
| return (*it);
|
| }
|
| }
|
|
|