自学教程：C++ unsetPendingActivity函数代码示例

void FileReader::abort(){    LOG(FileAPI, "FileReader: aborting/n");    if (m_aborting || m_state != LOADING)        return;    m_aborting = true;    // Schedule to have the abort done later since abort() might be called from the event handler and we do not want the resource loading code to be in the stack.    scriptExecutionContext()->postTask([this] (ScriptExecutionContext&) {        ASSERT(m_state != DONE);        terminate();        m_aborting = false;        m_error = FileError::create(FileError::ABORT_ERR);        fireEvent(eventNames().errorEvent);        fireEvent(eventNames().abortEvent);        fireEvent(eventNames().loadendEvent);        // All possible events have fired and we're done, no more pending activity.        unsetPendingActivity(this);    });}

void Notification::finalize(){    if (m_state == Closed)        return;    m_state = Closed;    unsetPendingActivity(this);}

void FileWriter::didWrite(long long bytes, bool complete){    if (m_operationInProgress == OperationAbort) {        completeAbort();        return;    }    ASSERT(m_readyState == WRITING);    ASSERT(m_truncateLength == -1);    ASSERT(m_operationInProgress == OperationWrite);    ASSERT(bytes + m_bytesWritten > 0);    ASSERT(bytes + m_bytesWritten <= m_bytesToWrite);    m_bytesWritten += bytes;    ASSERT((m_bytesWritten == m_bytesToWrite) || !complete);    setPosition(position() + bytes);    if (position() > length())        setLength(position());    if (complete) {        m_blobBeingWritten.clear();        m_operationInProgress = OperationNone;    }    // TODO: Throttle to no more frequently than every 50ms.    int numAborts = m_numAborts;    fireEvent(eventNames().progressEvent);    // We could get an abort in the handler for this event. If we do, it's    // already handled the cleanup and signalCompletion call.    if (complete) {      if (numAborts == m_numAborts)          signalCompletion(FileError::OK);      unsetPendingActivity(this);    }}

void Notification::finishLoading(){    if (m_state == Loading) {        if (m_notificationCenter->presenter() && m_notificationCenter->presenter()->show(this))            m_state = Showing;    }    unsetPendingActivity(this);}

void SharedWorkerScriptLoader::notifyFinished(){    // Hand off the just-loaded code to the repository to start up the worker thread.    if (m_scriptLoader->failed())        m_worker->dispatchLoadErrorEvent();    else        DefaultSharedWorkerRepository::instance().workerScriptLoaded(*m_proxy, scriptExecutionContext()->userAgent(m_scriptLoader->url()), m_scriptLoader->script(), m_port.release());    // This frees this object - must be the last action in this function.    unsetPendingActivity(this);}

void Worker::notifyFinished(){    if (m_scriptLoader->failed())        dispatchEvent(Event::create(eventNames().errorEvent, false, true));    else        m_contextProxy->startWorkerContext(m_scriptLoader->url(), scriptExecutionContext()->userAgent(m_scriptLoader->url()), m_scriptLoader->script());    m_scriptLoader = 0;    unsetPendingActivity(this);}

void Worker::notifyFinished(){    if (m_scriptLoader->failed())        dispatchEvent(Event::create(eventNames().errorEvent, false, true));    else {        const ContentSecurityPolicyResponseHeaders& contentSecurityPolicyResponseHeaders = m_contentSecurityPolicyResponseHeaders ? m_contentSecurityPolicyResponseHeaders.value() : scriptExecutionContext()->contentSecurityPolicy()->responseHeaders();        m_contextProxy->startWorkerGlobalScope(m_scriptLoader->url(), scriptExecutionContext()->userAgent(m_scriptLoader->url()), m_scriptLoader->script(), contentSecurityPolicyResponseHeaders, m_shouldBypassMainWorldContentSecurityPolicy, DontPauseWorkerGlobalScopeOnStart);        InspectorInstrumentation::scriptImported(scriptExecutionContext(), m_scriptLoader->identifier(), m_scriptLoader->script());    }    m_scriptLoader = nullptr;    unsetPendingActivity(this);}

void Worker::notifyFinished(){    if (m_scriptLoader->failed())        dispatchEvent(Event::create(eventNames().errorEvent, false, true));    else {        WorkerThreadStartMode startMode = DontPauseWorkerGlobalScopeOnStart;        m_contextProxy->startWorkerGlobalScope(m_scriptLoader->url(), scriptExecutionContext()->userAgent(m_scriptLoader->url()), m_scriptLoader->script(), startMode);        InspectorInstrumentation::scriptImported(scriptExecutionContext(), m_scriptLoader->identifier(), m_scriptLoader->script());    }    m_scriptLoader = nullptr;    unsetPendingActivity(this);}

void XMLHttpRequest::dropProtection(){    // The XHR object itself holds on to the responseText, and    // thus has extra cost even independent of any    // responseText or responseXML objects it has handed    // out. But it is protected from GC while loading, so this    // can't be recouped until the load is done, so only    // report the extra cost at that point.    JSC::VM* vm = scriptExecutionContext()->vm();    JSC::JSLockHolder lock(vm);    vm->heap.reportExtraMemoryCost(m_responseBuilder.length() * 2);    unsetPendingActivity(this);}

void EventSource::abortConnectionAttempt(){    ASSERT(m_state == CONNECTING);    if (m_requestInFlight)        m_loader->cancel();    else {        m_state = CLOSED;        unsetPendingActivity(this);    }    ASSERT(m_state == CLOSED);    dispatchEvent(Event::create(eventNames().errorEvent, false, false));}

void EventSource::endRequest(){    m_requestInFlight = false;    if (!m_failSilently)        dispatchEvent(Event::create(eventNames().errorEvent, false, false));    if (!scriptExecutionContext()->isWorkerContext())        cache()->loader()->nonCacheRequestComplete(m_url);    if (m_state != CLOSED)        scheduleReconnect();    else        unsetPendingActivity(this);}

void Worker::notifyFinished(){    if (m_scriptLoader->failed()) {        dispatchEvent(Event::createCancelable(EventTypeNames::error));    } else {        WorkerThreadStartMode startMode = DontPauseWorkerGlobalScopeOnStart;        if (InspectorInstrumentation::shouldPauseDedicatedWorkerOnStart(executionContext()))            startMode = PauseWorkerGlobalScopeOnStart;        m_contextProxy->startWorkerGlobalScope(m_scriptLoader->url(), executionContext()->userAgent(m_scriptLoader->url()), m_scriptLoader->script(), startMode);        InspectorInstrumentation::scriptImported(executionContext(), m_scriptLoader->identifier(), m_scriptLoader->script());    }    m_scriptLoader = nullptr;    unsetPendingActivity(this);}

void XMLHttpRequest::dropProtection(){#if USE(JSC)    // The XHR object itself holds on to the responseText, and    // thus has extra cost even independent of any    // responseText or responseXML objects it has handed    // out. But it is protected from GC while loading, so this    // can't be recouped until the load is done, so only    // report the extra cost at that point.    JSC::JSLock lock(JSC::SilenceAssertionsOnly);    JSC::JSGlobalData* globalData = scriptExecutionContext()->globalData();    globalData->heap.reportExtraMemoryCost(m_responseBuilder.length() * 2);#endif    unsetPendingActivity(this);}

void AudioContext::clear(){    // We have to release our reference to the destination node before the context will ever be deleted since the destination node holds a reference to the context.    if (m_destinationNode)        m_destinationNode.clear();    // Audio thread is dead. Nobody will schedule node deletion action. Let's do it ourselves.    do {        deleteMarkedNodes();        m_nodesToDelete.appendVector(m_nodesMarkedForDeletion);        m_nodesMarkedForDeletion.clear();    } while (m_nodesToDelete.size());    // It was set in constructCommon.    unsetPendingActivity(this);}

void XMLHttpRequest::dropProtection(){    // The XHR object itself holds on to the responseText, and    // thus has extra cost even independent of any    // responseText or responseXML objects it has handed    // out. But it is protected from GC while loading, so this    // can't be recouped until the load is done, so only    // report the extra cost at that point.    JSC::VM& vm = scriptExecutionContext()->vm();    JSC::JSLockHolder lock(vm);    // FIXME: Adopt reportExtraMemoryVisited, and switch to reportExtraMemoryAllocated.    // https://bugs.webkit.org/show_bug.cgi?id=142595    vm.heap.deprecatedReportExtraMemory(m_responseBuilder.length() * 2);    unsetPendingActivity(this);}

void EventSource::close(){    if (m_state == CLOSED)        return;    if (m_reconnectTimer.isActive()) {        m_reconnectTimer.stop();        unsetPendingActivity(this);    }    m_state = CLOSED;    m_failSilently = true;    if (m_requestInFlight)        m_loader->cancel();}

void Worker::notifyFinished(CachedResource* resource){    ASSERT(resource == m_cachedScript.get());    if (m_cachedScript->errorOccurred())        dispatchErrorEvent();    else {        String userAgent = document()->frame() ? document()->frame()->loader()->userAgent(m_scriptURL) : String();        RefPtr<WorkerThread> thread = WorkerThread::create(m_scriptURL, userAgent, m_cachedScript->script(), m_messagingProxy);        m_messagingProxy->workerThreadCreated(thread);        thread->start();    }    m_cachedScript->removeClient(this);    m_cachedScript = 0;    unsetPendingActivity(this);}