| 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 273 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 284 m_state = ChannelClosed; | 284 m_state = ChannelClosed; |
| 285 if (m_closingTimer.isActive()) | 285 if (m_closingTimer.isActive()) |
| 286 m_closingTimer.stop(); | 286 m_closingTimer.stop(); |
| 287 if (m_outgoingFrameQueueStatus != OutgoingFrameQueueClosed) | 287 if (m_outgoingFrameQueueStatus != OutgoingFrameQueueClosed) |
| 288 abortOutgoingFrameQueue(); | 288 abortOutgoingFrameQueue(); |
| 289 if (m_handle) { | 289 if (m_handle) { |
| 290 m_unhandledBufferedAmount = m_handle->bufferedAmount(); | 290 m_unhandledBufferedAmount = m_handle->bufferedAmount(); |
| 291 WebSocketChannelClient* client = m_client; | 291 WebSocketChannelClient* client = m_client; |
| 292 m_client = 0; | 292 m_client = 0; |
| 293 clearDocument(); | 293 clearDocument(); |
| 294 m_handle = 0; | 294 m_handle = nullptr; |
| 295 if (client) | 295 if (client) |
| 296 client->didClose(m_unhandledBufferedAmount, m_receivedClosingHandsha
ke ? WebSocketChannelClient::ClosingHandshakeComplete : WebSocketChannelClient::
ClosingHandshakeIncomplete, m_closeEventCode, m_closeEventReason); | 296 client->didClose(m_unhandledBufferedAmount, m_receivedClosingHandsha
ke ? WebSocketChannelClient::ClosingHandshakeComplete : WebSocketChannelClient::
ClosingHandshakeIncomplete, m_closeEventCode, m_closeEventReason); |
| 297 } | 297 } |
| 298 deref(); | 298 deref(); |
| 299 } | 299 } |
| 300 | 300 |
| 301 void MainThreadWebSocketChannel::didReceiveSocketStreamData(SocketStreamHandle*
handle, const char* data, int len) | 301 void MainThreadWebSocketChannel::didReceiveSocketStreamData(SocketStreamHandle*
handle, const char* data, int len) |
| 302 { | 302 { |
| 303 WTF_LOG(Network, "MainThreadWebSocketChannel %p didReceiveSocketStreamData()
Received %d bytes", this, len); | 303 WTF_LOG(Network, "MainThreadWebSocketChannel %p didReceiveSocketStreamData()
Received %d bytes", this, len); |
| 304 RefPtr<MainThreadWebSocketChannel> protect(this); // The client can close th
e channel, potentially removing the last reference. | 304 RefPtr<MainThreadWebSocketChannel> protect(this); // The client can close th
e channel, potentially removing the last reference. |
| (...skipping 517 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 822 } | 822 } |
| 823 | 823 |
| 824 Vector<char> frameData; | 824 Vector<char> frameData; |
| 825 frame.makeFrameData(frameData); | 825 frame.makeFrameData(frameData); |
| 826 | 826 |
| 827 m_perMessageDeflate.resetDeflateBuffer(); | 827 m_perMessageDeflate.resetDeflateBuffer(); |
| 828 return m_handle->send(frameData.data(), frameData.size()); | 828 return m_handle->send(frameData.data(), frameData.size()); |
| 829 } | 829 } |
| 830 | 830 |
| 831 } // namespace WebCore | 831 } // namespace WebCore |
| OLD | NEW |