| Index: media/audio/async_socket_io_handler.h
|
| diff --git a/media/audio/async_socket_io_handler.h b/media/audio/async_socket_io_handler.h
|
| deleted file mode 100644
|
| index cc7185eb243d093c65a1e6a02bcbf69ab77e00aa..0000000000000000000000000000000000000000
|
| --- a/media/audio/async_socket_io_handler.h
|
| +++ /dev/null
|
| @@ -1,113 +0,0 @@
|
| -// Copyright (c) 2012 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.
|
| -
|
| -#ifndef MEDIA_AUDIO_ASYNC_SOCKET_IO_HANDLER_H_
|
| -#define MEDIA_AUDIO_ASYNC_SOCKET_IO_HANDLER_H_
|
| -
|
| -#include "base/message_loop/message_loop.h"
|
| -#include "base/sync_socket.h"
|
| -#include "base/threading/non_thread_safe.h"
|
| -#include "media/base/media_export.h"
|
| -
|
| -namespace media {
|
| -
|
| -// The message loop callback interface is different based on platforms.
|
| -#if defined(OS_WIN)
|
| -typedef base::MessageLoopForIO::IOHandler MessageLoopIOHandler;
|
| -#elif defined(OS_POSIX)
|
| -typedef base::MessageLoopForIO::Watcher MessageLoopIOHandler;
|
| -#endif
|
| -
|
| -// Extends the CancelableSyncSocket class to allow reading from a socket
|
| -// asynchronously on a TYPE_IO message loop thread. This makes it easy to share
|
| -// a thread that uses a message loop (e.g. for IPC and other things) and not
|
| -// require a separate thread to read from the socket.
|
| -//
|
| -// Example usage (also see the unit tests):
|
| -//
|
| -// class SocketReader {
|
| -// public:
|
| -// SocketReader(base::CancelableSyncSocket* socket)
|
| -// : socket_(socket), buffer_() {
|
| -// io_handler.Initialize(socket_->handle(),
|
| -// base::Bind(&SocketReader::OnDataAvailable,
|
| -// base::Unretained(this));
|
| -// }
|
| -//
|
| -// void AsyncRead() {
|
| -// CHECK(io_handler.Read(&buffer_[0], sizeof(buffer_)));
|
| -// }
|
| -//
|
| -// private:
|
| -// void OnDataAvailable(int bytes_read) {
|
| -// if (ProcessData(&buffer_[0], bytes_read)) {
|
| -// // Issue another read.
|
| -// CHECK(io_handler.Read(&buffer_[0], sizeof(buffer_)));
|
| -// }
|
| -// }
|
| -//
|
| -// media::AsyncSocketIoHandler io_handler;
|
| -// base::CancelableSyncSocket* socket_;
|
| -// char buffer_[kBufferSize];
|
| -// };
|
| -//
|
| -class MEDIA_EXPORT AsyncSocketIoHandler
|
| - : public NON_EXPORTED_BASE(base::NonThreadSafe),
|
| - public NON_EXPORTED_BASE(MessageLoopIOHandler) {
|
| - public:
|
| - AsyncSocketIoHandler();
|
| - virtual ~AsyncSocketIoHandler();
|
| -
|
| - // Type definition for the callback. The parameter tells how many
|
| - // bytes were read and is 0 if an error occurred.
|
| - typedef base::Callback<void(int)> ReadCompleteCallback;
|
| -
|
| - // Initializes the AsyncSocketIoHandler by hooking it up to the current
|
| - // thread's message loop (must be TYPE_IO), to do async reads from the socket
|
| - // on the current thread. The |callback| will be invoked whenever a Read()
|
| - // has completed.
|
| - bool Initialize(base::SyncSocket::Handle socket,
|
| - const ReadCompleteCallback& callback);
|
| -
|
| - // Attempts to read from the socket. The return value will be |false|
|
| - // if an error occurred and |true| if data was read or a pending read
|
| - // was issued. Regardless of async or sync operation, the
|
| - // ReadCompleteCallback (see above) will be called when data is available.
|
| - bool Read(char* buffer, int buffer_len);
|
| -
|
| - private:
|
| -#if defined(OS_WIN)
|
| - // Implementation of IOHandler on Windows.
|
| - virtual void OnIOCompleted(base::MessageLoopForIO::IOContext* context,
|
| - DWORD bytes_transfered,
|
| - DWORD error) OVERRIDE;
|
| -#elif defined(OS_POSIX)
|
| - // Implementation of base::MessageLoopForIO::Watcher.
|
| - virtual void OnFileCanWriteWithoutBlocking(int socket) OVERRIDE {}
|
| - virtual void OnFileCanReadWithoutBlocking(int socket) OVERRIDE;
|
| -
|
| - void EnsureWatchingSocket();
|
| -#endif
|
| -
|
| - base::SyncSocket::Handle socket_;
|
| -#if defined(OS_WIN)
|
| - base::MessageLoopForIO::IOContext* context_;
|
| - bool is_pending_;
|
| -#elif defined(OS_POSIX)
|
| - base::MessageLoopForIO::FileDescriptorWatcher socket_watcher_;
|
| - // |pending_buffer_| and |pending_buffer_len_| are valid only between
|
| - // Read() and OnFileCanReadWithoutBlocking().
|
| - char* pending_buffer_;
|
| - int pending_buffer_len_;
|
| - // |true| iff the message loop is watching the socket for IO events.
|
| - bool is_watching_;
|
| -#endif
|
| - ReadCompleteCallback read_complete_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(AsyncSocketIoHandler);
|
| -};
|
| -
|
| -} // namespace media.
|
| -
|
| -#endif // MEDIA_AUDIO_ASYNC_SOCKET_IO_HANDLER_H_
|
|
|