| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright 2004 The WebRTC Project Authors. All rights reserved. | 2 * Copyright 2004 The WebRTC Project Authors. All rights reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| (...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 63 | 63 |
| 64 void AddInternal(MessageQueue *message_queue); | 64 void AddInternal(MessageQueue *message_queue); |
| 65 void RemoveInternal(MessageQueue *message_queue); | 65 void RemoveInternal(MessageQueue *message_queue); |
| 66 void ClearInternal(MessageHandler *handler); | 66 void ClearInternal(MessageHandler *handler); |
| 67 void ProcessAllMessageQueuesInternal(); | 67 void ProcessAllMessageQueuesInternal(); |
| 68 | 68 |
| 69 static MessageQueueManager* instance_; | 69 static MessageQueueManager* instance_; |
| 70 // This list contains all live MessageQueues. | 70 // This list contains all live MessageQueues. |
| 71 std::vector<MessageQueue*> message_queues_ GUARDED_BY(crit_); | 71 std::vector<MessageQueue*> message_queues_ GUARDED_BY(crit_); |
| 72 | 72 |
| 73 // Acquire this with DebugNonReentrantCritScope. | 73 // Methods that don't modify the list of message queues may be called in a |
| 74 // re-entrant fashion. "processing_" keeps track of the depth of re-entrant |
| 75 // calls. |
| 74 CriticalSection crit_; | 76 CriticalSection crit_; |
| 75 bool locked_ GUARDED_BY(crit_); | 77 size_t processing_ GUARDED_BY(crit_); |
| 76 }; | 78 }; |
| 77 | 79 |
| 78 // Derive from this for specialized data | 80 // Derive from this for specialized data |
| 79 // App manages lifetime, except when messages are purged | 81 // App manages lifetime, except when messages are purged |
| 80 | 82 |
| 81 class MessageData { | 83 class MessageData { |
| 82 public: | 84 public: |
| 83 MessageData() {} | 85 MessageData() {} |
| 84 virtual ~MessageData() {} | 86 virtual ~MessageData() {} |
| 85 }; | 87 }; |
| (...skipping 265 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 351 SocketServer* const ss_; | 353 SocketServer* const ss_; |
| 352 // Used if SocketServer ownership lies with |this|. | 354 // Used if SocketServer ownership lies with |this|. |
| 353 std::unique_ptr<SocketServer> own_ss_; | 355 std::unique_ptr<SocketServer> own_ss_; |
| 354 | 356 |
| 355 RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(MessageQueue); | 357 RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(MessageQueue); |
| 356 }; | 358 }; |
| 357 | 359 |
| 358 } // namespace rtc | 360 } // namespace rtc |
| 359 | 361 |
| 360 #endif // WEBRTC_RTC_BASE_MESSAGEQUEUE_H_ | 362 #endif // WEBRTC_RTC_BASE_MESSAGEQUEUE_H_ |
| OLD | NEW |