| OLD | NEW |
| (Empty) |
| 1 /* | |
| 2 * Copyright (C) 2013 Google Inc. All rights reserved. | |
| 3 * | |
| 4 * Redistribution and use in source and binary forms, with or without | |
| 5 * modification, are permitted provided that the following conditions | |
| 6 * are met: | |
| 7 * 1. Redistributions of source code must retain the above copyright | |
| 8 * notice, this list of conditions and the following disclaimer. | |
| 9 * 2. Redistributions in binary form must reproduce the above copyright | |
| 10 * notice, this list of conditions and the following disclaimer in the | |
| 11 * documentation and/or other materials provided with the distribution. | |
| 12 * | |
| 13 * THIS SOFTWARE IS PROVIDED BY GOOGLE INC. ``AS IS'' AND ANY | |
| 14 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | |
| 15 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR | |
| 16 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GOOGLE INC. OR | |
| 17 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, | |
| 18 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, | |
| 19 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR | |
| 20 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY | |
| 21 * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | |
| 22 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | |
| 23 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | |
| 24 */ | |
| 25 | |
| 26 #include "modules/mediastream/RTCDTMFSender.h" | |
| 27 | |
| 28 #include "bindings/core/v8/ExceptionMessages.h" | |
| 29 #include "bindings/core/v8/ExceptionState.h" | |
| 30 #include "core/dom/ExceptionCode.h" | |
| 31 #include "core/dom/ExecutionContext.h" | |
| 32 #include "modules/mediastream/MediaStreamTrack.h" | |
| 33 #include "modules/mediastream/RTCDTMFToneChangeEvent.h" | |
| 34 #include "public/platform/WebMediaStreamTrack.h" | |
| 35 #include "public/platform/WebRTCDTMFSenderHandler.h" | |
| 36 #include "public/platform/WebRTCPeerConnectionHandler.h" | |
| 37 #include "wtf/PtrUtil.h" | |
| 38 #include <memory> | |
| 39 | |
| 40 namespace blink { | |
| 41 | |
| 42 static const int minToneDurationMs = 70; | |
| 43 static const int defaultToneDurationMs = 100; | |
| 44 static const int maxToneDurationMs = 6000; | |
| 45 static const int minInterToneGapMs = 50; | |
| 46 static const int defaultInterToneGapMs = 50; | |
| 47 | |
| 48 RTCDTMFSender* RTCDTMFSender::create(ExecutionContext* context, WebRTCPeerConnec
tionHandler* peerConnectionHandler, MediaStreamTrack* track, ExceptionState& exc
eptionState) | |
| 49 { | |
| 50 std::unique_ptr<WebRTCDTMFSenderHandler> handler = wrapUnique(peerConnection
Handler->createDTMFSender(track->component())); | |
| 51 if (!handler) { | |
| 52 exceptionState.throwDOMException(NotSupportedError, "The MediaStreamTrac
k provided is not an element of a MediaStream that's currently in the local stre
ams set."); | |
| 53 return nullptr; | |
| 54 } | |
| 55 | |
| 56 RTCDTMFSender* dtmfSender = new RTCDTMFSender(context, track, std::move(hand
ler)); | |
| 57 dtmfSender->suspendIfNeeded(); | |
| 58 return dtmfSender; | |
| 59 } | |
| 60 | |
| 61 RTCDTMFSender::RTCDTMFSender(ExecutionContext* context, MediaStreamTrack* track,
std::unique_ptr<WebRTCDTMFSenderHandler> handler) | |
| 62 : ActiveDOMObject(context) | |
| 63 , m_track(track) | |
| 64 , m_duration(defaultToneDurationMs) | |
| 65 , m_interToneGap(defaultInterToneGapMs) | |
| 66 , m_handler(std::move(handler)) | |
| 67 , m_stopped(false) | |
| 68 , m_scheduledEventTimer(this, &RTCDTMFSender::scheduledEventTimerFired) | |
| 69 { | |
| 70 ThreadState::current()->registerPreFinalizer(this); | |
| 71 m_handler->setClient(this); | |
| 72 } | |
| 73 | |
| 74 RTCDTMFSender::~RTCDTMFSender() | |
| 75 { | |
| 76 } | |
| 77 | |
| 78 void RTCDTMFSender::dispose() | |
| 79 { | |
| 80 // Promptly clears a raw reference from content/ to an on-heap object | |
| 81 // so that content/ doesn't access it in a lazy sweeping phase. | |
| 82 m_handler->setClient(nullptr); | |
| 83 m_handler.reset(); | |
| 84 } | |
| 85 | |
| 86 bool RTCDTMFSender::canInsertDTMF() const | |
| 87 { | |
| 88 return m_handler->canInsertDTMF(); | |
| 89 } | |
| 90 | |
| 91 MediaStreamTrack* RTCDTMFSender::track() const | |
| 92 { | |
| 93 return m_track.get(); | |
| 94 } | |
| 95 | |
| 96 String RTCDTMFSender::toneBuffer() const | |
| 97 { | |
| 98 return m_handler->currentToneBuffer(); | |
| 99 } | |
| 100 | |
| 101 void RTCDTMFSender::insertDTMF(const String& tones, ExceptionState& exceptionSta
te) | |
| 102 { | |
| 103 insertDTMF(tones, defaultToneDurationMs, defaultInterToneGapMs, exceptionSta
te); | |
| 104 } | |
| 105 | |
| 106 void RTCDTMFSender::insertDTMF(const String& tones, int duration, ExceptionState
& exceptionState) | |
| 107 { | |
| 108 insertDTMF(tones, duration, defaultInterToneGapMs, exceptionState); | |
| 109 } | |
| 110 | |
| 111 void RTCDTMFSender::insertDTMF(const String& tones, int duration, int interToneG
ap, ExceptionState& exceptionState) | |
| 112 { | |
| 113 if (!canInsertDTMF()) { | |
| 114 exceptionState.throwDOMException(NotSupportedError, "The 'canInsertDTMF'
attribute is false: this sender cannot send DTMF."); | |
| 115 return; | |
| 116 } | |
| 117 | |
| 118 if (duration > maxToneDurationMs || duration < minToneDurationMs) { | |
| 119 exceptionState.throwDOMException(SyntaxError, ExceptionMessages::indexOu
tsideRange("duration", duration, minToneDurationMs, ExceptionMessages::Exclusive
Bound, maxToneDurationMs, ExceptionMessages::ExclusiveBound)); | |
| 120 return; | |
| 121 } | |
| 122 | |
| 123 if (interToneGap < minInterToneGapMs) { | |
| 124 exceptionState.throwDOMException(SyntaxError, ExceptionMessages::indexEx
ceedsMinimumBound("intertone gap", interToneGap, minInterToneGapMs)); | |
| 125 return; | |
| 126 } | |
| 127 | |
| 128 m_duration = duration; | |
| 129 m_interToneGap = interToneGap; | |
| 130 | |
| 131 if (!m_handler->insertDTMF(tones, m_duration, m_interToneGap)) | |
| 132 exceptionState.throwDOMException(SyntaxError, "Could not send provided t
ones, '" + tones + "'."); | |
| 133 } | |
| 134 | |
| 135 void RTCDTMFSender::didPlayTone(const WebString& tone) | |
| 136 { | |
| 137 scheduleDispatchEvent(RTCDTMFToneChangeEvent::create(tone)); | |
| 138 } | |
| 139 | |
| 140 const AtomicString& RTCDTMFSender::interfaceName() const | |
| 141 { | |
| 142 return EventTargetNames::RTCDTMFSender; | |
| 143 } | |
| 144 | |
| 145 ExecutionContext* RTCDTMFSender::getExecutionContext() const | |
| 146 { | |
| 147 return ActiveDOMObject::getExecutionContext(); | |
| 148 } | |
| 149 | |
| 150 void RTCDTMFSender::stop() | |
| 151 { | |
| 152 m_stopped = true; | |
| 153 m_handler->setClient(nullptr); | |
| 154 } | |
| 155 | |
| 156 void RTCDTMFSender::scheduleDispatchEvent(Event* event) | |
| 157 { | |
| 158 m_scheduledEvents.append(event); | |
| 159 | |
| 160 if (!m_scheduledEventTimer.isActive()) | |
| 161 m_scheduledEventTimer.startOneShot(0, BLINK_FROM_HERE); | |
| 162 } | |
| 163 | |
| 164 void RTCDTMFSender::scheduledEventTimerFired(Timer<RTCDTMFSender>*) | |
| 165 { | |
| 166 if (m_stopped) | |
| 167 return; | |
| 168 | |
| 169 HeapVector<Member<Event>> events; | |
| 170 events.swap(m_scheduledEvents); | |
| 171 | |
| 172 HeapVector<Member<Event>>::iterator it = events.begin(); | |
| 173 for (; it != events.end(); ++it) | |
| 174 dispatchEvent((*it).release()); | |
| 175 } | |
| 176 | |
| 177 DEFINE_TRACE(RTCDTMFSender) | |
| 178 { | |
| 179 visitor->trace(m_track); | |
| 180 visitor->trace(m_scheduledEvents); | |
| 181 EventTargetWithInlineData::trace(visitor); | |
| 182 ActiveDOMObject::trace(visitor); | |
| 183 } | |
| 184 | |
| 185 } // namespace blink | |
| OLD | NEW |