Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(16)

Side by Side Diff: test/cctest/test-thread-termination.cc

Issue 6685088: Merge isolates to bleeding_edge. (Closed) Base URL: http://v8.googlecode.com/svn/branches/bleeding_edge/
Patch Set: '' Created 9 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « test/cctest/test-strings.cc ('k') | test/cctest/test-threads.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2009 the V8 project authors. All rights reserved. 1 // Copyright 2009 the V8 project authors. All rights reserved.
2 // Redistribution and use in source and binary forms, with or without 2 // Redistribution and use in source and binary forms, with or without
3 // modification, are permitted provided that the following conditions are 3 // modification, are permitted provided that the following conditions are
4 // met: 4 // met:
5 // 5 //
6 // * Redistributions of source code must retain the above copyright 6 // * Redistributions of source code must retain the above copyright
7 // notice, this list of conditions and the following disclaimer. 7 // notice, this list of conditions and the following disclaimer.
8 // * Redistributions in binary form must reproduce the above 8 // * Redistributions in binary form must reproduce the above
9 // copyright notice, this list of conditions and the following 9 // copyright notice, this list of conditions and the following
10 // disclaimer in the documentation and/or other materials provided 10 // disclaimer in the documentation and/or other materials provided
(...skipping 141 matching lines...) Expand 10 before | Expand all | Expand 10 after
152 v8::String::New("try { loop(); fail(); } catch(e) { fail(); }"); 152 v8::String::New("try { loop(); fail(); } catch(e) { fail(); }");
153 v8::Script::Compile(source)->Run(); 153 v8::Script::Compile(source)->Run();
154 CHECK(!v8::V8::IsExecutionTerminating()); 154 CHECK(!v8::V8::IsExecutionTerminating());
155 // Test that we can run the code again after thread termination. 155 // Test that we can run the code again after thread termination.
156 v8::Script::Compile(source)->Run(); 156 v8::Script::Compile(source)->Run();
157 context.Dispose(); 157 context.Dispose();
158 } 158 }
159 159
160 160
161 class TerminatorThread : public v8::internal::Thread { 161 class TerminatorThread : public v8::internal::Thread {
162 public:
163 explicit TerminatorThread(i::Isolate* isolate) : Thread(isolate) { }
162 void Run() { 164 void Run() {
163 semaphore->Wait(); 165 semaphore->Wait();
164 CHECK(!v8::V8::IsExecutionTerminating()); 166 CHECK(!v8::V8::IsExecutionTerminating());
165 v8::V8::TerminateExecution(); 167 v8::V8::TerminateExecution();
166 } 168 }
167 }; 169 };
168 170
169 171
170 // Test that a single thread of JavaScript execution can be terminated 172 // Test that a single thread of JavaScript execution can be terminated
171 // from the side by another thread. 173 // from the side by another thread.
172 TEST(TerminateOnlyV8ThreadFromOtherThread) { 174 TEST(TerminateOnlyV8ThreadFromOtherThread) {
173 semaphore = v8::internal::OS::CreateSemaphore(0); 175 semaphore = v8::internal::OS::CreateSemaphore(0);
174 TerminatorThread thread; 176 TerminatorThread thread(i::Isolate::Current());
175 thread.Start(); 177 thread.Start();
176 178
177 v8::HandleScope scope; 179 v8::HandleScope scope;
178 v8::Handle<v8::ObjectTemplate> global = CreateGlobalTemplate(Signal, DoLoop); 180 v8::Handle<v8::ObjectTemplate> global = CreateGlobalTemplate(Signal, DoLoop);
179 v8::Persistent<v8::Context> context = v8::Context::New(NULL, global); 181 v8::Persistent<v8::Context> context = v8::Context::New(NULL, global);
180 v8::Context::Scope context_scope(context); 182 v8::Context::Scope context_scope(context);
181 CHECK(!v8::V8::IsExecutionTerminating()); 183 CHECK(!v8::V8::IsExecutionTerminating());
182 // Run a loop that will be infinite if thread termination does not work. 184 // Run a loop that will be infinite if thread termination does not work.
183 v8::Handle<v8::String> source = 185 v8::Handle<v8::String> source =
184 v8::String::New("try { loop(); fail(); } catch(e) { fail(); }"); 186 v8::String::New("try { loop(); fail(); } catch(e) { fail(); }");
185 v8::Script::Compile(source)->Run(); 187 v8::Script::Compile(source)->Run();
186 188
187 thread.Join(); 189 thread.Join();
188 delete semaphore; 190 delete semaphore;
189 semaphore = NULL; 191 semaphore = NULL;
190 context.Dispose(); 192 context.Dispose();
191 } 193 }
192 194
193 195
194 class LoopingThread : public v8::internal::Thread { 196 class LoopingThread : public v8::internal::Thread {
195 public: 197 public:
198 explicit LoopingThread(i::Isolate* isolate) : Thread(isolate) { }
196 void Run() { 199 void Run() {
197 v8::Locker locker; 200 v8::Locker locker;
198 v8::HandleScope scope; 201 v8::HandleScope scope;
199 v8_thread_id_ = v8::V8::GetCurrentThreadId(); 202 v8_thread_id_ = v8::V8::GetCurrentThreadId();
200 v8::Handle<v8::ObjectTemplate> global = 203 v8::Handle<v8::ObjectTemplate> global =
201 CreateGlobalTemplate(Signal, DoLoop); 204 CreateGlobalTemplate(Signal, DoLoop);
202 v8::Persistent<v8::Context> context = v8::Context::New(NULL, global); 205 v8::Persistent<v8::Context> context = v8::Context::New(NULL, global);
203 v8::Context::Scope context_scope(context); 206 v8::Context::Scope context_scope(context);
204 CHECK(!v8::V8::IsExecutionTerminating()); 207 CHECK(!v8::V8::IsExecutionTerminating());
205 // Run a loop that will be infinite if thread termination does not work. 208 // Run a loop that will be infinite if thread termination does not work.
(...skipping 12 matching lines...) Expand all
218 221
219 // Test that multiple threads using V8 can be terminated from another 222 // Test that multiple threads using V8 can be terminated from another
220 // thread when using Lockers and preemption. 223 // thread when using Lockers and preemption.
221 TEST(TerminateMultipleV8Threads) { 224 TEST(TerminateMultipleV8Threads) {
222 { 225 {
223 v8::Locker locker; 226 v8::Locker locker;
224 v8::V8::Initialize(); 227 v8::V8::Initialize();
225 v8::Locker::StartPreemption(1); 228 v8::Locker::StartPreemption(1);
226 semaphore = v8::internal::OS::CreateSemaphore(0); 229 semaphore = v8::internal::OS::CreateSemaphore(0);
227 } 230 }
228 LoopingThread thread1; 231 LoopingThread thread1(i::Isolate::Current());
229 thread1.Start(); 232 thread1.Start();
230 LoopingThread thread2; 233 LoopingThread thread2(i::Isolate::Current());
231 thread2.Start(); 234 thread2.Start();
232 // Wait until both threads have signaled the semaphore. 235 // Wait until both threads have signaled the semaphore.
233 semaphore->Wait(); 236 semaphore->Wait();
234 semaphore->Wait(); 237 semaphore->Wait();
235 { 238 {
236 v8::Locker locker; 239 v8::Locker locker;
237 v8::V8::TerminateExecution(thread1.GetV8ThreadId()); 240 v8::V8::TerminateExecution(thread1.GetV8ThreadId());
238 v8::V8::TerminateExecution(thread2.GetV8ThreadId()); 241 v8::V8::TerminateExecution(thread2.GetV8ThreadId());
239 } 242 }
240 thread1.Join(); 243 thread1.Join();
(...skipping 105 matching lines...) Expand 10 before | Expand all | Expand 10 after
346 v8::Handle<v8::String> source = 349 v8::Handle<v8::String> source =
347 v8::String::New("try { loop(); fail(); } catch(e) { fail(); }"); 350 v8::String::New("try { loop(); fail(); } catch(e) { fail(); }");
348 v8::Script::Compile(source)->Run(); 351 v8::Script::Compile(source)->Run();
349 CHECK(!v8::V8::IsExecutionTerminating()); 352 CHECK(!v8::V8::IsExecutionTerminating());
350 // Check we can run JS again after termination. 353 // Check we can run JS again after termination.
351 CHECK(v8::Script::Compile(v8::String::New("function f() { return true; }" 354 CHECK(v8::Script::Compile(v8::String::New("function f() { return true; }"
352 "f()"))->Run()->IsTrue()); 355 "f()"))->Run()->IsTrue());
353 context.Dispose(); 356 context.Dispose();
354 } 357 }
355 358
OLDNEW
« no previous file with comments | « test/cctest/test-strings.cc ('k') | test/cctest/test-threads.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698