| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (C) 2013 Google Inc. All rights reserved. | 2 * Copyright (C) 2013 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 152 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 163 flowControlIfNecessary(); | 163 flowControlIfNecessary(); |
| 164 if (m_identifier) { | 164 if (m_identifier) { |
| 165 TRACE_EVENT_INSTANT1(TRACE_DISABLED_BY_DEFAULT("devtools.timeline"), "We
bSocketCreate", "data", InspectorWebSocketCreateEvent::data(document(), m_identi
fier, url, protocol)); | 165 TRACE_EVENT_INSTANT1(TRACE_DISABLED_BY_DEFAULT("devtools.timeline"), "We
bSocketCreate", "data", InspectorWebSocketCreateEvent::data(document(), m_identi
fier, url, protocol)); |
| 166 TRACE_EVENT_INSTANT1(TRACE_DISABLED_BY_DEFAULT("devtools.timeline.stack"
), "CallStack", "stack", InspectorCallStackEvent::currentCallStack()); | 166 TRACE_EVENT_INSTANT1(TRACE_DISABLED_BY_DEFAULT("devtools.timeline.stack"
), "CallStack", "stack", InspectorCallStackEvent::currentCallStack()); |
| 167 // FIXME(361045): remove InspectorInstrumentation calls once DevTools Ti
meline migrates to tracing. | 167 // FIXME(361045): remove InspectorInstrumentation calls once DevTools Ti
meline migrates to tracing. |
| 168 InspectorInstrumentation::didCreateWebSocket(document(), m_identifier, u
rl, protocol); | 168 InspectorInstrumentation::didCreateWebSocket(document(), m_identifier, u
rl, protocol); |
| 169 } | 169 } |
| 170 return true; | 170 return true; |
| 171 } | 171 } |
| 172 | 172 |
| 173 String NewWebSocketChannelImpl::subprotocol() | |
| 174 { | |
| 175 WTF_LOG(Network, "NewWebSocketChannelImpl %p subprotocol()", this); | |
| 176 return m_subprotocol; | |
| 177 } | |
| 178 | |
| 179 String NewWebSocketChannelImpl::extensions() | |
| 180 { | |
| 181 WTF_LOG(Network, "NewWebSocketChannelImpl %p extensions()", this); | |
| 182 return m_extensions; | |
| 183 } | |
| 184 | |
| 185 WebSocketChannel::SendResult NewWebSocketChannelImpl::send(const String& message
) | 173 WebSocketChannel::SendResult NewWebSocketChannelImpl::send(const String& message
) |
| 186 { | 174 { |
| 187 WTF_LOG(Network, "NewWebSocketChannelImpl %p sendText(%s)", this, message.ut
f8().data()); | 175 WTF_LOG(Network, "NewWebSocketChannelImpl %p sendText(%s)", this, message.ut
f8().data()); |
| 188 if (m_identifier) { | 176 if (m_identifier) { |
| 189 // FIXME: Change the inspector API to show the entire message instead | 177 // FIXME: Change the inspector API to show the entire message instead |
| 190 // of individual frames. | 178 // of individual frames. |
| 191 CString data = message.utf8(); | 179 CString data = message.utf8(); |
| 192 InspectorInstrumentation::didSendWebSocketFrame(document(), m_identifier
, WebSocketFrame::OpCodeText, true, data.data(), data.length()); | 180 InspectorInstrumentation::didSendWebSocketFrame(document(), m_identifier
, WebSocketFrame::OpCodeText, true, data.data(), data.length()); |
| 193 } | 181 } |
| 194 m_messages.append(adoptPtr(new Message(message))); | 182 m_messages.append(adoptPtr(new Message(message))); |
| (...skipping 216 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 411 { | 399 { |
| 412 WTF_LOG(Network, "NewWebSocketChannelImpl %p didConnect(%p, %d, %s, %s)", th
is, handle, fail, selectedProtocol.utf8().data(), extensions.utf8().data()); | 400 WTF_LOG(Network, "NewWebSocketChannelImpl %p didConnect(%p, %d, %s, %s)", th
is, handle, fail, selectedProtocol.utf8().data(), extensions.utf8().data()); |
| 413 ASSERT(m_handle); | 401 ASSERT(m_handle); |
| 414 ASSERT(handle == m_handle); | 402 ASSERT(handle == m_handle); |
| 415 ASSERT(m_client); | 403 ASSERT(m_client); |
| 416 if (fail) { | 404 if (fail) { |
| 417 failAsError("Cannot connect to " + m_url.string() + "."); | 405 failAsError("Cannot connect to " + m_url.string() + "."); |
| 418 // failAsError may delete this object. | 406 // failAsError may delete this object. |
| 419 return; | 407 return; |
| 420 } | 408 } |
| 421 m_subprotocol = selectedProtocol; | 409 m_client->didConnect(selectedProtocol, extensions); |
| 422 m_extensions = extensions; | |
| 423 m_client->didConnect(); | |
| 424 } | 410 } |
| 425 | 411 |
| 426 void NewWebSocketChannelImpl::didStartOpeningHandshake(WebSocketHandle* handle,
const blink::WebSocketHandshakeRequestInfo& request) | 412 void NewWebSocketChannelImpl::didStartOpeningHandshake(WebSocketHandle* handle,
const blink::WebSocketHandshakeRequestInfo& request) |
| 427 { | 413 { |
| 428 WTF_LOG(Network, "NewWebSocketChannelImpl %p didStartOpeningHandshake(%p)",
this, handle); | 414 WTF_LOG(Network, "NewWebSocketChannelImpl %p didStartOpeningHandshake(%p)",
this, handle); |
| 429 if (m_identifier) { | 415 if (m_identifier) { |
| 430 TRACE_EVENT_INSTANT1(TRACE_DISABLED_BY_DEFAULT("devtools.timeline"), "We
bSocketSendHandshakeRequest", "data", InspectorWebSocketEvent::data(document(),
m_identifier)); | 416 TRACE_EVENT_INSTANT1(TRACE_DISABLED_BY_DEFAULT("devtools.timeline"), "We
bSocketSendHandshakeRequest", "data", InspectorWebSocketEvent::data(document(),
m_identifier)); |
| 431 TRACE_EVENT_INSTANT1(TRACE_DISABLED_BY_DEFAULT("devtools.timeline.stack"
), "CallStack", "stack", InspectorCallStackEvent::currentCallStack()); | 417 TRACE_EVENT_INSTANT1(TRACE_DISABLED_BY_DEFAULT("devtools.timeline.stack"
), "CallStack", "stack", InspectorCallStackEvent::currentCallStack()); |
| 432 // FIXME(361045): remove InspectorInstrumentation calls once DevTools Ti
meline migrates to tracing. | 418 // FIXME(361045): remove InspectorInstrumentation calls once DevTools Ti
meline migrates to tracing. |
| 433 InspectorInstrumentation::willSendWebSocketHandshakeRequest(document(),
m_identifier, &request.toCoreRequest()); | 419 InspectorInstrumentation::willSendWebSocketHandshakeRequest(document(),
m_identifier, &request.toCoreRequest()); |
| (...skipping 128 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 562 // |this| can be deleted here. | 548 // |this| can be deleted here. |
| 563 } | 549 } |
| 564 | 550 |
| 565 void NewWebSocketChannelImpl::trace(Visitor* visitor) | 551 void NewWebSocketChannelImpl::trace(Visitor* visitor) |
| 566 { | 552 { |
| 567 visitor->trace(m_blobLoader); | 553 visitor->trace(m_blobLoader); |
| 568 WebSocketChannel::trace(visitor); | 554 WebSocketChannel::trace(visitor); |
| 569 } | 555 } |
| 570 | 556 |
| 571 } // namespace WebCore | 557 } // namespace WebCore |
| OLD | NEW |