[WebSocket] bufferedAmount should not decrease inside a task.

Source/modules/websockets/ThreadableWebSocketChannelClientWrapper.cpp

Index: Source/modules/websockets/ThreadableWebSocketChannelClientWrapper.cpp
diff --git a/Source/modules/websockets/ThreadableWebSocketChannelClientWrapper.cpp b/Source/modules/websockets/ThreadableWebSocketChannelClientWrapper.cpp
index e7e303d0bebcfc90ec4907304da7d4c781597754..d1145276ecd0f019399b1d9397c9118db05bb44e 100644
--- a/Source/modules/websockets/ThreadableWebSocketChannelClientWrapper.cpp
+++ b/Source/modules/websockets/ThreadableWebSocketChannelClientWrapper.cpp
@@ -102,9 +102,16 @@ void ThreadableWebSocketChannelClientWrapper::didReceiveBinaryData(PassOwnPtr<Ve
         processPendingTasks();
 }
 
-void ThreadableWebSocketChannelClientWrapper::didUpdateBufferedAmount(unsigned long bufferedAmount)
+void ThreadableWebSocketChannelClientWrapper::didIncreaseBufferedAmount(unsigned long amount)
 {
-    m_pendingTasks.append(createCallbackTask(&didUpdateBufferedAmountCallback, this, bufferedAmount));
+    m_pendingTasks.append(createCallbackTask(&didIncreaseBufferedAmountCallback, this, amount));
+    if (!m_suspended)
+        processPendingTasks();
+}

[tyoshino (SeeGerritForStatus), 2014/06/09 09:24:26]

blank line here

[yhirano, 2014/06/09 11:59:51]

Done.

+void ThreadableWebSocketChannelClientWrapper::didDecreaseBufferedAmount(unsigned long amount)
+

[tyoshino (SeeGerritForStatus), 2014/06/09 09:24:26]

remove this blank line

[yhirano, 2014/06/09 11:59:51]

Done.

+{
+    m_pendingTasks.append(createCallbackTask(&didDecreaseBufferedAmountCallback, this, amount));
     if (!m_suspended)
         processPendingTasks();
 }
@@ -172,13 +179,21 @@ void ThreadableWebSocketChannelClientWrapper::didReceiveBinaryDataCallback(Execu
         wrapper->m_client->didReceiveBinaryData(binaryData);
 }
 
-void ThreadableWebSocketChannelClientWrapper::didUpdateBufferedAmountCallback(ExecutionContext* context, PassRefPtr<ThreadableWebSocketChannelClientWrapper> wrapper, unsigned long bufferedAmount)
+void ThreadableWebSocketChannelClientWrapper::didIncreaseBufferedAmountCallback(ExecutionContext* context, PassRefPtr<ThreadableWebSocketChannelClientWrapper> wrapper, unsigned long amount)
 {
     ASSERT_UNUSED(context, !context);
     if (wrapper->m_client)
-        wrapper->m_client->didUpdateBufferedAmount(bufferedAmount);
+        wrapper->m_client->didIncreaseBufferedAmount(amount);
 }
 
+void ThreadableWebSocketChannelClientWrapper::didDecreaseBufferedAmountCallback(ExecutionContext* context, PassRefPtr<ThreadableWebSocketChannelClientWrapper> wrapper, unsigned long amount)
+{
+    ASSERT_UNUSED(context, !context);
+    if (wrapper->m_client)
+        wrapper->m_client->didDecreaseBufferedAmount(amount);
+}
+
+

[tyoshino (SeeGerritForStatus), 2014/06/09 09:24:26]

one blank line

[yhirano, 2014/06/09 11:59:51]

Done.

 void ThreadableWebSocketChannelClientWrapper::didStartClosingHandshakeCallback(ExecutionContext* context, PassRefPtr<ThreadableWebSocketChannelClientWrapper> wrapper)
 {
     ASSERT_UNUSED(context, !context);