Run all directory async operations on a separate thread using native ports

runtime/bin/directory.cc

Index: runtime/bin/directory.cc
diff --git a/runtime/bin/directory.cc b/runtime/bin/directory.cc
index 534fc3c200b612cf4265b536435c8e94c5042102..31bbddbc86a22e5a8acfb26b0f5fe8ab9ce9fe9c 100644
--- a/runtime/bin/directory.cc
+++ b/runtime/bin/directory.cc
@@ -8,38 +8,6 @@
 #include "include/dart_api.h"
 #include "platform/assert.h"
 
-static intptr_t GetHandlerPort(Dart_Handle handle) {
-  if (Dart_IsNull(handle)) {
-    return 0;
-  }
-  return DartUtils::GetIntegerInstanceField(handle, DartUtils::kIdFieldName);
-}
-
-
-void FUNCTION_NAME(Directory_List)(Dart_NativeArguments args) {
-  Dart_EnterScope();
-  Dart_Handle path = Dart_GetNativeArgument(args, 1);
-  Dart_Handle recursive = Dart_GetNativeArgument(args, 2);
-  Dart_Port dir_port = GetHandlerPort(Dart_GetNativeArgument(args, 3));
-  Dart_Port file_port = GetHandlerPort(Dart_GetNativeArgument(args, 4));
-  Dart_Port done_port = GetHandlerPort(Dart_GetNativeArgument(args, 5));
-  Dart_Port error_port =
-      GetHandlerPort(Dart_GetNativeArgument(args, 6));
-  if (!Dart_IsString(path) || !Dart_IsBoolean(recursive)) {
-    Dart_SetReturnValue(args, Dart_NewBoolean(false));
-  } else {
-    Directory::List(DartUtils::GetStringValue(path),
-                    DartUtils::GetBooleanValue(recursive),
-                    dir_port,
-                    file_port,
-                    done_port,
-                    error_port);
-    Dart_SetReturnValue(args, Dart_NewBoolean(true));
-  }
-  Dart_ExitScope();
-}
-
-
 void FUNCTION_NAME(Directory_Exists)(Dart_NativeArguments args) {
   static const int kError = -1;
   static const int kExists = 1;
@@ -131,3 +99,180 @@ void FUNCTION_NAME(Directory_Delete)(Dart_NativeArguments args) {
   }
   Dart_ExitScope();
 }
