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

Unified Diff: runtime/lib/isolate.cc

Issue 10332257: Revert my last change. (Closed) Base URL: http://dart.googlecode.com/svn/branches/bleeding_edge/dart/
Patch Set: Created 8 years, 7 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « runtime/include/dart_api.h ('k') | runtime/lib/isolate.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: runtime/lib/isolate.cc
===================================================================
--- runtime/lib/isolate.cc (revision 7756)
+++ runtime/lib/isolate.cc (working copy)
@@ -239,20 +239,30 @@
}
-static char* GetRootScriptUri(Isolate* isolate) {
- const Library& library =
- Library::Handle(isolate->object_store()->root_library());
- ASSERT(!library.IsNull());
- const String& script_name = String::Handle(library.url());
- return isolate->current_zone()->MakeCopyOfString(script_name.ToCString());
-}
+static char* BuildIsolateName(const char* script_name,
+ const char* class_name,
+ const char* func_name) {
+ // Skip past any slashes in the script name.
+ const char* last_slash = strrchr(script_name, '/');
+ if (last_slash != NULL) {
+ script_name = last_slash + 1;
+ }
-
-static char* BuildMainName(const char* class_name) {
- intptr_t len = OS::SNPrint(NULL, 0, "%s.main", class_name) + 1;
- char* chars = reinterpret_cast<char*>(
- Isolate::Current()->current_zone()->Allocate(len));
- OS::SNPrint(chars, len, "%s.main", class_name);
+ char* chars = NULL;
+ if (class_name && class_name[0] != '\0') {
+ const char* kFormat = "%s/%s.%s";
+ intptr_t len = OS::SNPrint(NULL, 0, kFormat, script_name, class_name,
+ func_name) + 1;
+ chars = reinterpret_cast<char*>(
+ Isolate::Current()->current_zone()->Allocate(len));
+ OS::SNPrint(chars, len, kFormat, script_name, class_name, func_name);
+ } else {
+ const char* kFormat = "%s/%s";
+ intptr_t len = OS::SNPrint(NULL, 0, kFormat, script_name, func_name) + 1;
+ chars = reinterpret_cast<char*>(
+ Isolate::Current()->current_zone()->Allocate(len));
+ OS::SNPrint(chars, len, kFormat, script_name, func_name);
+ }
return chars;
}
@@ -273,11 +283,10 @@
void* callback_data = preserved_isolate->init_callback_data();
char* error = NULL;
Dart_IsolateCreateCallback callback = Isolate::CreateCallback();
- const char* root_script_uri = GetRootScriptUri(preserved_isolate);
- const char* main = BuildMainName(class_name);
+ const char* isolate_name = BuildIsolateName(library_url, class_name, "main");
if (callback == NULL) {
error = strdup("Null callback specified for isolate creation\n");
- } else if (callback(root_script_uri, main, callback_data, &error)) {
+ } else if (callback(isolate_name, callback_data, &error)) {
spawned_isolate = Isolate::Current();
ASSERT(spawned_isolate != NULL);
// Check arguments to see if the specified library and classes are
@@ -377,51 +386,12 @@
}
-static bool CanonicalizeUri(Isolate* isolate,
- const Library& library,
- const String& uri,
- char** canonical_uri,
- char** error) {
- Zone* zone = isolate->current_zone();
- Dart_LibraryTagHandler handler = isolate->library_tag_handler();
- if (handler == NULL) {
- *error = zone->PrintToString(
- "Unable to canonicalize uri '%s': no library tag handler found.",
- uri.ToCString());
- return false;
- }
- Dart_Handle result = handler(kCanonicalizeUrl,
- Api::NewHandle(isolate, library.raw()),
- Api::NewHandle(isolate, uri.raw()));
- const Object& obj = Object::Handle(Api::UnwrapHandle(result));
- if (obj.IsError()) {
- Error& error_obj = Error::Handle();
- error_obj ^= obj.raw();
- *error = zone->PrintToString("Unable to canonicalize uri '%s': %s",
- uri.ToCString(), error_obj.ToErrorCString());
- return false;
- } else if (obj.IsString()) {
- String& string_obj = String::Handle();
- string_obj ^= obj.raw();
- *canonical_uri = zone->MakeCopyOfString(string_obj.ToCString());
- return true;
- } else {
- *error = zone->PrintToString("Unable to canonicalize uri '%s': "
- "library tag handler returned wrong type",
- uri.ToCString());
- return false;
- }
-}
-
-
class SpawnState {
public:
explicit SpawnState(const Function& func)
: isolate_(NULL),
- script_url_(NULL),
library_url_(NULL),
function_name_(NULL) {
- script_url_ = strdup(GetRootScriptUri(Isolate::Current()));
const Class& cls = Class::Handle(func.owner());
ASSERT(cls.IsTopLevel());
const Library& lib = Library::Handle(cls.library());
@@ -432,54 +402,27 @@
function_name_ = strdup(func_name.ToCString());
}
- explicit SpawnState(const char* script_url)
- : isolate_(NULL),
- library_url_(NULL),
- function_name_(NULL) {
- script_url_ = strdup(script_url);
- library_url_ = NULL;
- function_name_ = strdup("main");
- }
-
~SpawnState() {
- free(script_url_);
free(library_url_);
free(function_name_);
}
Isolate* isolate() const { return isolate_; }
void set_isolate(Isolate* value) { isolate_ = value; }
- char* script_url() const { return script_url_; }
char* library_url() const { return library_url_; }
char* function_name() const { return function_name_; }
- RawObject* ResolveFunction() {
- // Resolve the library.
- Library& lib = Library::Handle();
- if (library_url()) {
- const String& lib_url = String::Handle(String::New(library_url()));
- lib = Library::LookupLibrary(lib_url);
- if (lib.IsNull() || lib.IsError()) {
- const String& msg = String::Handle(String::NewFormatted(
- "Unable to find library '%s'.", library_url()));
- return LanguageError::New(msg);
- }
- } else {
- lib = isolate()->object_store()->root_library();
- }
- ASSERT(!lib.IsNull());
-
- // Resolve the function.
+ RawFunction* ResolveFunction() {
+ const String& lib_url =
+ String::Handle(String::NewSymbol(library_url()));
const String& func_name =
- String::Handle(String::New(function_name()));
- const Function& func = Function::Handle(lib.LookupLocalFunction(func_name));
- if (func.IsNull()) {
- const String& msg = String::Handle(String::NewFormatted(
- "Unable to resolve function '%s' in library '%s'.",
- function_name(), (library_url() ? library_url() : script_url())));
- return LanguageError::New(msg);
+ String::Handle(String::NewSymbol(function_name()));
+
+ const Library& lib = Library::Handle(Library::LookupLibrary(lib_url));
+ if (lib.IsNull() || lib.IsError()) {
+ return Function::null();
}
- return func.raw();
+ return lib.LookupLocalFunction(func_name);
}
void Cleanup() {
@@ -489,7 +432,6 @@
private:
Isolate* isolate_;
- char* script_url_;
char* library_url_;
char* function_name_;
};
@@ -499,45 +441,40 @@
Isolate* parent_isolate = Isolate::Current();
Dart_IsolateCreateCallback callback = Isolate::CreateCallback();
- ASSERT(callback != NULL);
+ ASSERT(callback);
+ const char* isolate_name = BuildIsolateName(state->library_url(),
+ "",
+ state->function_name());
void* init_data = parent_isolate->init_callback_data();
- bool retval = (callback)(state->script_url(),
- state->function_name(),
- init_data,
- error);
- if (!retval) {
- Isolate::SetCurrent(parent_isolate);
- return false;
- }
+ bool retval = (callback)(isolate_name, init_data, error);
+ if (retval) {
+ Isolate* child_isolate = Isolate::Current();
+ ASSERT(child_isolate);
+ state->set_isolate(child_isolate);
- Isolate* child_isolate = Isolate::Current();
- ASSERT(child_isolate);
- state->set_isolate(child_isolate);
-
- // Attempt to resolve the entry function now, so that we fail fast
- // in the case that the function cannot be resolved.
- //
- // TODO(turnidge): Revisit this once we have an isolate death api.
- bool resolve_error = false;
- {
- Zone zone(child_isolate);
- HandleScope handle_scope(child_isolate);
- const Object& result = Object::Handle(state->ResolveFunction());
- if (result.IsError()) {
- Error& errobj = Error::Handle();
- errobj ^= result.raw();
- *error = strdup(errobj.ToErrorCString());
- resolve_error = true;
+ // Attempt to resolve the entry function now, so that we fail fast
+ // in the case that the embedder's isolate create callback is
+ // violating its contract.
+ //
+ // TODO(turnidge): Revisit this once we have an isolate death api.
+ {
+ Zone zone(child_isolate);
+ HandleScope handle_scope(child_isolate);
+ const Function& func = Function::Handle(state->ResolveFunction());
+ if (func.IsNull()) {
+ *error = strdup(zone.PrintToString(
+ "Internal error while starting isolate '%s': "
+ "unable to resolve entry function '%s'.",
+ child_isolate->name(), state->function_name()));
+ retval = false;
+ }
}
}
- if (resolve_error) {
+ if (!retval) {
Dart::ShutdownIsolate();
- Isolate::SetCurrent(parent_isolate);
- return false;
}
-
Isolate::SetCurrent(parent_isolate);
- return true;
+ return retval;
}
@@ -552,16 +489,11 @@
ASSERT(ClassFinalizer::FinalizePendingClasses());
Object& result = Object::Handle();
- result = state->ResolveFunction();
+ const Function& func = Function::Handle(state->ResolveFunction());
delete state;
state = NULL;
- if (result.IsError()) {
- StoreError(isolate, result);
- return false;
- }
- ASSERT(result.IsFunction());
- Function& func = Function::Handle(isolate);
- func ^= result.raw();
+ ASSERT(!func.IsNull());
+
GrowableArray<const Object*> args(0);
const Array& kNoArgNames = Array::Handle();
result = DartEntry::InvokeStatic(func, args, kNoArgNames);
@@ -574,13 +506,28 @@
}
-static void Spawn(NativeArguments* arguments, SpawnState* state) {
+DEFINE_NATIVE_ENTRY(isolate_spawnFunction, 1) {
+ GET_NATIVE_ARGUMENT(Closure, closure, arguments->At(0));
+ const Function& func = Function::Handle(closure.function());
+ const Class& cls = Class::Handle(func.owner());
+ if (!func.IsClosureFunction() || !func.is_static() || !cls.IsTopLevel()) {
+ const String& msg = String::Handle(String::New(
+ "spawnFunction expects to be passed a closure to a top-level static "
+ "function"));
+ ThrowIllegalArgException(msg);
+ }
+
+#if defined(DEBUG)
+ const Context& ctx = Context::Handle(closure.context());
+ ASSERT(ctx.num_variables() == 0);
+#endif
+
// Create a new isolate.
char* error = NULL;
+ SpawnState* state = new SpawnState(func);
if (!CreateIsolate(state, &error)) {
delete state;
const String& msg = String::Handle(String::New(error));
- free(error);
ThrowIsolateSpawnException(msg);
}
@@ -603,45 +550,6 @@
}
-DEFINE_NATIVE_ENTRY(isolate_spawnFunction, 1) {
- GET_NATIVE_ARGUMENT(Closure, closure, arguments->At(0));
- const Function& func = Function::Handle(closure.function());
- const Class& cls = Class::Handle(func.owner());
- if (!func.IsClosureFunction() || !func.is_static() || !cls.IsTopLevel()) {
- const String& msg = String::Handle(String::New(
- "spawnFunction expects to be passed a closure to a top-level static "
- "function"));
- ThrowIllegalArgException(msg);
- }
-
-#if defined(DEBUG)
- const Context& ctx = Context::Handle(closure.context());
- ASSERT(ctx.num_variables() == 0);
-#endif
-
- Spawn(arguments, new SpawnState(func));
-}
-
-
-DEFINE_NATIVE_ENTRY(isolate_spawnUri, 1) {
- GET_NATIVE_ARGUMENT(String, uri, arguments->At(0));
-
- // Canonicalize the uri with respect to the current isolate.
- char* error = NULL;
- char* canonical_uri = NULL;
- const Library& root_lib =
- Library::Handle(arguments->isolate()->object_store()->root_library());
- if (!CanonicalizeUri(arguments->isolate(), root_lib, uri,
- &canonical_uri, &error)) {
- const String& msg = String::Handle(String::New(error));
- free(error);
- ThrowIsolateSpawnException(msg);
- }
-
- Spawn(arguments, new SpawnState(canonical_uri));
-}
-
-
DEFINE_NATIVE_ENTRY(isolate_getPortInternal, 0) {
const Object& port = Object::Handle(ReceivePortCreate(isolate->main_port()));
if (port.IsError()) {
« no previous file with comments | « runtime/include/dart_api.h ('k') | runtime/lib/isolate.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698