| OLD | NEW | 
|    1 /* |    1 /* | 
|    2  * Copyright (C) 2008 Apple Inc. All Rights Reserved. |    2  * Copyright (C) 2008 Apple Inc. All Rights Reserved. | 
|    3  * Copyright (C) 2009 Google Inc. All Rights Reserved. |    3  * Copyright (C) 2009 Google Inc. All Rights Reserved. | 
|    4  * |    4  * | 
|    5  * Redistribution and use in source and binary forms, with or without |    5  * Redistribution and use in source and binary forms, with or without | 
|    6  * modification, are permitted provided that the following conditions |    6  * modification, are permitted provided that the following conditions | 
|    7  * are met: |    7  * are met: | 
|    8  * 1. Redistributions of source code must retain the above copyright |    8  * 1. 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  * 2. Redistributions in binary form must reproduce the above copyright |   10  * 2. Redistributions in binary form must reproduce the above copyright | 
| (...skipping 278 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  289     if (m_askedToTerminate) |  289     if (m_askedToTerminate) | 
|  290         return; |  290         return; | 
|  291  |  291  | 
|  292     if (m_workerThread) { |  292     if (m_workerThread) { | 
|  293         ++m_unconfirmedMessageCount; |  293         ++m_unconfirmedMessageCount; | 
|  294         m_workerThread->runLoop().postTask(MessageWorkerContextTask::create(mess
     age, channels)); |  294         m_workerThread->runLoop().postTask(MessageWorkerContextTask::create(mess
     age, channels)); | 
|  295     } else |  295     } else | 
|  296         m_queuedEarlyTasks.append(MessageWorkerContextTask::create(message, chan
     nels)); |  296         m_queuedEarlyTasks.append(MessageWorkerContextTask::create(message, chan
     nels)); | 
|  297 } |  297 } | 
|  298  |  298  | 
|  299 void WorkerMessagingProxy::postTaskForModeToWorkerContext(PassOwnPtr<ScriptExecu
     tionContext::Task> task, const String& mode) |  299 bool WorkerMessagingProxy::postTaskForModeToWorkerContext(PassOwnPtr<ScriptExecu
     tionContext::Task> task, const String& mode) | 
|  300 { |  300 { | 
|  301     if (m_askedToTerminate) |  301     if (m_askedToTerminate) | 
|  302         return; |  302         return false; | 
|  303  |  303  | 
|  304     ASSERT(m_workerThread); |  304     ASSERT(m_workerThread); | 
|  305     m_workerThread->runLoop().postTaskForMode(task, mode); |  305     m_workerThread->runLoop().postTaskForMode(task, mode); | 
 |  306     return true; | 
|  306 } |  307 } | 
|  307  |  308  | 
|  308 void WorkerMessagingProxy::postTaskToLoader(PassOwnPtr<ScriptExecutionContext::T
     ask> task) |  309 void WorkerMessagingProxy::postTaskToLoader(PassOwnPtr<ScriptExecutionContext::T
     ask> task) | 
|  309 { |  310 { | 
|  310     // FIXME: In case of nested workers, this should go directly to the root Doc
     ument context. |  311     // FIXME: In case of nested workers, this should go directly to the root Doc
     ument context. | 
|  311     ASSERT(m_scriptExecutionContext->isDocument()); |  312     ASSERT(m_scriptExecutionContext->isDocument()); | 
|  312     m_scriptExecutionContext->postTask(task); |  313     m_scriptExecutionContext->postTask(task); | 
|  313 } |  314 } | 
|  314  |  315  | 
|  315 void WorkerMessagingProxy::postExceptionToWorkerObject(const String& errorMessag
     e, int lineNumber, const String& sourceURL) |  316 void WorkerMessagingProxy::postExceptionToWorkerObject(const String& errorMessag
     e, int lineNumber, const String& sourceURL) | 
| (...skipping 172 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  488 } |  489 } | 
|  489  |  490  | 
|  490 bool WorkerMessagingProxy::hasPendingActivity() const |  491 bool WorkerMessagingProxy::hasPendingActivity() const | 
|  491 { |  492 { | 
|  492     return (m_unconfirmedMessageCount || m_workerThreadHadPendingActivity) && !m
     _askedToTerminate; |  493     return (m_unconfirmedMessageCount || m_workerThreadHadPendingActivity) && !m
     _askedToTerminate; | 
|  493 } |  494 } | 
|  494  |  495  | 
|  495 } // namespace WebCore |  496 } // namespace WebCore | 
|  496  |  497  | 
|  497 #endif // ENABLE(WORKERS) |  498 #endif // ENABLE(WORKERS) | 
| OLD | NEW |