Initial implementation of onbufferedamountlow

Source/modules/mediastream/RTCDataChannel.h

 /*
  * 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
@@ skipping 24 matching lines @@
 
 class Blob;
 class DOMArrayBuffer;
 class DOMArrayBufferView;
 class ExceptionState;
 class RTCPeerConnection;
 class WebRTCDataChannelHandler;
 class WebRTCPeerConnectionHandler;
 struct WebRTCDataChannelInit;
 
-class RTCDataChannel final
+class MODULES_EXPORT RTCDataChannel final
     : public RefCountedGarbageCollectedEventTargetWithInlineData<RTCDataChannel>
     , public WebRTCDataChannelHandlerClient {
     REFCOUNTED_GARBAGE_COLLECTED_EVENT_TARGET(RTCDataChannel);
     DEFINE_WRAPPERTYPEINFO();
 public:
     static RTCDataChannel* create(ExecutionContext*, RTCPeerConnection*, PassOwnPtr<WebRTCDataChannelHandler>);
     static RTCDataChannel* create(ExecutionContext*, RTCPeerConnection*, WebRTCPeerConnectionHandler*, const String& label, const WebRTCDataChannelInit&, ExceptionState&);
     ~RTCDataChannel() override;
 
     ReadyState getHandlerState() const;
 
     String label() const;
 
     // DEPRECATED
     bool reliable() const;
 
     bool ordered() const;
     unsigned short maxRetransmitTime() const;
     unsigned short maxRetransmits() const;
     String protocol() const;
     bool negotiated() const;
     unsigned short id() const;
     String readyState() const;
     unsigned bufferedAmount() const;
 
+    unsigned bufferedAmountLowThreshold() const;
+    void setBufferedAmountLowThreshold(unsigned);
+
     String binaryType() const;
     void setBinaryType(const String&, ExceptionState&);
 
     void send(const String&, ExceptionState&);
     void send(PassRefPtr<DOMArrayBuffer>, ExceptionState&);
     void send(PassRefPtr<DOMArrayBufferView>, ExceptionState&);
     void send(Blob*, ExceptionState&);
 
     void close();
 
     DEFINE_ATTRIBUTE_EVENT_LISTENER(open);
+    DEFINE_ATTRIBUTE_EVENT_LISTENER(bufferedamountlow);
     DEFINE_ATTRIBUTE_EVENT_LISTENER(error);
     DEFINE_ATTRIBUTE_EVENT_LISTENER(close);
     DEFINE_ATTRIBUTE_EVENT_LISTENER(message);
 
     void stop();
 
     // EventTarget
     const AtomicString& interfaceName() const override;
     ExecutionContext* executionContext() const override;
 
     void clearWeakMembers(Visitor*);
 
     // Oilpan: need to eagerly finalize m_handler
     EAGERLY_FINALIZE();
     DECLARE_VIRTUAL_TRACE();
 
     // WebRTCDataChannelHandlerClient
     void didChangeReadyState(WebRTCDataChannelHandlerClient::ReadyState) override;
+    void didDecreaseBufferedAmount(unsigned) override;
     void didReceiveStringData(const WebString&) override;
     void didReceiveRawData(const char*, size_t) override;
     void didDetectError() override;
 
 private:
     RTCDataChannel(ExecutionContext*, RTCPeerConnection*, PassOwnPtr<WebRTCDataChannelHandler>);
 
     void scheduleDispatchEvent(PassRefPtrWillBeRawPtr<Event>);
     void scheduledEventTimerFired(Timer<RTCDataChannel>*);
 
     RawPtrWillBeMember<ExecutionContext> m_executionContext;
 
     OwnPtr<WebRTCDataChannelHandler> m_handler;
 
     bool m_stopped;
 
     WebRTCDataChannelHandlerClient::ReadyState m_readyState;
 
     enum BinaryType {
         BinaryTypeBlob,
         BinaryTypeArrayBuffer
     };
     BinaryType m_binaryType;
 
     Timer<RTCDataChannel> m_scheduledEventTimer;
     WillBeHeapVector<RefPtrWillBeMember<Event>> m_scheduledEvents;
 
     WeakMember<RTCPeerConnection> m_connection;
+
+    unsigned m_bufferedAmountLowThreshold;
+
+    // TODO(tkent): Use FRIEND_TEST macro provided by gtest_prod.h
+    friend class RTCDataChannelTest_BufferedAmountLow_Test; // NOLINT
 };
 
 } // namespace blink
 
 #endif // RTCDataChannel_h