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 110 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
121 return ""; | 121 return ""; |
122 String extensions = m_handshake->acceptedExtensions(); | 122 String extensions = m_handshake->acceptedExtensions(); |
123 if (extensions.isNull()) | 123 if (extensions.isNull()) |
124 return ""; | 124 return ""; |
125 return extensions; | 125 return extensions; |
126 } | 126 } |
127 | 127 |
128 WebSocketChannel::SendResult MainThreadWebSocketChannel::send(const String& mess
age) | 128 WebSocketChannel::SendResult MainThreadWebSocketChannel::send(const String& mess
age) |
129 { | 129 { |
130 WTF_LOG(Network, "MainThreadWebSocketChannel %p send() Sending String '%s'",
this, message.utf8().data()); | 130 WTF_LOG(Network, "MainThreadWebSocketChannel %p send() Sending String '%s'",
this, message.utf8().data()); |
131 CString utf8 = message.utf8(String::StrictConversionReplacingUnpairedSurroga
tesWithFFFD); | 131 CString utf8 = message.utf8(StrictUTF8ConversionReplacingUnpairedSurrogatesW
ithFFFD); |
132 enqueueTextFrame(utf8); | 132 enqueueTextFrame(utf8); |
133 processOutgoingFrameQueue(); | 133 processOutgoingFrameQueue(); |
134 // m_channel->send() may happen later, thus it's not always possible to know
whether | 134 // m_channel->send() may happen later, thus it's not always possible to know
whether |
135 // the message has been sent to the socket successfully. In this case, we ha
ve no choice | 135 // the message has been sent to the socket successfully. In this case, we ha
ve no choice |
136 // but to return SendSuccess. | 136 // but to return SendSuccess. |
137 return WebSocketChannel::SendSuccess; | 137 return WebSocketChannel::SendSuccess; |
138 } | 138 } |
139 | 139 |
140 WebSocketChannel::SendResult MainThreadWebSocketChannel::send(const ArrayBuffer&
binaryData, unsigned byteOffset, unsigned byteLength) | 140 WebSocketChannel::SendResult MainThreadWebSocketChannel::send(const ArrayBuffer&
binaryData, unsigned byteOffset, unsigned byteLength) |
141 { | 141 { |
(...skipping 672 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
814 } | 814 } |
815 | 815 |
816 Vector<char> frameData; | 816 Vector<char> frameData; |
817 frame.makeFrameData(frameData); | 817 frame.makeFrameData(frameData); |
818 | 818 |
819 m_perMessageDeflate.resetDeflateBuffer(); | 819 m_perMessageDeflate.resetDeflateBuffer(); |
820 return m_handle->send(frameData.data(), frameData.size()); | 820 return m_handle->send(frameData.data(), frameData.size()); |
821 } | 821 } |
822 | 822 |
823 } // namespace WebCore | 823 } // namespace WebCore |
OLD | NEW |