+
+
+static CObject* DirectoryCreateRequest(const CObjectArray& request) {
+  if (request.Length() == 2 && request[1]->IsString()) {
+    CObjectString path(request[1]);
+    bool created = Directory::Create(path.CString());
+    return CObject::Bool(created);
+  }
+  return CObject::False();
+}
+
+
+static CObject* DirectoryDeleteRequest(const CObjectArray& request) {
+  if (request.Length() == 3 && request[1]->IsString() && request[2]->IsBool()) {
+    CObjectString path(request[1]);
+    CObjectBool recursive(request[2]);
+    bool deleted = Directory::Delete(path.CString(), recursive.Value());
+    return CObject::Bool(deleted);
+  }
+  return CObject::False();
+}
+
+
+static CObject* DirectoryExistsRequest(const CObjectArray& request) {
+  static const int kError = -1;
+  static const int kExists = 1;
+  static const int kDoesNotExist = 0;
+  if (request.Length() == 2 && request[1]->IsString()) {
+    CObjectString path(request[1]);
+    Directory::ExistsResult result = Directory::Exists(path.CString());
+    int return_value = kError;
+    if (result == Directory::EXISTS) {
+      return_value = kExists;
+    }
+    if (result == Directory::DOES_NOT_EXIST) {
+      return_value = kDoesNotExist;
+    }
+    return new CObjectInt32(CObject::NewInt32(return_value));
+  }
+  return new CObjectInt32(CObject::NewInt32(kDoesNotExist));
+}
+
+
+static CObject* DirectoryCreateTempRequest(const CObjectArray& request) {
+  if (request.Length() == 2 && request[1]->IsString()) {
+    CObjectString path(request[1]);
+
+    static const int kMaxChildOsErrorMessageLength = 256;
+    char os_error_message[kMaxChildOsErrorMessageLength];
+    char* result = NULL;
+    int error_code = Directory::CreateTemp(path.CString(),
+                                           &result,
+                                           os_error_message,
+                                           kMaxChildOsErrorMessageLength);
+    if (error_code == 0) {
+      CObject* temp_dir = new CObjectString(CObject::NewString(result));
+      free(result);
+      return temp_dir;
+    } else {
+      ASSERT(result == NULL);
+      CObjectArray* error_response = new CObjectArray(CObject::NewArray(2));
+      if (error_code == -1) {
+        error_response->SetAt(0, new CObjectInt32(CObject::NewInt32(0)));
+        error_response->SetAt(
+            1, new CObjectString(CObject::NewString("Invalid arguments")));
+      } else {
+        error_response->SetAt(
+            0, new CObjectInt32(CObject::NewInt32(error_code)));
+        error_response->SetAt(
+            1, new CObjectString(CObject::NewString(os_error_message)));
+      }
+      return error_response;
+    }
+  }
+  return CObject::False();
+}
+
+
+static CObject* DirectoryListRequest(const CObjectArray& request,
+                                     Dart_Port response_port) {
+  if (request.Length() == 3 && request[1]->IsString() && request[2]->IsBool()) {
+    DirectoryListing* dir_listing = new DirectoryListing(response_port);
+    CObjectString path(request[1]);
+    CObjectBool recursive(request[2]);
+    bool completed = Directory::List(
+        path.CString(), recursive.Value(), dir_listing);
+    delete dir_listing;
+    CObjectArray* response = new CObjectArray(CObject::NewArray(2));
+    response->SetAt(
+        0, new CObjectInt32(CObject::NewInt32(DirectoryListing::kListDone)));
+    response->SetAt(1, CObject::Bool(completed));
+    return response;
+  }
+  return CObject::False();
+}
+
+
+void DirectoryService(Dart_Port dest_port_id,
+                      Dart_Port reply_port_id,
+                      Dart_CObject* message) {
+  CObject* response = CObject::False();
+  CObjectArray request(message);
+  if (message->type == Dart_CObject::kArray) {
+    if (request.Length() > 1 && request[0]->IsInt32()) {
+      CObjectInt32 requestType(request[0]);
+      switch (requestType.Value()) {
+        case Directory::kCreateRequest:
+          response = DirectoryCreateRequest(request);
+          break;
+        case Directory::kDeleteRequest:
+          response = DirectoryDeleteRequest(request);
+          break;
+        case Directory::kExistsRequest:
+          response = DirectoryExistsRequest(request);
+          break;
+        case Directory::kCreateTempRequest:
+          response = DirectoryCreateTempRequest(request);
+          break;
+        case Directory::kListRequest:
+          response = DirectoryListRequest(request, reply_port_id);
+          break;
+        default:
+          UNREACHABLE();
+      }
+    }
+  }
+
+  Dart_PostCObject(reply_port_id, response->AsApiCObject());
+}
+
+
+void FUNCTION_NAME(Directory_NewServicePort)(Dart_NativeArguments args) {
+  Dart_EnterScope();
+  Dart_SetReturnValue(args, Dart_Null());
+  Dart_Port service_port = kIllegalPort;
+  service_port = Dart_NewNativePort("DirectoryService",
+                                    DirectoryService,
+                                    true);
+  if (service_port != kIllegalPort) {
+    // Return a send port for the service port.
+    Dart_Handle send_port = Dart_NewSendPort(service_port);
+    Dart_SetReturnValue(args, send_port);
+  }
+  Dart_ExitScope();
+}
+
+
+CObjectArray* DirectoryListing::NewResponse(Response type, char* arg) {
+  CObjectArray* response = new CObjectArray(CObject::NewArray(2));
+  response->SetAt(0, new CObjectInt32(CObject::NewInt32(type)));
+  response->SetAt(1, new CObjectString(CObject::NewString(arg)));
+  return response;
+}
+
+
+bool DirectoryListing::HandleDirectory(char* dir_name) {
+  // TODO(sgjesse): Pass flags to indicate whether directory
+  // responses are needed.
+  CObjectArray* response = NewResponse(kListDirectory, dir_name);
+  return Dart_PostCObject(response_port_, response->AsApiCObject());
+}
+
+
+bool DirectoryListing::HandleFile(char* file_name) {
+  // TODO(sgjesse): Pass flags to indicate whether file
+  // responses are needed.
+  CObjectArray* response = NewResponse(kListFile, file_name);
+  return Dart_PostCObject(response_port_, response->AsApiCObject());
+}
+
+
+bool DirectoryListing::HandleError(char* message) {
+  // TODO(sgjesse): Pass flags to indicate whether error
+  // responses are needed.
+  CObjectArray* response = NewResponse(kListError, message);
+  return Dart_PostCObject(response_port_, response->AsApiCObject());
+}