| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (C) 2011, 2012 Google Inc. All rights reserved. | 2 * Copyright (C) 2011, 2012 Google Inc. All rights reserved. |
| 3 * | 3 * |
| 4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
| 5 * modification, are permitted provided that the following conditions are | 5 * modification, are permitted provided that the following conditions are |
| 6 * met: | 6 * met: |
| 7 * | 7 * |
| 8 * * Redistributions of source code must retain the above copyright | 8 * * Redistributions of source code must retain the above copyright |
| 9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
| 10 * * Redistributions in binary form must reproduce the above | 10 * * Redistributions in binary form must reproduce the above |
| (...skipping 337 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 348 if (m_shouldDiscardReceivedData) | 348 if (m_shouldDiscardReceivedData) |
| 349 return; | 349 return; |
| 350 if (!appendToBuffer(data, len)) { | 350 if (!appendToBuffer(data, len)) { |
| 351 m_shouldDiscardReceivedData = true; | 351 m_shouldDiscardReceivedData = true; |
| 352 failAsError("Ran out of memory while receiving WebSocket data."); | 352 failAsError("Ran out of memory while receiving WebSocket data."); |
| 353 return; | 353 return; |
| 354 } | 354 } |
| 355 processBuffer(); | 355 processBuffer(); |
| 356 } | 356 } |
| 357 | 357 |
| 358 void MainThreadWebSocketChannel::didUpdateBufferedAmount(SocketStreamHandle*, si
ze_t bufferedAmount) | 358 void MainThreadWebSocketChannel::didIncreaseBufferedAmount(SocketStreamHandle*,
size_t amount) |
| 359 { | 359 { |
| 360 if (m_client) | 360 if (m_client) |
| 361 m_client->didUpdateBufferedAmount(bufferedAmount); | 361 m_client->didIncreaseBufferedAmount(amount); |
| 362 } |
| 363 |
| 364 void MainThreadWebSocketChannel::didDecreaseBufferedAmount(SocketStreamHandle*,
size_t amount) |
| 365 { |
| 366 if (m_client) |
| 367 m_client->didDecreaseBufferedAmount(amount); |
| 362 } | 368 } |
| 363 | 369 |
| 364 void MainThreadWebSocketChannel::didFailSocketStream(SocketStreamHandle* handle,
const SocketStreamError& error) | 370 void MainThreadWebSocketChannel::didFailSocketStream(SocketStreamHandle* handle,
const SocketStreamError& error) |
| 365 { | 371 { |
| 366 WTF_LOG(Network, "MainThreadWebSocketChannel %p didFailSocketStream()", this
); | 372 WTF_LOG(Network, "MainThreadWebSocketChannel %p didFailSocketStream()", this
); |
| 367 ASSERT_UNUSED(handle, handle == m_handle || !m_handle); | 373 ASSERT_UNUSED(handle, handle == m_handle || !m_handle); |
| 368 m_shouldDiscardReceivedData = true; | 374 m_shouldDiscardReceivedData = true; |
| 369 String message; | 375 String message; |
| 370 if (error.isNull()) | 376 if (error.isNull()) |
| 371 message = "WebSocket network error"; | 377 message = "WebSocket network error"; |
| (...skipping 492 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 864 } | 870 } |
| 865 | 871 |
| 866 Vector<char> frameData; | 872 Vector<char> frameData; |
| 867 frame.makeFrameData(frameData); | 873 frame.makeFrameData(frameData); |
| 868 | 874 |
| 869 m_perMessageDeflate.resetDeflateBuffer(); | 875 m_perMessageDeflate.resetDeflateBuffer(); |
| 870 return m_handle->send(frameData.data(), frameData.size()); | 876 return m_handle->send(frameData.data(), frameData.size()); |
| 871 } | 877 } |
| 872 | 878 |
| 873 } // namespace WebCore | 879 } // namespace WebCore |
| OLD | NEW |