]>
Commit | Line | Data |
---|---|---|
ba379fdc A |
1 | /* |
2 | * Copyright (C) 2008, 2009 Apple Inc. All rights reserved. | |
3 | * Copyright (C) 2008 Cameron Zwarich <cwzwarich@uwaterloo.ca> | |
4 | * | |
5 | * Redistribution and use in source and binary forms, with or without | |
6 | * modification, are permitted provided that the following conditions | |
7 | * are met: | |
8 | * | |
9 | * 1. Redistributions of source code must retain the above copyright | |
10 | * notice, this list of conditions and the following disclaimer. | |
11 | * 2. Redistributions in binary form must reproduce the above copyright | |
12 | * notice, this list of conditions and the following disclaimer in the | |
13 | * documentation and/or other materials provided with the distribution. | |
14 | * 3. Neither the name of Apple Computer, Inc. ("Apple") nor the names of | |
15 | * its contributors may be used to endorse or promote products derived | |
16 | * from this software without specific prior written permission. | |
17 | * | |
18 | * THIS SOFTWARE IS PROVIDED BY APPLE AND ITS CONTRIBUTORS "AS IS" AND ANY | |
19 | * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED | |
20 | * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE | |
21 | * DISCLAIMED. IN NO EVENT SHALL APPLE OR ITS CONTRIBUTORS BE LIABLE FOR ANY | |
22 | * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES | |
23 | * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | |
24 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND | |
25 | * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | |
26 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF | |
27 | * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | |
28 | */ | |
29 | ||
30 | #include "config.h" | |
31 | #include "TimeoutChecker.h" | |
32 | ||
33 | #include "CallFrame.h" | |
34 | #include "JSGlobalObject.h" | |
35 | ||
36 | #if PLATFORM(DARWIN) | |
37 | #include <mach/mach.h> | |
38 | #endif | |
39 | ||
40 | #if HAVE(SYS_TIME_H) | |
41 | #include <sys/time.h> | |
42 | #endif | |
43 | ||
44 | #if PLATFORM(WIN_OS) | |
45 | #include <windows.h> | |
46 | #endif | |
47 | ||
48 | #if PLATFORM(QT) | |
49 | #include <QDateTime> | |
50 | #endif | |
51 | ||
52 | using namespace std; | |
53 | ||
54 | namespace JSC { | |
55 | ||
56 | // Number of ticks before the first timeout check is done. | |
57 | static const int ticksUntilFirstCheck = 1024; | |
58 | ||
59 | // Number of milliseconds between each timeout check. | |
60 | static const int intervalBetweenChecks = 1000; | |
61 | ||
62 | // Returns the time the current thread has spent executing, in milliseconds. | |
63 | static inline unsigned getCPUTime() | |
64 | { | |
65 | #if PLATFORM(DARWIN) | |
66 | mach_msg_type_number_t infoCount = THREAD_BASIC_INFO_COUNT; | |
67 | thread_basic_info_data_t info; | |
68 | ||
69 | // Get thread information | |
70 | mach_port_t threadPort = mach_thread_self(); | |
71 | thread_info(threadPort, THREAD_BASIC_INFO, reinterpret_cast<thread_info_t>(&info), &infoCount); | |
72 | mach_port_deallocate(mach_task_self(), threadPort); | |
73 | ||
74 | unsigned time = info.user_time.seconds * 1000 + info.user_time.microseconds / 1000; | |
75 | time += info.system_time.seconds * 1000 + info.system_time.microseconds / 1000; | |
76 | ||
77 | return time; | |
78 | #elif HAVE(SYS_TIME_H) | |
79 | // FIXME: This should probably use getrusage with the RUSAGE_THREAD flag. | |
80 | struct timeval tv; | |
81 | gettimeofday(&tv, 0); | |
82 | return tv.tv_sec * 1000 + tv.tv_usec / 1000; | |
83 | #elif PLATFORM(QT) | |
84 | QDateTime t = QDateTime::currentDateTime(); | |
85 | return t.toTime_t() * 1000 + t.time().msec(); | |
86 | #elif PLATFORM(WIN_OS) | |
87 | union { | |
88 | FILETIME fileTime; | |
89 | unsigned long long fileTimeAsLong; | |
90 | } userTime, kernelTime; | |
91 | ||
92 | // GetThreadTimes won't accept NULL arguments so we pass these even though | |
93 | // they're not used. | |
94 | FILETIME creationTime, exitTime; | |
95 | ||
96 | GetThreadTimes(GetCurrentThread(), &creationTime, &exitTime, &kernelTime.fileTime, &userTime.fileTime); | |
97 | ||
98 | return userTime.fileTimeAsLong / 10000 + kernelTime.fileTimeAsLong / 10000; | |
99 | #else | |
100 | #error Platform does not have getCurrentTime function | |
101 | #endif | |
102 | } | |
103 | ||
104 | TimeoutChecker::TimeoutChecker() | |
105 | : m_timeoutInterval(0) | |
106 | , m_startCount(0) | |
107 | { | |
108 | reset(); | |
109 | } | |
110 | ||
111 | void TimeoutChecker::reset() | |
112 | { | |
113 | m_ticksUntilNextCheck = ticksUntilFirstCheck; | |
114 | m_timeAtLastCheck = 0; | |
115 | m_timeExecuting = 0; | |
116 | } | |
117 | ||
118 | bool TimeoutChecker::didTimeOut(ExecState* exec) | |
119 | { | |
120 | unsigned currentTime = getCPUTime(); | |
121 | ||
122 | if (!m_timeAtLastCheck) { | |
123 | // Suspicious amount of looping in a script -- start timing it | |
124 | m_timeAtLastCheck = currentTime; | |
125 | return false; | |
126 | } | |
127 | ||
128 | unsigned timeDiff = currentTime - m_timeAtLastCheck; | |
129 | ||
130 | if (timeDiff == 0) | |
131 | timeDiff = 1; | |
132 | ||
133 | m_timeExecuting += timeDiff; | |
134 | m_timeAtLastCheck = currentTime; | |
135 | ||
136 | // Adjust the tick threshold so we get the next checkTimeout call in the | |
137 | // interval specified in intervalBetweenChecks. | |
138 | m_ticksUntilNextCheck = static_cast<unsigned>((static_cast<float>(intervalBetweenChecks) / timeDiff) * m_ticksUntilNextCheck); | |
139 | // If the new threshold is 0 reset it to the default threshold. This can happen if the timeDiff is higher than the | |
140 | // preferred script check time interval. | |
141 | if (m_ticksUntilNextCheck == 0) | |
142 | m_ticksUntilNextCheck = ticksUntilFirstCheck; | |
143 | ||
144 | if (exec->dynamicGlobalObject()->shouldInterruptScriptBeforeTimeout()) | |
145 | return true; | |
146 | ||
147 | if (m_timeoutInterval && m_timeExecuting > m_timeoutInterval) { | |
148 | if (exec->dynamicGlobalObject()->shouldInterruptScript()) | |
149 | return true; | |
150 | ||
151 | reset(); | |
152 | } | |
153 | ||
154 | return false; | |
155 | } | |
156 | ||
157 | } // namespace JSC |