| 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 423 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 434 ASSERT_UNUSED(context, context->isWorkerGlobalScope()); | 434 ASSERT_UNUSED(context, context->isWorkerGlobalScope()); |
| 435 workerClientWrapper->didReceiveMessageError(); | 435 workerClientWrapper->didReceiveMessageError(); |
| 436 } | 436 } |
| 437 | 437 |
| 438 void WorkerThreadableWebSocketChannel::Peer::didReceiveMessageError() | 438 void WorkerThreadableWebSocketChannel::Peer::didReceiveMessageError() |
| 439 { | 439 { |
| 440 ASSERT(isMainThread()); | 440 ASSERT(isMainThread()); |
| 441 m_loaderProxy.postTaskToWorkerGlobalScope(createCallbackTask(&workerGlobalSc
opeDidReceiveMessageError, m_workerClientWrapper)); | 441 m_loaderProxy.postTaskToWorkerGlobalScope(createCallbackTask(&workerGlobalSc
opeDidReceiveMessageError, m_workerClientWrapper)); |
| 442 } | 442 } |
| 443 | 443 |
| 444 WorkerThreadableWebSocketChannel::Bridge::Bridge(PassRefPtr<ThreadableWebSocketC
hannelClientWrapper> workerClientWrapper, PassRefPtr<WorkerGlobalScope> workerGl
obalScope) | 444 WorkerThreadableWebSocketChannel::Bridge::Bridge(PassRefPtr<ThreadableWebSocketC
hannelClientWrapper> workerClientWrapper, PassRefPtrWillBeRawPtr<WorkerGlobalSco
pe> workerGlobalScope) |
| 445 : m_workerClientWrapper(workerClientWrapper) | 445 : m_workerClientWrapper(workerClientWrapper) |
| 446 , m_workerGlobalScope(workerGlobalScope) | 446 , m_workerGlobalScope(workerGlobalScope) |
| 447 , m_loaderProxy(m_workerGlobalScope->thread()->workerLoaderProxy()) | 447 , m_loaderProxy(m_workerGlobalScope->thread()->workerLoaderProxy()) |
| 448 , m_syncHelper(0) | 448 , m_syncHelper(0) |
| 449 { | 449 { |
| 450 ASSERT(m_workerClientWrapper.get()); | 450 ASSERT(m_workerClientWrapper.get()); |
| 451 } | 451 } |
| 452 | 452 |
| 453 WorkerThreadableWebSocketChannel::Bridge::~Bridge() | 453 WorkerThreadableWebSocketChannel::Bridge::~Bridge() |
| 454 { | 454 { |
| (...skipping 119 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 574 } | 574 } |
| 575 | 575 |
| 576 void WorkerThreadableWebSocketChannel::Bridge::terminatePeer() | 576 void WorkerThreadableWebSocketChannel::Bridge::terminatePeer() |
| 577 { | 577 { |
| 578 m_loaderProxy.postTaskToLoader(CallClosureTask::create(bind(&Peer::destroy,
m_peer))); | 578 m_loaderProxy.postTaskToLoader(CallClosureTask::create(bind(&Peer::destroy,
m_peer))); |
| 579 m_workerGlobalScope = nullptr; | 579 m_workerGlobalScope = nullptr; |
| 580 m_syncHelper = 0; | 580 m_syncHelper = 0; |
| 581 } | 581 } |
| 582 | 582 |
| 583 } // namespace WebCore | 583 } // namespace WebCore |
| OLD | NEW |