mirror of https://github.com/lukechilds/node.git
Ryan
16 years ago
33 changed files with 726 additions and 145 deletions
@ -0,0 +1,195 @@ |
|||
// Copyright 2009 the V8 project authors. All rights reserved.
|
|||
// Redistribution and use in source and binary forms, with or without
|
|||
// modification, are permitted provided that the following conditions are
|
|||
// met:
|
|||
//
|
|||
// * Redistributions of source code must retain the above copyright
|
|||
// notice, this list of conditions and the following disclaimer.
|
|||
// * Redistributions in binary form must reproduce the above
|
|||
// copyright notice, this list of conditions and the following
|
|||
// disclaimer in the documentation and/or other materials provided
|
|||
// with the distribution.
|
|||
// * Neither the name of Google Inc. nor the names of its
|
|||
// contributors may be used to endorse or promote products derived
|
|||
// from this software without specific prior written permission.
|
|||
//
|
|||
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
|||
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
|||
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
|||
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
|||
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|||
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
|||
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|||
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|||
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|||
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
|||
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|||
|
|||
#include "v8.h" |
|||
#include "platform.h" |
|||
#include "cctest.h" |
|||
|
|||
|
|||
v8::internal::Semaphore* semaphore = NULL; |
|||
|
|||
|
|||
v8::Handle<v8::Value> Signal(const v8::Arguments& args) { |
|||
semaphore->Signal(); |
|||
return v8::Undefined(); |
|||
} |
|||
|
|||
|
|||
v8::Handle<v8::Value> TerminateCurrentThread(const v8::Arguments& args) { |
|||
v8::V8::TerminateExecution(); |
|||
return v8::Undefined(); |
|||
} |
|||
|
|||
|
|||
v8::Handle<v8::Value> Fail(const v8::Arguments& args) { |
|||
CHECK(false); |
|||
return v8::Undefined(); |
|||
} |
|||
|
|||
|
|||
v8::Handle<v8::Value> Loop(const v8::Arguments& args) { |
|||
v8::Handle<v8::String> source = |
|||
v8::String::New("try { doloop(); fail(); } catch(e) { fail(); }"); |
|||
v8::Script::Compile(source)->Run(); |
|||
return v8::Undefined(); |
|||
} |
|||
|
|||
|
|||
v8::Handle<v8::Value> DoLoop(const v8::Arguments& args) { |
|||
v8::TryCatch try_catch; |
|||
v8::Script::Compile(v8::String::New("function f() {" |
|||
" var term = true;" |
|||
" try {" |
|||
" while(true) {" |
|||
" if (term) terminate();" |
|||
" term = false;" |
|||
" }" |
|||
" fail();" |
|||
" } catch(e) {" |
|||
" fail();" |
|||
" }" |
|||
"}" |
|||
"f()"))->Run(); |
|||
CHECK(try_catch.HasCaught()); |
|||
CHECK(try_catch.Exception()->IsNull()); |
|||
CHECK(try_catch.Message().IsEmpty()); |
|||
CHECK(!try_catch.CanContinue()); |
|||
return v8::Undefined(); |
|||
} |
|||
|
|||
|
|||
v8::Handle<v8::ObjectTemplate> CreateGlobalTemplate( |
|||
v8::InvocationCallback terminate) { |
|||
v8::Handle<v8::ObjectTemplate> global = v8::ObjectTemplate::New(); |
|||
global->Set(v8::String::New("terminate"), |
|||
v8::FunctionTemplate::New(terminate)); |
|||
global->Set(v8::String::New("fail"), v8::FunctionTemplate::New(Fail)); |
|||
global->Set(v8::String::New("loop"), v8::FunctionTemplate::New(Loop)); |
|||
global->Set(v8::String::New("doloop"), v8::FunctionTemplate::New(DoLoop)); |
|||
return global; |
|||
} |
|||
|
|||
|
|||
// Test that a single thread of JavaScript execution can terminate
|
|||
// itself.
|
|||
TEST(TerminateOnlyV8ThreadFromThreadItself) { |
|||
v8::HandleScope scope; |
|||
v8::Handle<v8::ObjectTemplate> global = |
|||
CreateGlobalTemplate(TerminateCurrentThread); |
|||
v8::Persistent<v8::Context> context = v8::Context::New(NULL, global); |
|||
v8::Context::Scope context_scope(context); |
|||
// Run a loop that will be infinite if thread termination does not work.
|
|||
v8::Handle<v8::String> source = |
|||
v8::String::New("try { loop(); fail(); } catch(e) { fail(); }"); |
|||
v8::Script::Compile(source)->Run(); |
|||
// Test that we can run the code again after thread termination.
|
|||
v8::Script::Compile(source)->Run(); |
|||
context.Dispose(); |
|||
} |
|||
|
|||
|
|||
class TerminatorThread : public v8::internal::Thread { |
|||
void Run() { |
|||
semaphore->Wait(); |
|||
v8::V8::TerminateExecution(); |
|||
} |
|||
}; |
|||
|
|||
|
|||
// Test that a single thread of JavaScript execution can be terminated
|
|||
// from the side by another thread.
|
|||
TEST(TerminateOnlyV8ThreadFromOtherThread) { |
|||
semaphore = v8::internal::OS::CreateSemaphore(0); |
|||
TerminatorThread thread; |
|||
thread.Start(); |
|||
|
|||
v8::HandleScope scope; |
|||
v8::Handle<v8::ObjectTemplate> global = CreateGlobalTemplate(Signal); |
|||
v8::Persistent<v8::Context> context = v8::Context::New(NULL, global); |
|||
v8::Context::Scope context_scope(context); |
|||
// Run a loop that will be infinite if thread termination does not work.
|
|||
v8::Handle<v8::String> source = |
|||
v8::String::New("try { loop(); fail(); } catch(e) { fail(); }"); |
|||
v8::Script::Compile(source)->Run(); |
|||
|
|||
thread.Join(); |
|||
delete semaphore; |
|||
semaphore = NULL; |
|||
context.Dispose(); |
|||
} |
|||
|
|||
|
|||
class LoopingThread : public v8::internal::Thread { |
|||
public: |
|||
void Run() { |
|||
v8::Locker locker; |
|||
v8::HandleScope scope; |
|||
v8_thread_id_ = v8::V8::GetCurrentThreadId(); |
|||
v8::Handle<v8::ObjectTemplate> global = CreateGlobalTemplate(Signal); |
|||
v8::Persistent<v8::Context> context = v8::Context::New(NULL, global); |
|||
v8::Context::Scope context_scope(context); |
|||
// Run a loop that will be infinite if thread termination does not work.
|
|||
v8::Handle<v8::String> source = |
|||
v8::String::New("try { loop(); fail(); } catch(e) { fail(); }"); |
|||
v8::Script::Compile(source)->Run(); |
|||
context.Dispose(); |
|||
} |
|||
|
|||
int GetV8ThreadId() { return v8_thread_id_; } |
|||
|
|||
private: |
|||
int v8_thread_id_; |
|||
}; |
|||
|
|||
|
|||
// Test that multiple threads using V8 can be terminated from another
|
|||
// thread when using Lockers and preemption.
|
|||
TEST(TerminateMultipleV8Threads) { |
|||
{ |
|||
v8::Locker locker; |
|||
v8::V8::Initialize(); |
|||
v8::Locker::StartPreemption(1); |
|||
semaphore = v8::internal::OS::CreateSemaphore(0); |
|||
} |
|||
LoopingThread thread1; |
|||
thread1.Start(); |
|||
LoopingThread thread2; |
|||
thread2.Start(); |
|||
// Wait until both threads have signaled the semaphore.
|
|||
semaphore->Wait(); |
|||
semaphore->Wait(); |
|||
{ |
|||
v8::Locker locker; |
|||
v8::V8::TerminateExecution(thread1.GetV8ThreadId()); |
|||
v8::V8::TerminateExecution(thread2.GetV8ThreadId()); |
|||
} |
|||
thread1.Join(); |
|||
thread2.Join(); |
|||
|
|||
delete semaphore; |
|||
semaphore = NULL; |
|||
} |
|||
Loading…
Reference in new issue