| Index: trunk/Source/platform/network/SocketStreamHandle.cpp
|
| ===================================================================
|
| --- trunk/Source/platform/network/SocketStreamHandle.cpp (revision 176310)
|
| +++ trunk/Source/platform/network/SocketStreamHandle.cpp (working copy)
|
| @@ -194,6 +194,8 @@
|
| return false;
|
| }
|
| m_buffer.append(data, length);
|
| + if (m_client)
|
| + m_client->didUpdateBufferedAmount(this, bufferedAmount());
|
| return true;
|
| }
|
| int bytesWritten = 0;
|
| @@ -201,14 +203,14 @@
|
| bytesWritten = sendInternal(data, length);
|
| if (bytesWritten < 0)
|
| return false;
|
| - if (m_client)
|
| - m_client->didConsumeBufferedAmount(this, bytesWritten);
|
| if (m_buffer.size() + length - bytesWritten > bufferSize) {
|
| // FIXME: report error to indicate that buffer has no more space.
|
| return false;
|
| }
|
| if (bytesWritten < length) {
|
| m_buffer.append(data + bytesWritten, length - bytesWritten);
|
| + if (m_client)
|
| + m_client->didUpdateBufferedAmount(this, bufferedAmount());
|
| }
|
| return true;
|
| }
|
| @@ -257,9 +259,9 @@
|
| return false;
|
| ASSERT(m_buffer.size() - bytesWritten <= bufferSize);
|
| m_buffer.consume(bytesWritten);
|
| - if (m_client)
|
| - m_client->didConsumeBufferedAmount(this, bytesWritten);
|
| } while (!pending && !m_buffer.isEmpty());
|
| + if (m_client)
|
| + m_client->didUpdateBufferedAmount(this, bufferedAmount());
|
| return true;
|
| }
|
|
|
|
|