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

Unified Diff: content/renderer/media/audio_input_message_filter.cc

Issue 1142063003: content/child: Remove use of MessageLoopProxy and deprecated MessageLoop APIs (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Build fix. Created 5 years, 7 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 | « content/renderer/media/audio_input_message_filter.h ('k') | content/renderer/media/audio_message_filter.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: content/renderer/media/audio_input_message_filter.cc
diff --git a/content/renderer/media/audio_input_message_filter.cc b/content/renderer/media/audio_input_message_filter.cc
index 6c2906f3678727124904f8f4e6206a5b34bee53f..286c89ea967ca51243c58dde0a246a3d410e7d7b 100644
--- a/content/renderer/media/audio_input_message_filter.cc
+++ b/content/renderer/media/audio_input_message_filter.cc
@@ -5,7 +5,7 @@
#include "content/renderer/media/audio_input_message_filter.h"
#include "base/bind.h"
-#include "base/message_loop/message_loop_proxy.h"
+#include "base/single_thread_task_runner.h"
#include "base/strings/stringprintf.h"
#include "content/common/media/audio_messages.h"
#include "content/renderer/media/webrtc_logging.h"
@@ -53,9 +53,8 @@ class AudioInputMessageFilter::AudioInputIPCImpl
AudioInputMessageFilter* AudioInputMessageFilter::g_filter = NULL;
AudioInputMessageFilter::AudioInputMessageFilter(
- const scoped_refptr<base::MessageLoopProxy>& io_message_loop)
- : sender_(NULL),
- io_message_loop_(io_message_loop) {
+ scoped_refptr<base::SingleThreadTaskRunner> io_task_runner)
+ : sender_(NULL), io_task_runner_(io_task_runner) {
DCHECK(!g_filter);
g_filter = this;
}
@@ -71,7 +70,7 @@ AudioInputMessageFilter* AudioInputMessageFilter::Get() {
}
void AudioInputMessageFilter::Send(IPC::Message* message) {
- DCHECK(io_message_loop_->BelongsToCurrentThread());
+ DCHECK(io_task_runner_->BelongsToCurrentThread());
if (!sender_) {
delete message;
} else {
@@ -80,7 +79,7 @@ void AudioInputMessageFilter::Send(IPC::Message* message) {
}
bool AudioInputMessageFilter::OnMessageReceived(const IPC::Message& message) {
- DCHECK(io_message_loop_->BelongsToCurrentThread());
+ DCHECK(io_task_runner_->BelongsToCurrentThread());
bool handled = true;
IPC_BEGIN_MESSAGE_MAP(AudioInputMessageFilter, message)
IPC_MESSAGE_HANDLER(AudioInputMsg_NotifyStreamCreated,
@@ -94,14 +93,14 @@ bool AudioInputMessageFilter::OnMessageReceived(const IPC::Message& message) {
}
void AudioInputMessageFilter::OnFilterAdded(IPC::Sender* sender) {
- DCHECK(io_message_loop_->BelongsToCurrentThread());
+ DCHECK(io_task_runner_->BelongsToCurrentThread());
// Captures the sender for IPC.
sender_ = sender;
}
void AudioInputMessageFilter::OnFilterRemoved() {
- DCHECK(io_message_loop_->BelongsToCurrentThread());
+ DCHECK(io_task_runner_->BelongsToCurrentThread());
// Once removed, a filter will not be used again. At this time all
// delegates must be notified so they release their reference.
@@ -109,7 +108,7 @@ void AudioInputMessageFilter::OnFilterRemoved() {
}
void AudioInputMessageFilter::OnChannelClosing() {
- DCHECK(io_message_loop_->BelongsToCurrentThread());
+ DCHECK(io_task_runner_->BelongsToCurrentThread());
sender_ = NULL;
DLOG_IF(WARNING, !delegates_.IsEmpty())
@@ -129,7 +128,7 @@ void AudioInputMessageFilter::OnStreamCreated(
base::SyncSocket::TransitDescriptor socket_descriptor,
uint32 length,
uint32 total_segments) {
- DCHECK(io_message_loop_->BelongsToCurrentThread());
+ DCHECK(io_task_runner_->BelongsToCurrentThread());
LogMessage(stream_id, "OnStreamCreated");
base::SyncSocket::Handle socket_handle =
@@ -147,7 +146,7 @@ void AudioInputMessageFilter::OnStreamCreated(
}
void AudioInputMessageFilter::OnStreamVolume(int stream_id, double volume) {
- DCHECK(io_message_loop_->BelongsToCurrentThread());
+ DCHECK(io_task_runner_->BelongsToCurrentThread());
media::AudioInputIPCDelegate* delegate = delegates_.Lookup(stream_id);
if (!delegate) {
DLOG(WARNING) << "Got audio stream event for a non-existent or removed"
@@ -159,7 +158,7 @@ void AudioInputMessageFilter::OnStreamVolume(int stream_id, double volume) {
void AudioInputMessageFilter::OnStreamStateChanged(
int stream_id, media::AudioInputIPCDelegate::State state) {
- DCHECK(io_message_loop_->BelongsToCurrentThread());
+ DCHECK(io_task_runner_->BelongsToCurrentThread());
media::AudioInputIPCDelegate* delegate = delegates_.Lookup(stream_id);
if (!delegate) {
DLOG(WARNING) << "Got audio stream event for a non-existent or removed"
@@ -192,7 +191,7 @@ void AudioInputMessageFilter::AudioInputIPCImpl::CreateStream(
const media::AudioParameters& params,
bool automatic_gain_control,
uint32 total_segments) {
- DCHECK(filter_->io_message_loop_->BelongsToCurrentThread());
+ DCHECK(filter_->io_task_runner_->BelongsToCurrentThread());
DCHECK(delegate);
stream_id_ = filter_->delegates_.Add(delegate);
@@ -220,7 +219,7 @@ void AudioInputMessageFilter::AudioInputIPCImpl::SetVolume(double volume) {
}
void AudioInputMessageFilter::AudioInputIPCImpl::CloseStream() {
- DCHECK(filter_->io_message_loop_->BelongsToCurrentThread());
+ DCHECK(filter_->io_task_runner_->BelongsToCurrentThread());
DCHECK_NE(stream_id_, kStreamIDNotSet);
LogMessage(stream_id_, "CloseStream");
filter_->Send(new AudioInputHostMsg_CloseStream(stream_id_));
« no previous file with comments | « content/renderer/media/audio_input_message_filter.h ('k') | content/renderer/media/audio_message_filter.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698