Replace Timers used in ActiveDOMObject with AsyncMethodRunner

Source/modules/mediastream/RTCPeerConnection.cpp

 /*
  * Copyright (C) 2012 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  *
  * 1. Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
  * 2. Redistributions in binary form must reproduce the above copyright
@@ skipping 119 matching lines @@
         return 0;
 
     return peerConnection.release();
 }
 
 RTCPeerConnection::RTCPeerConnection(ExecutionContext* context, PassRefPtr<RTCConfiguration> configuration, PassRefPtr<MediaConstraints> constraints, ExceptionState& es)
     : ActiveDOMObject(context)
     , m_signalingState(SignalingStateStable)
     , m_iceGatheringState(IceGatheringStateNew)
     , m_iceConnectionState(IceConnectionStateNew)
-    , m_scheduledEventTimer(this, &RTCPeerConnection::scheduledEventTimerFired)
+    , m_dispatchScheduledEventRunner(this, &RTCPeerConnection::dispatchScheduledEvent)
     , m_stopped(false)
 {
     ScriptWrappable::init(this);
     Document* document = toDocument(executionContext());
 
     if (!document->frame()) {
         es.throwUninformativeAndGenericDOMException(NotSupportedError);
         return;
     }
 
@@ skipping 466 matching lines @@
 const AtomicString& RTCPeerConnection::interfaceName() const
 {
     return EventTargetNames::RTCPeerConnection;
 }
 
 ExecutionContext* RTCPeerConnection::executionContext() const
 {
     return ActiveDOMObject::executionContext();
 }
 
+void RTCPeerConnection::suspend()
+{
+    m_dispatchScheduledEventRunner.suspend();
+}
+
+void RTCPeerConnection::resume()
+{
+    m_dispatchScheduledEventRunner.resume();
+}
+
 void RTCPeerConnection::stop()
 {
     if (m_stopped)
         return;
 
     m_stopped = true;
     m_iceConnectionState = IceConnectionStateClosed;
     m_signalingState = SignalingStateClosed;
 
     Vector<RefPtr<RTCDataChannel> >::iterator i = m_dataChannels.begin();
     for (; i != m_dataChannels.end(); ++i)
         (*i)->stop();
+
+    m_dispatchScheduledEventRunner.stop();
 }
 
 void RTCPeerConnection::changeSignalingState(SignalingState signalingState)
 {
     if (m_signalingState != SignalingStateClosed && m_signalingState != signalingState) {
         m_signalingState = signalingState;
         scheduleDispatchEvent(Event::create(EventTypeNames::signalingstatechange));
     }
 }
 
 void RTCPeerConnection::changeIceGatheringState(IceGatheringState iceGatheringState)
 {
     m_iceGatheringState = iceGatheringState;
 }
 
 void RTCPeerConnection::changeIceConnectionState(IceConnectionState iceConnectionState)
 {
     if (m_iceConnectionState != IceConnectionStateClosed && m_iceConnectionState != iceConnectionState) {
         m_iceConnectionState = iceConnectionState;
         scheduleDispatchEvent(Event::create(EventTypeNames::iceconnectionstatechange));
     }
 }
 
 void RTCPeerConnection::scheduleDispatchEvent(PassRefPtr<Event> event)
 {
     m_scheduledEvents.append(event);
 
-    if (!m_scheduledEventTimer.isActive())
-        m_scheduledEventTimer.startOneShot(0);
+    m_dispatchScheduledEventRunner.runAsync();
 }
 
-void RTCPeerConnection::scheduledEventTimerFired(Timer<RTCPeerConnection>*)
+void RTCPeerConnection::dispatchScheduledEvent()
 {
     if (m_stopped)
         return;
 
     Vector<RefPtr<Event> > events;
     events.swap(m_scheduledEvents);
 
     Vector<RefPtr<Event> >::iterator it = events.begin();
     for (; it != events.end(); ++it)
         dispatchEvent((*it).release());
 
     events.clear();
 }
 
 } // namespace WebCore