Changeset 92102 in webkit
- Timestamp:
- Aug 1, 2011, 12:26:41 AM (15 years ago)
- Location:
- trunk/Source
- Files:
-
- 10 edited
-
WebCore/ChangeLog (modified) (1 diff)
-
WebCore/platform/network/SocketStreamHandleClient.h (modified) (1 diff)
-
WebCore/platform/network/brew/SocketStreamHandleBrew.cpp (modified) (4 diffs)
-
WebCore/platform/network/cf/SocketStreamHandleCFNet.cpp (modified) (9 diffs)
-
WebCore/platform/network/qt/SocketStreamHandleQt.cpp (modified) (4 diffs)
-
WebCore/platform/network/soup/SocketStreamHandleSoup.cpp (modified) (7 diffs)
-
WebCore/websockets/WebSocketChannel.cpp (modified) (5 diffs)
-
WebCore/websockets/WebSocketChannel.h (modified) (1 diff)
-
WebKit/chromium/ChangeLog (modified) (1 diff)
-
WebKit/chromium/src/SocketStreamHandle.cpp (modified) (4 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/Source/WebCore/ChangeLog
r92098 r92102 1 2011-08-01 Yuta Kitamura <yutak@chromium.org> 2 3 WebSocket: Rename SocketStreamHandleClient member functions 4 https://bugs.webkit.org/show_bug.cgi?id=65374 5 6 Reviewed by Kent Tamura. 7 8 Rename SocketStreamHandleClient member functions to avoid conflict of the names of 9 FileReaderLoaderClient functions. 10 11 No change in behavior, thus no new tests are added. 12 13 * platform/network/SocketStreamHandleClient.h: 14 (WebCore::SocketStreamHandleClient::didOpenSocketStream): 15 (WebCore::SocketStreamHandleClient::didCloseSocketStream): 16 (WebCore::SocketStreamHandleClient::didReceiveSocketStreamData): 17 (WebCore::SocketStreamHandleClient::didFailSocketStream): 18 * platform/network/brew/SocketStreamHandleBrew.cpp: 19 (WebCore::SocketStreamHandlePrivate::socketConnected): 20 (WebCore::SocketStreamHandlePrivate::socketReadyRead): 21 (WebCore::SocketStreamHandlePrivate::socketClosed): 22 (WebCore::SocketStreamHandlePrivate::socketError): 23 * platform/network/cf/SocketStreamHandleCFNet.cpp: 24 (WebCore::SocketStreamHandle::addCONNECTCredentials): 25 (WebCore::SocketStreamHandle::readStreamCallback): 26 (WebCore::SocketStreamHandle::writeStreamCallback): 27 (WebCore::SocketStreamHandle::reportErrorToClient): 28 (WebCore::SocketStreamHandle::platformClose): 29 * platform/network/qt/SocketStreamHandleQt.cpp: 30 (WebCore::SocketStreamHandlePrivate::socketConnected): 31 (WebCore::SocketStreamHandlePrivate::socketReadyRead): 32 (WebCore::SocketStreamHandlePrivate::socketClosedCallback): 33 (WebCore::SocketStreamHandlePrivate::socketErrorCallback): 34 * platform/network/soup/SocketStreamHandleSoup.cpp: 35 (WebCore::SocketStreamHandle::connected): 36 (WebCore::SocketStreamHandle::readBytes): 37 (WebCore::SocketStreamHandle::platformSend): 38 (WebCore::SocketStreamHandle::platformClose): 39 * websockets/WebSocketChannel.cpp: 40 (WebCore::WebSocketChannel::didOpenSocketStream): 41 (WebCore::WebSocketChannel::didCloseSocketStream): 42 (WebCore::WebSocketChannel::didReceiveSocketStreamData): 43 (WebCore::WebSocketChannel::didFailSocketStream): 44 (WebCore::WebSocketChannel::resumeTimerFired): 45 * websockets/WebSocketChannel.h: 46 1 47 2011-07-31 Sheriff Bot <webkit.review.bot@gmail.com> 2 48 -
trunk/Source/WebCore/platform/network/SocketStreamHandleClient.h
r50951 r92102 44 44 virtual ~SocketStreamHandleClient() { } 45 45 46 virtual void didOpen (SocketStreamHandle*) { }47 virtual void didClose (SocketStreamHandle*) { }48 virtual void didReceive Data(SocketStreamHandle*, const char* /*data*/, int /*length*/) { }46 virtual void didOpenSocketStream(SocketStreamHandle*) { } 47 virtual void didCloseSocketStream(SocketStreamHandle*) { } 48 virtual void didReceiveSocketStreamData(SocketStreamHandle*, const char* /*data*/, int /*length*/) { } 49 49 50 virtual void didFail (SocketStreamHandle*, const SocketStreamError&) { }50 virtual void didFailSocketStream(SocketStreamHandle*, const SocketStreamError&) { } 51 51 52 52 // No authentication for streams per se, but proxy may ask for credentials. -
trunk/Source/WebCore/platform/network/brew/SocketStreamHandleBrew.cpp
r61496 r92102 114 114 if (m_streamHandle && m_streamHandle->client()) { 115 115 m_streamHandle->m_state = SocketStreamHandleBase::Open; 116 m_streamHandle->client()->didOpen (m_streamHandle);116 m_streamHandle->client()->didOpenSocketStream(m_streamHandle); 117 117 } 118 118 … … 131 131 } 132 132 133 m_streamHandle->client()->didReceive Data(m_streamHandle, buffer.data(), readSize);133 m_streamHandle->client()->didReceiveSocketStreamData(m_streamHandle, buffer.data(), readSize); 134 134 } 135 135 … … 167 167 m_streamHandle = 0; 168 168 // This following call deletes _this_. Nothing should be after it. 169 streamHandle->client()->didClose (streamHandle);169 streamHandle->client()->didCloseSocketStream(streamHandle); 170 170 } 171 171 } … … 178 178 m_streamHandle = 0; 179 179 // This following call deletes _this_. Nothing should be after it. 180 streamHandle->client()->didClose (streamHandle);180 streamHandle->client()->didCloseSocketStream(streamHandle); 181 181 } 182 182 } -
trunk/Source/WebCore/platform/network/cf/SocketStreamHandleCFNet.cpp
r87135 r92102 330 330 if (!CFHTTPAuthenticationRequiresUserNameAndPassword(authentication.get())) { 331 331 // That's all we can offer... 332 m_client->didFail (this, SocketStreamError()); // FIXME: Provide a sensible error.332 m_client->didFailSocketStream(this, SocketStreamError()); // FIXME: Provide a sensible error. 333 333 return; 334 334 } … … 355 355 if (!proxyAuthorizationString) { 356 356 // Fails e.g. for NTLM auth. 357 m_client->didFail (this, SocketStreamError()); // FIXME: Provide a sensible error.357 m_client->didFailSocketStream(this, SocketStreamError()); // FIXME: Provide a sensible error. 358 358 return; 359 359 } … … 367 367 // FIXME: Ask the client if credentials could not be found. 368 368 369 m_client->didFail (this, SocketStreamError()); // FIXME: Provide a sensible error.369 m_client->didFailSocketStream(this, SocketStreamError()); // FIXME: Provide a sensible error. 370 370 } 371 371 … … 446 446 447 447 RefPtr<SocketStreamHandle> protect(this); // The client can close the handle, potentially removing the last reference. 448 m_client->didOpen (this);448 m_client->didOpenSocketStream(this); 449 449 if (m_state == Closed) 450 450 break; … … 464 464 } 465 465 466 m_client->didReceive Data(this, reinterpret_cast<const char*>(ptr), length);466 m_client->didReceiveSocketStreamData(this, reinterpret_cast<const char*>(ptr), length); 467 467 468 468 break; … … 505 505 506 506 RefPtr<SocketStreamHandle> protect(this); // The client can close the handle, potentially removing the last reference. 507 m_client->didOpen (this);507 m_client->didOpenSocketStream(this); 508 508 break; 509 509 } … … 544 544 } 545 545 546 m_client->didFail (this, SocketStreamError(static_cast<int>(errorCode), m_url.string(), description));546 m_client->didFailSocketStream(this, SocketStreamError(static_cast<int>(errorCode), m_url.string(), description)); 547 547 } 548 548 … … 572 572 if (!m_readStream) { 573 573 if (m_connectingSubstate == New || m_connectingSubstate == ExecutingPACFile) 574 m_client->didClose (this);574 m_client->didCloseSocketStream(this); 575 575 return; 576 576 } … … 590 590 m_writeStream = 0; 591 591 592 m_client->didClose (this);592 m_client->didCloseSocketStream(this); 593 593 } 594 594 -
trunk/Source/WebCore/platform/network/qt/SocketStreamHandleQt.cpp
r69221 r92102 84 84 if (m_streamHandle && m_streamHandle->client()) { 85 85 m_streamHandle->m_state = SocketStreamHandleBase::Open; 86 m_streamHandle->client()->didOpen (m_streamHandle);86 m_streamHandle->client()->didOpenSocketStream(m_streamHandle); 87 87 } 88 88 } … … 92 92 if (m_streamHandle && m_streamHandle->client()) { 93 93 QByteArray data = m_socket->read(m_socket->bytesAvailable()); 94 m_streamHandle->client()->didReceive Data(m_streamHandle, data.constData(), data.size());94 m_streamHandle->client()->didReceiveSocketStreamData(m_streamHandle, data.constData(), data.size()); 95 95 } 96 96 } … … 133 133 m_streamHandle = 0; 134 134 // This following call deletes _this_. Nothing should be after it. 135 streamHandle->client()->didClose (streamHandle);135 streamHandle->client()->didCloseSocketStream(streamHandle); 136 136 } 137 137 } … … 144 144 m_streamHandle = 0; 145 145 // This following call deletes _this_. Nothing should be after it. 146 streamHandle->client()->didClose (streamHandle);146 streamHandle->client()->didCloseSocketStream(streamHandle); 147 147 } 148 148 } -
trunk/Source/WebCore/platform/network/soup/SocketStreamHandleSoup.cpp
r89197 r92102 103 103 { 104 104 if (error) { 105 m_client->didFail (this, SocketStreamError(error->code));105 m_client->didFailSocketStream(this, SocketStreamError(error->code)); 106 106 return; 107 107 } … … 118 118 RefPtr<SocketStreamHandle> protect(this); 119 119 m_state = Open; 120 m_client->didOpen (this);120 m_client->didOpenSocketStream(this); 121 121 if (!m_socketConnection) // Client closed the connection. 122 122 return; … … 126 126 { 127 127 if (error) { 128 m_client->didFail (this, SocketStreamError(error->code));128 m_client->didFailSocketStream(this, SocketStreamError(error->code)); 129 129 return; 130 130 } … … 137 137 // The client can close the handle, potentially removing the last reference. 138 138 RefPtr<SocketStreamHandle> protect(this); 139 m_client->didReceive Data(this, m_readBuffer, bytesRead);139 m_client->didReceiveSocketStreamData(this, m_readBuffer, bytesRead); 140 140 if (m_inputStream) // The client may have closed the connection. 141 141 g_input_stream_read_async(m_inputStream.get(), m_readBuffer, READ_BUFFER_SIZE, G_PRIORITY_DEFAULT, 0, … … 164 164 gssize written = g_pollable_output_stream_write_nonblocking(m_outputStream.get(), data, length, 0, &error.outPtr()); 165 165 if (error && !g_error_matches(error.get(), G_IO_ERROR, G_IO_ERROR_WOULD_BLOCK)) { 166 m_client->didFail (this, SocketStreamError(error->code)); // FIXME: Provide a sensible error.166 m_client->didFailSocketStream(this, SocketStreamError(error->code)); // FIXME: Provide a sensible error. 167 167 return 0; 168 168 } … … 186 186 g_io_stream_close(G_IO_STREAM(m_socketConnection.get()), 0, &error.outPtr()); 187 187 if (error) 188 m_client->didFail (this, SocketStreamError(error->code)); // FIXME: Provide a sensible error.188 m_client->didFailSocketStream(this, SocketStreamError(error->code)); // FIXME: Provide a sensible error. 189 189 m_socketConnection = 0; 190 190 } … … 194 194 delete m_readBuffer; 195 195 196 m_client->didClose (this);196 m_client->didCloseSocketStream(this); 197 197 } 198 198 -
trunk/Source/WebCore/websockets/WebSocketChannel.cpp
r91919 r92102 204 204 } 205 205 206 void WebSocketChannel::didOpen (SocketStreamHandle* handle)207 { 208 LOG(Network, "WebSocketChannel %p didOpen ", this);206 void WebSocketChannel::didOpenSocketStream(SocketStreamHandle* handle) 207 { 208 LOG(Network, "WebSocketChannel %p didOpenSocketStream", this); 209 209 ASSERT(handle == m_handle); 210 210 if (!m_context) … … 217 217 } 218 218 219 void WebSocketChannel::didClose (SocketStreamHandle* handle)220 { 221 LOG(Network, "WebSocketChannel %p didClose ", this);219 void WebSocketChannel::didCloseSocketStream(SocketStreamHandle* handle) 220 { 221 LOG(Network, "WebSocketChannel %p didCloseSocketStream", this); 222 222 if (m_identifier && m_context) 223 223 InspectorInstrumentation::didCloseWebSocket(m_context, m_identifier); … … 240 240 } 241 241 242 void WebSocketChannel::didReceive Data(SocketStreamHandle* handle, const char* data, int len)243 { 244 LOG(Network, "WebSocketChannel %p didReceive Data %d", this, len);242 void WebSocketChannel::didReceiveSocketStreamData(SocketStreamHandle* handle, const char* data, int len) 243 { 244 LOG(Network, "WebSocketChannel %p didReceiveSocketStreamData %d", this, len); 245 245 RefPtr<WebSocketChannel> protect(this); // The client can close the channel, potentially removing the last reference. 246 246 ASSERT(handle == m_handle); … … 269 269 } 270 270 271 void WebSocketChannel::didFail (SocketStreamHandle* handle, const SocketStreamError& error)272 { 273 LOG(Network, "WebSocketChannel %p didFail ", this);271 void WebSocketChannel::didFailSocketStream(SocketStreamHandle* handle, const SocketStreamError& error) 272 { 273 LOG(Network, "WebSocketChannel %p didFailSocketStream", this); 274 274 ASSERT(handle == m_handle || !m_handle); 275 275 if (m_context) { … … 396 396 break; 397 397 if (!m_suspended && m_client && m_closed && m_handle) 398 didClose (m_handle.get());398 didCloseSocketStream(m_handle.get()); 399 399 } 400 400 -
trunk/Source/WebCore/websockets/WebSocketChannel.h
r91919 r92102 66 66 virtual void resume(); 67 67 68 virtual void didOpen(SocketStreamHandle*); 69 virtual void didClose(SocketStreamHandle*); 70 virtual void didReceiveData(SocketStreamHandle*, const char*, int); 71 virtual void didFail(SocketStreamHandle*, const SocketStreamError&); 68 // SocketStreamHandleClient functions. 69 virtual void didOpenSocketStream(SocketStreamHandle*); 70 virtual void didCloseSocketStream(SocketStreamHandle*); 71 virtual void didReceiveSocketStreamData(SocketStreamHandle*, const char*, int); 72 virtual void didFailSocketStream(SocketStreamHandle*, const SocketStreamError&); 72 73 virtual void didReceiveAuthenticationChallenge(SocketStreamHandle*, const AuthenticationChallenge&); 73 74 virtual void didCancelAuthenticationChallenge(SocketStreamHandle*, const AuthenticationChallenge&); -
trunk/Source/WebKit/chromium/ChangeLog
r92083 r92102 1 2011-08-01 Yuta Kitamura <yutak@chromium.org> 2 3 WebSocket: Rename SocketStreamHandleClient member functions 4 https://bugs.webkit.org/show_bug.cgi?id=65374 5 6 Reviewed by Kent Tamura. 7 8 * src/SocketStreamHandle.cpp: 9 (WebCore::SocketStreamHandleInternal::didOpenStream): 10 (WebCore::SocketStreamHandleInternal::didReceiveData): 11 (WebCore::SocketStreamHandleInternal::didClose): 12 (WebCore::SocketStreamHandleInternal::didFail): 13 1 14 2011-07-31 Bill Budge <bbudge@chromium.org> 2 15 -
trunk/Source/WebKit/chromium/src/SocketStreamHandle.cpp
r86067 r92102 131 131 m_handle->m_state = SocketStreamHandleBase::Open; 132 132 if (m_handle->m_client) { 133 m_handle->m_client->didOpen (m_handle);133 m_handle->m_client->didOpenSocketStream(m_handle); 134 134 return; 135 135 } … … 156 156 ASSERT(socketHandle == m_socket.get()); 157 157 if (m_handle->m_client) 158 m_handle->m_client->didReceive Data(m_handle, data.data(), data.size());158 m_handle->m_client->didReceiveSocketStreamData(m_handle, data.data(), data.size()); 159 159 } 160 160 } … … 169 169 m_handle = 0; 170 170 if (h->m_client) 171 h->m_client->didClose (h);171 h->m_client->didCloseSocketStream(h); 172 172 } 173 173 } … … 182 182 m_handle = 0; 183 183 if (h->m_client) 184 h->m_client->didClose (h);// didFail(h, err);184 h->m_client->didCloseSocketStream(h); // didFail(h, err); 185 185 } 186 186 }
Note:
See TracChangeset
for help on using the changeset viewer.