OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "ppapi/proxy/ppb_flash_file_proxy.h" | 5 #include "ppapi/proxy/ppb_flash_file_proxy.h" |
6 | 6 |
7 #include <map> | 7 #include <map> |
8 #include <set> | 8 #include <set> |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
(...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
96 // These will be sent ASAP. | 96 // These will be sent ASAP. |
97 std::vector<IPC::Message*> pre_connect_pending_messages_; | 97 std::vector<IPC::Message*> pre_connect_pending_messages_; |
98 | 98 |
99 // Holds the IDs of the sync messages we're currently waiting on for this | 99 // Holds the IDs of the sync messages we're currently waiting on for this |
100 // channel. This tracking allows us to cancel those requests if the | 100 // channel. This tracking allows us to cancel those requests if the |
101 // remote process crashes and we're cleaning up this filter (without just | 101 // remote process crashes and we're cleaning up this filter (without just |
102 // deadlocking the waiting thread(s). | 102 // deadlocking the waiting thread(s). |
103 std::set<int> pending_requests_for_filter_; | 103 std::set<int> pending_requests_for_filter_; |
104 }; | 104 }; |
105 | 105 |
106 virtual void SendFromIOThread(Dispatcher* dispatcher, IPC::Message* msg); | 106 void SendFromIOThread(Dispatcher* dispatcher, IPC::Message* msg); |
107 | 107 |
108 // Internal version of OnModuleLocalMessageFailed which assumes the lock | 108 // Internal version of OnModuleLocalMessageFailed which assumes the lock |
109 // is already held. | 109 // is already held. |
110 void OnModuleLocalMessageFailedLocked(int message_id); | 110 void OnModuleLocalMessageFailedLocked(int message_id); |
111 | 111 |
112 base::Lock lock_; | 112 base::Lock lock_; |
113 | 113 |
114 scoped_refptr<base::MessageLoopProxy> main_thread_; | 114 scoped_refptr<base::MessageLoopProxy> main_thread_; |
115 | 115 |
116 // Will be NULL before an instance routing is added. | 116 // Will be NULL before an instance routing is added. |
(...skipping 606 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
723 void PPB_Flash_File_FileRef_Proxy::OnMsgQueryFile( | 723 void PPB_Flash_File_FileRef_Proxy::OnMsgQueryFile( |
724 const HostResource& host_resource, | 724 const HostResource& host_resource, |
725 PP_FileInfo_Dev* info, | 725 PP_FileInfo_Dev* info, |
726 int32_t* result) { | 726 int32_t* result) { |
727 *result = ppb_flash_file_module_local_target()-> | 727 *result = ppb_flash_file_module_local_target()-> |
728 QueryFile(host_resource.host_resource(), info); | 728 QueryFile(host_resource.host_resource(), info); |
729 } | 729 } |
730 | 730 |
731 } // namespace proxy | 731 } // namespace proxy |
732 } // namespace pp | 732 } // namespace pp |
OLD | NEW |