| /* |
| * 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 |
| * notice, this list of conditions and the following disclaimer |
| * in the documentation and/or other materials provided with the |
| * distribution. |
| * 3. Neither the name of Google Inc. nor the names of its contributors |
| * may be used to endorse or promote products derived from this |
| * software without specific prior written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
| * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
| * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
| * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
| * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
| * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
| * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
| * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| */ |
| |
| #ifndef RTCPeerConnection_h |
| #define RTCPeerConnection_h |
| |
| #include "bindings/core/v8/Dictionary.h" |
| #include "core/dom/ActiveDOMObject.h" |
| #include "modules/EventTargetModules.h" |
| #include "modules/mediastream/MediaStream.h" |
| #include "modules/mediastream/RTCIceCandidate.h" |
| #include "platform/AsyncMethodRunner.h" |
| #include "public/platform/WebMediaConstraints.h" |
| #include "public/platform/WebRTCPeerConnectionHandler.h" |
| #include "public/platform/WebRTCPeerConnectionHandlerClient.h" |
| |
| namespace blink { |
| |
| class ExceptionState; |
| class MediaStreamTrack; |
| class RTCConfiguration; |
| class RTCDTMFSender; |
| class RTCDataChannel; |
| class RTCErrorCallback; |
| class RTCOfferOptions; |
| class RTCSessionDescription; |
| class RTCSessionDescriptionCallback; |
| class RTCStatsCallback; |
| class VoidCallback; |
| |
| class RTCPeerConnection FINAL |
| : public RefCountedGarbageCollectedWillBeGarbageCollectedFinalized<RTCPeerConnection> |
| , public WebRTCPeerConnectionHandlerClient |
| , public EventTargetWithInlineData |
| , public ActiveDOMObject { |
| DEFINE_EVENT_TARGET_REFCOUNTING_WILL_BE_REMOVED(RefCountedGarbageCollectedWillBeGarbageCollectedFinalized<RTCPeerConnection>); |
| WILL_BE_USING_GARBAGE_COLLECTED_MIXIN(RTCPeerConnection); |
| public: |
| static RTCPeerConnection* create(ExecutionContext*, const Dictionary&, const Dictionary&, ExceptionState&); |
| virtual ~RTCPeerConnection(); |
| |
| void createOffer(PassOwnPtr<RTCSessionDescriptionCallback>, PassOwnPtr<RTCErrorCallback>, const Dictionary&, ExceptionState&); |
| |
| void createAnswer(PassOwnPtr<RTCSessionDescriptionCallback>, PassOwnPtr<RTCErrorCallback>, const Dictionary&, ExceptionState&); |
| |
| void setLocalDescription(RTCSessionDescription*, PassOwnPtr<VoidCallback>, PassOwnPtr<RTCErrorCallback>, ExceptionState&); |
| RTCSessionDescription* localDescription(ExceptionState&); |
| |
| void setRemoteDescription(RTCSessionDescription*, PassOwnPtr<VoidCallback>, PassOwnPtr<RTCErrorCallback>, ExceptionState&); |
| RTCSessionDescription* remoteDescription(ExceptionState&); |
| |
| String signalingState() const; |
| |
| void updateIce(const Dictionary& rtcConfiguration, const Dictionary& mediaConstraints, ExceptionState&); |
| |
| // DEPRECATED |
| void addIceCandidate(RTCIceCandidate*, ExceptionState&); |
| |
| void addIceCandidate(RTCIceCandidate*, PassOwnPtr<VoidCallback>, PassOwnPtr<RTCErrorCallback>, ExceptionState&); |
| |
| String iceGatheringState() const; |
| |
| String iceConnectionState() const; |
| |
| MediaStreamVector getLocalStreams() const; |
| |
| MediaStreamVector getRemoteStreams() const; |
| |
| MediaStream* getStreamById(const String& streamId); |
| |
| void addStream(MediaStream*, const Dictionary& mediaConstraints, ExceptionState&); |
| |
| void removeStream(MediaStream*, ExceptionState&); |
| |
| void getStats(PassOwnPtr<RTCStatsCallback> successCallback, MediaStreamTrack* selector); |
| |
| RTCDataChannel* createDataChannel(String label, const Dictionary& dataChannelDict, ExceptionState&); |
| |
| RTCDTMFSender* createDTMFSender(MediaStreamTrack*, ExceptionState&); |
| |
| void close(ExceptionState&); |
| |
| // We allow getStats after close, but not other calls or callbacks. |
| bool shouldFireDefaultCallbacks() { return !m_closed && !m_stopped; } |
| bool shouldFireGetStatsCallback() { return !m_stopped; } |
| |
| DEFINE_ATTRIBUTE_EVENT_LISTENER(negotiationneeded); |
| DEFINE_ATTRIBUTE_EVENT_LISTENER(icecandidate); |
| DEFINE_ATTRIBUTE_EVENT_LISTENER(signalingstatechange); |
| DEFINE_ATTRIBUTE_EVENT_LISTENER(addstream); |
| DEFINE_ATTRIBUTE_EVENT_LISTENER(removestream); |
| DEFINE_ATTRIBUTE_EVENT_LISTENER(iceconnectionstatechange); |
| DEFINE_ATTRIBUTE_EVENT_LISTENER(datachannel); |
| |
| // WebRTCPeerConnectionHandlerClient |
| virtual void negotiationNeeded() OVERRIDE; |
| virtual void didGenerateICECandidate(const WebRTCICECandidate&) OVERRIDE; |
| virtual void didChangeSignalingState(SignalingState) OVERRIDE; |
| virtual void didChangeICEGatheringState(ICEGatheringState) OVERRIDE; |
| virtual void didChangeICEConnectionState(ICEConnectionState) OVERRIDE; |
| virtual void didAddRemoteStream(const WebMediaStream&) OVERRIDE; |
| virtual void didRemoveRemoteStream(const WebMediaStream&) OVERRIDE; |
| virtual void didAddRemoteDataChannel(WebRTCDataChannelHandler*) OVERRIDE; |
| virtual void releasePeerConnectionHandler() OVERRIDE; |
| |
| // EventTarget |
| virtual const AtomicString& interfaceName() const OVERRIDE; |
| virtual ExecutionContext* executionContext() const OVERRIDE; |
| |
| // ActiveDOMObject |
| virtual void suspend() OVERRIDE; |
| virtual void resume() OVERRIDE; |
| virtual void stop() OVERRIDE; |
| // We keep the this object alive until either stopped or closed. |
| virtual bool hasPendingActivity() const OVERRIDE |
| { |
| return !m_closed && !m_stopped; |
| } |
| |
| virtual void trace(Visitor*) OVERRIDE; |
| |
| private: |
| RTCPeerConnection(ExecutionContext*, PassRefPtr<RTCConfiguration>, WebMediaConstraints, ExceptionState&); |
| |
| static PassRefPtr<RTCConfiguration> parseConfiguration(const Dictionary&, ExceptionState&); |
| static PassRefPtr<RTCOfferOptions> parseOfferOptions(const Dictionary&, ExceptionState&); |
| |
| void scheduleDispatchEvent(PassRefPtrWillBeRawPtr<Event>); |
| void dispatchScheduledEvent(); |
| bool hasLocalStreamWithTrackId(const String& trackId); |
| |
| void changeSignalingState(WebRTCPeerConnectionHandlerClient::SignalingState); |
| void changeIceGatheringState(WebRTCPeerConnectionHandlerClient::ICEGatheringState); |
| void changeIceConnectionState(WebRTCPeerConnectionHandlerClient::ICEConnectionState); |
| |
| SignalingState m_signalingState; |
| ICEGatheringState m_iceGatheringState; |
| ICEConnectionState m_iceConnectionState; |
| |
| MediaStreamVector m_localStreams; |
| MediaStreamVector m_remoteStreams; |
| |
| HeapVector<Member<RTCDataChannel> > m_dataChannels; |
| |
| OwnPtr<WebRTCPeerConnectionHandler> m_peerHandler; |
| |
| AsyncMethodRunner<RTCPeerConnection> m_dispatchScheduledEventRunner; |
| WillBeHeapVector<RefPtrWillBeMember<Event> > m_scheduledEvents; |
| |
| bool m_stopped; |
| bool m_closed; |
| }; |
| |
| } // namespace blink |
| |
| #endif // RTCPeerConnection_h |