[WebSocket] bufferedAmount should not decrease inside a task.

Source/modules/websockets/WebSocket.h

Index: Source/modules/websockets/WebSocket.h
diff --git a/Source/modules/websockets/WebSocket.h b/Source/modules/websockets/WebSocket.h
index 8fd7bf97c1f20f319d370081cc0979ad4b20b3b0..1eb3d8dc14af95881fe5a292cd12646fe50f16f2 100644
--- a/Source/modules/websockets/WebSocket.h
+++ b/Source/modules/websockets/WebSocket.h
@@ -120,9 +120,9 @@ public:
     virtual void didReceiveMessage(const String& message) OVERRIDE;
     virtual void didReceiveBinaryData(PassOwnPtr<Vector<char> >) OVERRIDE;
     virtual void didReceiveMessageError() OVERRIDE;
-    virtual void didUpdateBufferedAmount(unsigned long bufferedAmount) OVERRIDE;
+    virtual void didConsumeBufferedAmount(unsigned long) OVERRIDE;
     virtual void didStartClosingHandshake() OVERRIDE;
-    virtual void didClose(unsigned long unhandledBufferedAmount, ClosingHandshakeCompletionStatus, unsigned short code, const String& reason) OVERRIDE;
+    virtual void didClose(ClosingHandshakeCompletionStatus, unsigned short code, const String& reason) OVERRIDE;
 
     virtual void trace(Visitor*) OVERRIDE;
 
@@ -208,6 +208,7 @@ private:
     // Updates m_bufferedAmountAfterClose given the amount of data passed to
     // send() method after the state changed to CLOSING or CLOSED.
     void updateBufferedAmountAfterClose(unsigned long);
+    void reflectBufferedAmountConsumption(Timer<WebSocket>*);
 
     void releaseChannel();
 
@@ -221,6 +222,7 @@ private:
     State m_state;
     KURL m_url;
     unsigned long m_bufferedAmount;
+    unsigned long m_consumedBufferedAmount;

[tyoshino (SeeGerritForStatus), 2014/06/16 07:31:42]

write comment to say that this is pending amount not yet reflected to
m_bufferedAmount

[yhirano, 2014/06/16 10:19:45]

Done.

     unsigned long m_bufferedAmountAfterClose;
     BinaryType m_binaryType;
     // The subprotocol the server selected.
@@ -228,6 +230,7 @@ private:
     String m_extensions;
 
     RefPtrWillBeMember<EventQueue> m_eventQueue;
+    Timer<WebSocket> m_bufferedAmountConsumeTimer;
 };
 
 } // namespace WebCore