Motown: ffmpeg implementations of framework 'parts'

services/media/framework_ffmpeg/ffmpeg_io.cc

Index: services/media/framework_ffmpeg/ffmpeg_io.cc
diff --git a/services/media/framework_ffmpeg/ffmpeg_io.cc b/services/media/framework_ffmpeg/ffmpeg_io.cc
new file mode 100644
index 0000000000000000000000000000000000000000..c15c614d8511bc8cecf7a2d2fd67ee2b62535990
--- /dev/null
+++ b/services/media/framework_ffmpeg/ffmpeg_io.cc
@@ -0,0 +1,99 @@
+// 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 "base/logging.h"
+#include "services/media/framework/parts/reader.h"
+#include "services/media/framework_ffmpeg/ffmpeg_init.h"
+#include "services/media/framework_ffmpeg/ffmpeg_io.h"
+extern "C" {
+#include "third_party/ffmpeg/libavformat/avio.h"
+}
+
+namespace mojo {
+namespace media {
+
+static int AvioRead(void* opaque, uint8_t* buf, int buf_size);
+static int64_t AvioSeek(void* opaque, int64_t offset, int whence);
+
+AvioContextPtr CreateAvioContext(Reader* reader) {
+  // Internal buffer size used by AVIO for reading.
+  const int kBufferSize = 32 * 1024;
+
+  InitFfmpeg();
+
+  AVIOContext* result = avio_alloc_context(
+      static_cast<unsigned char*>(av_malloc(kBufferSize)),
+      kBufferSize,
+      0, // write_flag
+      reader, // opaque
+      &AvioRead,
+      nullptr,
+      &AvioSeek);
+
+  // Ensure FFmpeg only tries to seek when we know how.
+  result->seekable = reader->CanSeek() ? AVIO_SEEKABLE_NORMAL : 0;
+
+  // Ensure writing is disabled.
+  result->write_flag = 0;
+
+  return AvioContextPtr(result);
+}
+
+// Performs a read operation using the signature required for avio.
+static int AvioRead(void* opaque, uint8_t* buf, int buf_size) {
+  Reader* reader = reinterpret_cast<Reader*>(opaque);
+  int result = reader->Read(buf, buf_size);
+  if (result < 0) {
+    result = AVERROR(EIO);
+  }
+  return result;
+}
+
+// Performs a seek operation using the signature required for avio.
+static int64_t AvioSeek(void* opaque, int64_t offset, int whence) {
+  Reader* reader = reinterpret_cast<Reader*>(opaque);
+
+  if (whence == AVSEEK_SIZE) {
+    int64_t result = reader->GetSize();
+    if (result == -1) {
+      return AVERROR(EIO);
+    }
+    return result;
+  }
+
+  int64_t base;
+  switch (whence) {
+    case SEEK_SET:
+      base = 0;
+      break;
+
+    case SEEK_CUR:
+      base = reader->GetPosition();
+      if (base == -1) {
+        return AVERROR(EIO);
+      }
+      break;
+
+    case SEEK_END:
+      base = reader->GetSize();
+      if (base == -1) {
+        return AVERROR(EIO);
+      }
+      break;
+
+    default:
+      NOTREACHED();
+      return AVERROR(EIO);
+  }
+
+  int64_t result = reader->SetPosition(base + offset);
+  if (result == -1) {
+    return AVERROR(EIO);
+  }
+
+  return result;
+}
+
+} // namespace media
+} // namespace mojo