OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 #ifndef IPC_IPC_SYNC_CHANNEL_H_ | 5 #ifndef IPC_IPC_SYNC_CHANNEL_H_ |
6 #define IPC_IPC_SYNC_CHANNEL_H_ | 6 #define IPC_IPC_SYNC_CHANNEL_H_ |
7 | 7 |
8 #include <deque> | 8 #include <deque> |
9 #include <memory> | 9 #include <memory> |
10 #include <string> | 10 #include <string> |
(...skipping 171 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
182 private: | 182 private: |
183 ~SyncContext() override; | 183 ~SyncContext() override; |
184 // ChannelProxy methods that we override. | 184 // ChannelProxy methods that we override. |
185 | 185 |
186 // Called on the listener thread. | 186 // Called on the listener thread. |
187 void Clear() override; | 187 void Clear() override; |
188 | 188 |
189 // Called on the IPC thread. | 189 // Called on the IPC thread. |
190 bool OnMessageReceived(const Message& msg) override; | 190 bool OnMessageReceived(const Message& msg) override; |
191 void OnChannelError() override; | 191 void OnChannelError() override; |
192 void OnChannelOpened(bool pause) override; | 192 void OnChannelOpened() override; |
193 void OnChannelClosed() override; | 193 void OnChannelClosed() override; |
194 | 194 |
195 // Cancels all pending Send calls. | 195 // Cancels all pending Send calls. |
196 void CancelPendingSends(); | 196 void CancelPendingSends(); |
197 | 197 |
198 void OnShutdownEventSignaled(base::WaitableEvent* event); | 198 void OnShutdownEventSignaled(base::WaitableEvent* event); |
199 | 199 |
200 typedef std::deque<PendingSyncMsg> PendingSyncMessageQueue; | 200 typedef std::deque<PendingSyncMsg> PendingSyncMessageQueue; |
201 PendingSyncMessageQueue deserializers_; | 201 PendingSyncMessageQueue deserializers_; |
202 bool reject_new_deserializers_ = false; | 202 bool reject_new_deserializers_ = false; |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
245 | 245 |
246 // Tracks SyncMessageFilters created before complete channel initialization. | 246 // Tracks SyncMessageFilters created before complete channel initialization. |
247 std::vector<scoped_refptr<SyncMessageFilter>> pre_init_sync_message_filters_; | 247 std::vector<scoped_refptr<SyncMessageFilter>> pre_init_sync_message_filters_; |
248 | 248 |
249 DISALLOW_COPY_AND_ASSIGN(SyncChannel); | 249 DISALLOW_COPY_AND_ASSIGN(SyncChannel); |
250 }; | 250 }; |
251 | 251 |
252 } // namespace IPC | 252 } // namespace IPC |
253 | 253 |
254 #endif // IPC_IPC_SYNC_CHANNEL_H_ | 254 #endif // IPC_IPC_SYNC_CHANNEL_H_ |
OLD | NEW |