Home | History | Annotate | Download | only in Shared 
      1 /*
      2  * Copyright (C) 2010 Apple Inc. All rights reserved.
      3  *
      4  * Redistribution and use in source and binary forms, with or without
      5  * modification, are permitted provided that the following conditions
      6  * are met:
      7  * 1. Redistributions of source code must retain the above copyright
      8  *    notice, this list of conditions and the following disclaimer.
      9  * 2. Redistributions in binary form must reproduce the above copyright
     10  *    notice, this list of conditions and the following disclaimer in the
     11  *    documentation and/or other materials provided with the distribution.
     12  *
     13  * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS''
     14  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
     15  * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     16  * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS
     17  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     18  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     19  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     20  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     21  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     22  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
     23  * THE POSSIBILITY OF SUCH DAMAGE.
     24  */
     25 
     26 #include "config.h"
     27 #include "ChildProcess.h"
     28 
     29 #if !OS(WINDOWS)
     30 #include <unistd.h>
     31 #endif
     32 
     33 namespace WebKit {
     34 
     35 void ChildProcess::disableTermination()
     36 {
     37     m_terminationCounter++;
     38     m_terminationTimer.stop();
     39 }
     40 
     41 void ChildProcess::enableTermination()
     42 {
     43     ASSERT(m_terminationCounter > 0);
     44     m_terminationCounter--;
     45 
     46     if (m_terminationCounter)
     47         return;
     48 
     49     if (!m_terminationTimeout) {
     50         terminationTimerFired();
     51         return;
     52     }
     53 
     54     m_terminationTimer.startOneShot(m_terminationTimeout);
     55 }
     56 
     57 ChildProcess::ChildProcess(double terminationTimeout)
     58     : m_terminationTimeout(terminationTimeout)
     59     , m_terminationCounter(0)
     60     , m_terminationTimer(RunLoop::main(), this, &ChildProcess::terminationTimerFired)
     61 {
     62     // FIXME: The termination timer should not be scheduled on the main run loop.
     63     // It won't work with the threaded mode, but it's not really useful anyway as is.
     64 }
     65 
     66 ChildProcess::~ChildProcess()
     67 {
     68 }
     69 
     70 void ChildProcess::terminationTimerFired()
     71 {
     72     if (!shouldTerminate())
     73         return;
     74 
     75     terminate();
     76 }
     77 
     78 void ChildProcess::terminate()
     79 {
     80     RunLoop::main()->stop();
     81 }
     82 
     83 NO_RETURN static void watchdogCallback()
     84 {
     85     // We use _exit here since the watchdog callback is called from another thread and we don't want
     86     // global destructors or atexit handlers to be called from this thread while the main thread is busy
     87     // doing its thing.
     88     _exit(EXIT_FAILURE);
     89 }
     90 
     91 void ChildProcess::didCloseOnConnectionWorkQueue(WorkQueue& workQueue, CoreIPC::Connection*)
     92 {
     93     // If the connection has been closed and we haven't responded in the main thread for 10 seconds
     94     // the process will exit forcibly.
     95     static const double watchdogDelay = 10.0;
     96 
     97     workQueue.scheduleWorkAfterDelay(WorkItem::create(watchdogCallback), watchdogDelay);
     98 }
     99 
    100 } // namespace WebKit
    101