ScriptExecutionContext.cpp [plain text]
#include "config.h"
#include "ScriptExecutionContext.h"
#include "ActiveDOMObject.h"
#include "Document.h"
#include "MessagePort.h"
#include "SecurityOrigin.h"
#include "WorkerContext.h"
#include "WorkerThread.h"
#include <wtf/MainThread.h>
#include <wtf/PassRefPtr.h>
namespace WebCore {
class ProcessMessagesSoonTask : public ScriptExecutionContext::Task {
public:
static PassRefPtr<ProcessMessagesSoonTask> create()
{
return adoptRef(new ProcessMessagesSoonTask);
}
virtual void performTask(ScriptExecutionContext* context)
{
context->dispatchMessagePortEvents();
}
};
ScriptExecutionContext::ScriptExecutionContext()
{
}
ScriptExecutionContext::~ScriptExecutionContext()
{
HashMap<ActiveDOMObject*, void*>::iterator activeObjectsEnd = m_activeDOMObjects.end();
for (HashMap<ActiveDOMObject*, void*>::iterator iter = m_activeDOMObjects.begin(); iter != activeObjectsEnd; ++iter) {
ASSERT(iter->first->scriptExecutionContext() == this);
iter->first->contextDestroyed();
}
HashSet<MessagePort*>::iterator messagePortsEnd = m_messagePorts.end();
for (HashSet<MessagePort*>::iterator iter = m_messagePorts.begin(); iter != messagePortsEnd; ++iter) {
ASSERT((*iter)->scriptExecutionContext() == this);
(*iter)->contextDestroyed();
}
}
void ScriptExecutionContext::processMessagePortMessagesSoon()
{
postTask(ProcessMessagesSoonTask::create());
}
void ScriptExecutionContext::dispatchMessagePortEvents()
{
RefPtr<ScriptExecutionContext> protect(this);
Vector<MessagePort*> ports;
copyToVector(m_messagePorts, ports);
unsigned portCount = ports.size();
for (unsigned i = 0; i < portCount; ++i) {
MessagePort* port = ports[i];
if (m_messagePorts.contains(port) && port->queueIsOpen())
port->dispatchMessages();
}
}
void ScriptExecutionContext::createdMessagePort(MessagePort* port)
{
ASSERT(port);
#if ENABLE(WORKERS)
ASSERT((isDocument() && isMainThread())
|| (isWorkerContext() && currentThread() == static_cast<WorkerContext*>(this)->thread()->threadID()));
#endif
m_messagePorts.add(port);
}
void ScriptExecutionContext::destroyedMessagePort(MessagePort* port)
{
ASSERT(port);
#if ENABLE(WORKERS)
ASSERT((isDocument() && isMainThread())
|| (isWorkerContext() && currentThread() == static_cast<WorkerContext*>(this)->thread()->threadID()));
#endif
m_messagePorts.remove(port);
}
bool ScriptExecutionContext::canSuspendActiveDOMObjects()
{
HashMap<ActiveDOMObject*, void*>::iterator activeObjectsEnd = m_activeDOMObjects.end();
for (HashMap<ActiveDOMObject*, void*>::iterator iter = m_activeDOMObjects.begin(); iter != activeObjectsEnd; ++iter) {
ASSERT(iter->first->scriptExecutionContext() == this);
if (!iter->first->canSuspend())
return false;
}
return true;
}
void ScriptExecutionContext::suspendActiveDOMObjects()
{
HashMap<ActiveDOMObject*, void*>::iterator activeObjectsEnd = m_activeDOMObjects.end();
for (HashMap<ActiveDOMObject*, void*>::iterator iter = m_activeDOMObjects.begin(); iter != activeObjectsEnd; ++iter) {
ASSERT(iter->first->scriptExecutionContext() == this);
iter->first->suspend();
}
}
void ScriptExecutionContext::resumeActiveDOMObjects()
{
HashMap<ActiveDOMObject*, void*>::iterator activeObjectsEnd = m_activeDOMObjects.end();
for (HashMap<ActiveDOMObject*, void*>::iterator iter = m_activeDOMObjects.begin(); iter != activeObjectsEnd; ++iter) {
ASSERT(iter->first->scriptExecutionContext() == this);
iter->first->resume();
}
}
void ScriptExecutionContext::stopActiveDOMObjects()
{
HashMap<ActiveDOMObject*, void*>::iterator activeObjectsEnd = m_activeDOMObjects.end();
for (HashMap<ActiveDOMObject*, void*>::iterator iter = m_activeDOMObjects.begin(); iter != activeObjectsEnd; ++iter) {
ASSERT(iter->first->scriptExecutionContext() == this);
iter->first->stop();
}
}
void ScriptExecutionContext::createdActiveDOMObject(ActiveDOMObject* object, void* upcastPointer)
{
ASSERT(object);
ASSERT(upcastPointer);
m_activeDOMObjects.add(object, upcastPointer);
}
void ScriptExecutionContext::destroyedActiveDOMObject(ActiveDOMObject* object)
{
ASSERT(object);
m_activeDOMObjects.remove(object);
}
void ScriptExecutionContext::setSecurityOrigin(PassRefPtr<SecurityOrigin> securityOrigin)
{
m_securityOrigin = securityOrigin;
}
ScriptExecutionContext::Task::~Task()
{
}
}