Index: media/audio/pulse/pulse_output.cc |
diff --git a/media/audio/pulse/pulse_output.cc b/media/audio/pulse/pulse_output.cc |
index df4b5be979c6937b949f0c9dc8822236b92c6c6a..98f1f58391cd3faf615da999affe4d29a56876c8 100644 |
--- a/media/audio/pulse/pulse_output.cc |
+++ b/media/audio/pulse/pulse_output.cc |
@@ -128,7 +128,7 @@ void PulseAudioOutputStream::WriteRequestCallback(pa_stream* playback_handle, |
PulseAudioOutputStream* stream = |
reinterpret_cast<PulseAudioOutputStream*>(stream_addr); |
- DCHECK_EQ(stream->manager_->GetMessageLoop(), MessageLoop::current()); |
+ DCHECK(stream->manager_->GetMessageLoop()->BelongsToCurrentThread()); |
stream->write_callback_handled_ = true; |
@@ -138,16 +138,16 @@ void PulseAudioOutputStream::WriteRequestCallback(pa_stream* playback_handle, |
PulseAudioOutputStream::PulseAudioOutputStream(const AudioParameters& params, |
AudioManagerPulse* manager) |
- : channel_layout_(params.channel_layout), |
+ : channel_layout_(params.channel_layout()), |
channel_count_(ChannelLayoutToChannelCount(channel_layout_)), |
- sample_format_(BitsToPASampleFormat(params.bits_per_sample)), |
- sample_rate_(params.sample_rate), |
- bytes_per_frame_(params.channels * params.bits_per_sample / 8), |
+ sample_format_(BitsToPASampleFormat(params.bits_per_sample())), |
+ sample_rate_(params.sample_rate()), |
+ bytes_per_frame_(params.GetBytesPerFrame()), |
manager_(manager), |
pa_context_(NULL), |
pa_mainloop_(NULL), |
playback_handle_(NULL), |
- packet_size_(params.GetPacketSize()), |
+ packet_size_(params.GetBytesPerBuffer()), |
frames_per_packet_(packet_size_ / bytes_per_frame_), |
client_buffer_(NULL), |
volume_(1.0f), |
@@ -155,7 +155,7 @@ PulseAudioOutputStream::PulseAudioOutputStream(const AudioParameters& params, |
write_callback_handled_(false), |
ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)), |
source_callback_(NULL) { |
- DCHECK_EQ(manager_->GetMessageLoop(), MessageLoop::current()); |
+ DCHECK(manager_->GetMessageLoop()->BelongsToCurrentThread()); |
// TODO(slock): Sanity check input values. |
} |
@@ -169,7 +169,7 @@ PulseAudioOutputStream::~PulseAudioOutputStream() { |
} |
bool PulseAudioOutputStream::Open() { |
- DCHECK_EQ(manager_->GetMessageLoop(), MessageLoop::current()); |
+ DCHECK(manager_->GetMessageLoop()->BelongsToCurrentThread()); |
// TODO(slock): Possibly move most of this to an OpenPlaybackDevice function |
// in a new class 'pulse_util', like alsa_util. |
@@ -272,7 +272,7 @@ void PulseAudioOutputStream::Reset() { |
} |
void PulseAudioOutputStream::Close() { |
- DCHECK_EQ(manager_->GetMessageLoop(), MessageLoop::current()); |
+ DCHECK(manager_->GetMessageLoop()->BelongsToCurrentThread()); |
Reset(); |
@@ -282,7 +282,7 @@ void PulseAudioOutputStream::Close() { |
} |
void PulseAudioOutputStream::WaitForWriteRequest() { |
- DCHECK_EQ(manager_->GetMessageLoop(), MessageLoop::current()); |
+ DCHECK(manager_->GetMessageLoop()->BelongsToCurrentThread()); |
if (stream_stopped_) |
return; |
@@ -337,8 +337,8 @@ void PulseAudioOutputStream::FulfillWriteRequest(size_t requested_bytes) { |
// Request more data from the source until we can fulfill the request or |
// fail to receive anymore data. |
bool buffering_successful = true; |
- while (client_buffer_->forward_bytes() < requested_bytes && |
- buffering_successful) { |
+ size_t forward_bytes = static_cast<size_t>(client_buffer_->forward_bytes()); |
+ while (forward_bytes < requested_bytes && buffering_successful) { |
buffering_successful = BufferPacketFromSource(); |
} |
@@ -369,7 +369,7 @@ void PulseAudioOutputStream::WriteToStream(size_t bytes_to_write, |
*bytes_written = 0; |
while (*bytes_written < bytes_to_write) { |
const uint8* chunk; |
- size_t chunk_size; |
+ int chunk_size; |
// Stop writing if there is no more data available. |
if (!client_buffer_->GetCurrentChunk(&chunk, &chunk_size)) |
@@ -384,7 +384,7 @@ void PulseAudioOutputStream::WriteToStream(size_t bytes_to_write, |
} |
void PulseAudioOutputStream::Start(AudioSourceCallback* callback) { |
- DCHECK_EQ(manager_->GetMessageLoop(), MessageLoop::current()); |
+ DCHECK(manager_->GetMessageLoop()->BelongsToCurrentThread()); |
CHECK(callback); |
DLOG_IF(ERROR, !playback_handle_) |
<< "Open() has not been called successfully"; |
@@ -404,19 +404,19 @@ void PulseAudioOutputStream::Start(AudioSourceCallback* callback) { |
} |
void PulseAudioOutputStream::Stop() { |
- DCHECK_EQ(manager_->GetMessageLoop(), MessageLoop::current()); |
+ DCHECK(manager_->GetMessageLoop()->BelongsToCurrentThread()); |
stream_stopped_ = true; |
} |
void PulseAudioOutputStream::SetVolume(double volume) { |
- DCHECK_EQ(manager_->GetMessageLoop(), MessageLoop::current()); |
+ DCHECK(manager_->GetMessageLoop()->BelongsToCurrentThread()); |
volume_ = static_cast<float>(volume); |
} |
void PulseAudioOutputStream::GetVolume(double* volume) { |
- DCHECK_EQ(manager_->GetMessageLoop(), MessageLoop::current()); |
+ DCHECK(manager_->GetMessageLoop()->BelongsToCurrentThread()); |
*volume = volume_; |
} |