Handle unexpected MojoWait() result in MojoAudioDecoderService

media/mojo/services/mojo_audio_decoder_service.cc

 // 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/mojo/services/mojo_audio_decoder_service.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/logging.h"
 #include "media/base/cdm_context.h"
@@ skipping 135 matching lines @@
 scoped_refptr<DecoderBuffer> MojoAudioDecoderService::ReadDecoderBuffer(
     mojom::DecoderBufferPtr buffer) {
   scoped_refptr<DecoderBuffer> media_buffer(
       buffer.To<scoped_refptr<DecoderBuffer>>());
 
   if (media_buffer->end_of_stream())
     return media_buffer;
 
   // Wait for the data to become available in the DataPipe.
   MojoHandleSignalsState state;
-  CHECK_EQ(MOJO_RESULT_OK,
-           MojoWait(consumer_handle_.get().value(), MOJO_HANDLE_SIGNAL_READABLE,
-                    MOJO_DEADLINE_INDEFINITE, &state));
+  MojoResult result =
+      MojoWait(consumer_handle_.get().value(), MOJO_HANDLE_SIGNAL_READABLE,
+               MOJO_DEADLINE_INDEFINITE, &state);
 
-  if (state.satisfied_signals & MOJO_HANDLE_SIGNAL_PEER_CLOSED) {
+  if (result != MOJO_RESULT_OK) {
     DVLOG(1) << __FUNCTION__ << ": Peer closed the data pipe";
-    return scoped_refptr<DecoderBuffer>();
+    return nullptr;
   }
 
-  CHECK_EQ(MOJO_HANDLE_SIGNAL_READABLE,
-           state.satisfied_signals & MOJO_HANDLE_SIGNAL_READABLE);
+  // Read the inner data for the DecoderBuffer from our DataPipe.
+  uint32_t data_size = static_cast<uint32_t>(media_buffer->data_size());
+  DCHECK_EQ(data_size, buffer->data_size);
+  DCHECK_GT(data_size, 0u);
 
-  // Read the inner data for the DecoderBuffer from our DataPipe.
-  uint32_t bytes_to_read =
-      base::checked_cast<uint32_t>(media_buffer->data_size());
-  DCHECK_GT(bytes_to_read, 0u);
-  uint32_t bytes_read = bytes_to_read;
-  CHECK_EQ(ReadDataRaw(consumer_handle_.get(), media_buffer->writable_data(),
-                       &bytes_read, MOJO_READ_DATA_FLAG_ALL_OR_NONE),
-           MOJO_RESULT_OK);
-  CHECK_EQ(bytes_to_read, bytes_read);
+  uint32_t bytes_read = data_size;
+  result = ReadDataRaw(consumer_handle_.get(), media_buffer->writable_data(),
+                       &bytes_read, MOJO_READ_DATA_FLAG_ALL_OR_NONE);
+  if (result != MOJO_RESULT_OK || bytes_read != data_size) {
+    DVLOG(1) << __FUNCTION__ << ": reading from pipe failed";
+    return nullptr;
+  }
 
   return media_buffer;
 }
 
 }  // namespace media