| Index: trunk/src/content/child/threaded_data_provider.h
|
| ===================================================================
|
| --- trunk/src/content/child/threaded_data_provider.h (revision 276493)
|
| +++ trunk/src/content/child/threaded_data_provider.h (working copy)
|
| @@ -1,83 +0,0 @@
|
| -// Copyright 2014 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 CONTENT_CHILD_THREADEDDATAPROVIDER_IMPL_H_
|
| -#define CONTENT_CHILD_THREADEDDATAPROVIDER_IMPL_H_
|
| -
|
| -#include "base/compiler_specific.h"
|
| -#include "base/memory/linked_ptr.h"
|
| -#include "base/memory/ref_counted.h"
|
| -#include "base/memory/scoped_ptr.h"
|
| -#include "base/memory/shared_memory.h"
|
| -#include "base/memory/weak_ptr.h"
|
| -#include "ipc/ipc_channel.h"
|
| -#include "ipc/message_filter.h"
|
| -
|
| -namespace blink {
|
| -class WebThreadedDataReceiver;
|
| -}
|
| -
|
| -namespace IPC {
|
| -class SyncChannel;
|
| -}
|
| -
|
| -namespace webkit_glue {
|
| -class WebThreadImpl;
|
| -}
|
| -
|
| -namespace content {
|
| -class ResourceDispatcher;
|
| -class WebThreadImpl;
|
| -
|
| -class ThreadedDataProvider {
|
| - public:
|
| - ThreadedDataProvider(
|
| - int request_id,
|
| - blink::WebThreadedDataReceiver* threaded_data_receiver,
|
| - linked_ptr<base::SharedMemory> shm_buffer,
|
| - int shm_size);
|
| - virtual ~ThreadedDataProvider();
|
| -
|
| - void Stop();
|
| - void OnReceivedDataOnBackgroundThread(int data_offset,
|
| - int data_length,
|
| - int encoded_data_length);
|
| -
|
| - void OnReceivedDataOnForegroundThread(const char* data,
|
| - int data_length,
|
| - int encoded_data_length);
|
| -
|
| - void OnResourceMessageFilterAddedMainThread();
|
| -
|
| - private:
|
| - void StopOnBackgroundThread();
|
| - void OnResourceMessageFilterAddedBackgroundThread();
|
| - void ForwardAndACKData(const char* data, int data_length);
|
| -
|
| - scoped_refptr<IPC::MessageFilter> filter_;
|
| - int request_id_;
|
| - linked_ptr<base::SharedMemory> shm_buffer_;
|
| - int shm_size_;
|
| - scoped_ptr<base::WeakPtrFactory<ThreadedDataProvider> >
|
| - background_thread_weak_factory_;
|
| - base::WeakPtrFactory<ThreadedDataProvider>
|
| - main_thread_weak_factory_;
|
| - WebThreadImpl& background_thread_;
|
| - IPC::SyncChannel* ipc_channel_;
|
| - blink::WebThreadedDataReceiver* threaded_data_receiver_;
|
| - bool resource_filter_active_;
|
| - base::MessageLoop* main_thread_message_loop_;
|
| -
|
| - struct QueuedSharedMemoryData {
|
| - const char* data;
|
| - int length;
|
| - };
|
| - std::vector<QueuedSharedMemoryData> queued_data_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(ThreadedDataProvider);
|
| -};
|
| -
|
| -} // namespace content
|
| -
|
| -#endif // CONTENT_CHILD_THREADEDDATAPROVIDER_IMPL_H_
|
|
|