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

runtime/bin/directory_posix.cc

 // Copyright (c) 2012, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 #include "bin/directory.h"
 
 #include <dirent.h>
 #include <errno.h>
 #include <sys/param.h>
 #include <sys/stat.h>
@@ skipping 12 matching lines @@
 
 static void SetOsErrorMessage(char* os_error_message,
                               int os_error_message_len) {
   SafeStrNCpy(os_error_message, strerror(errno), os_error_message_len);
 }
 
 
 // Forward declarations.
 static bool ListRecursively(const char* dir_name,
                             bool recursive,
-                            Dart_Port dir_port,
-                            Dart_Port file_port,
-                            Dart_Port done_port,
-                            Dart_Port error_port);
+                            DirectoryListing* listing);
 static bool DeleteRecursively(const char* dir_name);
 
 
 static bool ComputeFullPath(const char* dir_name,
                             char* path,
                             int* path_length) {
   char* abs_path;
   do {
     abs_path = realpath(dir_name, path);
   } while (abs_path == NULL && errno == EINTR);
@@ skipping 10 matching lines @@
   }
   *path_length += written;
   return true;
 }
 
 
 static bool HandleDir(char* dir_name,
                       char* path,
                       int path_length,
                       bool recursive,
-                      Dart_Port dir_port,
-                      Dart_Port file_port,
-                      Dart_Port done_port,
-                      Dart_Port error_port) {
+                      DirectoryListing *listing) {
   if (strcmp(dir_name, ".") != 0 &&
       strcmp(dir_name, "..") != 0) {
     size_t written = snprintf(path + path_length,
                               PATH_MAX - path_length,
                               "%s",
                               dir_name);
     if (written != strlen(dir_name)) {
       return false;
     }
-    if (dir_port != 0) {
-      Dart_Handle name = Dart_NewString(path);
-      Dart_Post(dir_port, name);
-    }
+    bool ok = listing->HandleDirectory(dir_name);
+    if (!ok) return ok;
     if (recursive) {
-      return ListRecursively(path,
-                             recursive,
-                             dir_port,
-                             file_port,
-                             done_port,
-                             error_port);
+      return ListRecursively(path, recursive, listing);
     }
   }
   return true;
 }
 
 
 static bool HandleFile(char* file_name,
                        char* path,
                        int path_length,
-                       Dart_Port file_port) {
-  if (file_port != 0) {
-    size_t written = snprintf(path + path_length,
-                              PATH_MAX - path_length,
-                              "%s",
-                              file_name);
-    if (written != strlen(file_name)) {
-      return false;
-    }
-    Dart_Handle name = Dart_NewString(path);
-    Dart_Post(file_port, name);
+                       DirectoryListing *listing) {
+  // TODO(sgjesse): Pass flags to indicate whether file responses are
+  // needed.
+  size_t written = snprintf(path + path_length,
+                            PATH_MAX - path_length,
+                            "%s",
+                            file_name);
+  if (written != strlen(file_name)) {
+    return false;
   }
-  return true;
+  return listing->HandleFile(path);
 }
 
 
-static void PostError(Dart_Port error_port,
+static void PostError(DirectoryListing *listing,
                       const char* prefix,
                       const char* suffix,
                       int error_code) {
-  if (error_port != 0) {
-    char* error_str = Platform::StrError(error_code);
-    int error_message_size =
-        strlen(prefix) + strlen(suffix) + strlen(error_str) + 3;
-    char* message = static_cast<char*>(malloc(error_message_size + 1));
-    int written = snprintf(message,
-                           error_message_size + 1,
-                           "%s%s (%s)",
-                           prefix,
-                           suffix,
-                           error_str);
-    ASSERT(written == error_message_size);
-    free(error_str);
-    Dart_Post(error_port, Dart_NewString(message));
-    free(message);
-  }
+  // TODO(sgjesse): Pass flags to indicate whether error response is
+  // needed.
+  char* error_str = Platform::StrError(error_code);
+  int error_message_size =
+      strlen(prefix) + strlen(suffix) + strlen(error_str) + 3;
+  char* message = static_cast<char*>(malloc(error_message_size + 1));
+  int written = snprintf(message,
+                         error_message_size + 1,
+                         "%s%s (%s)",
+                         prefix,
+                         suffix,
+                         error_str);
+  ASSERT(written == error_message_size);
+  free(error_str);
+  listing->HandleError(message);
+  free(message);
 }
 
 
 static bool ListRecursively(const char* dir_name,
                             bool recursive,
-                            Dart_Port dir_port,
-                            Dart_Port file_port,
-                            Dart_Port done_port,
-                            Dart_Port error_port) {
+                            DirectoryListing *listing) {
   DIR* dir_pointer;
   do {
     dir_pointer = opendir(dir_name);
   } while (dir_pointer == NULL && errno == EINTR);
   if (dir_pointer == NULL) {
-    PostError(error_port, "Directory listing failed for: ", dir_name, errno);
+    PostError(listing, "Directory listing failed for: ", dir_name, errno);
     return false;
   }
 
   // Compute full path for the directory currently being listed.  The
   // path buffer will be used to construct the current path in the
   // recursive traversal. path_length does not always equal
   // strlen(path) but indicates the current prefix of path that is the
   // path of the current directory in the traversal.
   char *path = static_cast<char*>(malloc(PATH_MAX));
   ASSERT(path != NULL);
   int path_length = 0;
   bool valid = ComputeFullPath(dir_name, path, &path_length);
   if (!valid) {
     free(path);
-    PostError(error_port, "Directory listing failed for: ", dir_name, errno);
+    PostError(listing, "Directory listing failed for: ", dir_name, errno);
     return false;
   }
 
   // Iterated the directory and post the directories and files to the
   // ports.
   int read = 0;
   bool success = true;
   dirent entry;
   dirent* result;
   while ((read = TEMP_FAILURE_RETRY(readdir_r(dir_pointer,
                                               &entry,
                                               &result))) == 0 &&
          result != NULL &&
          success) {
     switch (entry.d_type) {
       case DT_DIR:
         success = success && HandleDir(entry.d_name,
                                        path,
                                        path_length,
                                        recursive,
-                                       dir_port,
-                                       file_port,
-                                       done_port,
-                                       error_port);
+                                       listing);
         break;
       case DT_REG:
         success = success && HandleFile(entry.d_name,
                                         path,
                                         path_length,
-                                        file_port);
+                                        listing);
         break;
       case DT_UNKNOWN: {
         // On some file systems the entry type is not determined by
         // readdir_r. For those we use lstat to determine the entry
         // type.
         struct stat entry_info;
         size_t written = snprintf(path + path_length,
                                   PATH_MAX - path_length,
                                   "%s",
                                   entry.d_name);
         if (written != strlen(entry.d_name)) {
           success = false;
           break;
         }
         int lstat_success = TEMP_FAILURE_RETRY(lstat(path, &entry_info));
         if (lstat_success == -1) {
           success = false;
-          PostError(error_port, "Directory listing failed for: ", path, errno);
+          PostError(listing, "Directory listing failed for: ", path, errno);
           break;
         }
         if ((entry_info.st_mode & S_IFMT) == S_IFDIR) {
           success = success && HandleDir(entry.d_name,
                                          path,
                                          path_length,
                                          recursive,
-                                         dir_port,
-                                         file_port,
-                                         done_port,
-                                         error_port);
+                                         listing);
         } else if ((entry_info.st_mode & S_IFMT) == S_IFREG) {
           success = success && HandleFile(entry.d_name,
                                           path,
                                           path_length,
-                                          file_port);
+                                          listing);
         }
         break;
       }
       default:
         break;
     }
   }
 
   if (read != 0) {
     success = false;
-    PostError(error_port, "Directory listing failed", "", read);
+    PostError(listing, "Directory listing failed", "", read);
   }
 
   if (closedir(dir_pointer) == -1) {
-    PostError(error_port, "Failed to close directory", "", errno);
+    PostError(listing, "Failed to close directory", "", errno);
   }
   free(path);
 
   return success;
 }
 
 
 static bool DeleteFile(char* file_name,
                        char* path,
                        int path_length) {
@@ skipping 102 matching lines @@
   if ((read != 0) ||
       (closedir(dir_pointer) == -1) ||
       (remove(dir_name) == -1)) {
     return false;
   }
 
   return success;
 }
 
 
-void Directory::List(const char* dir_name,
+bool Directory::List(const char* dir_name,
                      bool recursive,
-                     Dart_Port dir_port,
-                     Dart_Port file_port,
-                     Dart_Port done_port,
-                     Dart_Port error_port) {
-  bool completed = ListRecursively(dir_name,
-                                   recursive,
-                                   dir_port,
-                                   file_port,
-                                   done_port,
-                                   error_port);
-  if (done_port != 0) {
-    Dart_Handle value = Dart_NewBoolean(completed);
-    Dart_Post(done_port, value);
-  }
+                     DirectoryListing *listing) {
+  bool completed = ListRecursively(dir_name, recursive, listing);
+  return completed;
 }
 
 
 Directory::ExistsResult Directory::Exists(const char* dir_name) {
   struct stat entry_info;
   int lstat_success = TEMP_FAILURE_RETRY(lstat(dir_name, &entry_info));
   if (lstat_success == 0) {
     if ((entry_info.st_mode & S_IFMT) == S_IFDIR) {
       return EXISTS;
     } else {
@@ skipping 60 matching lines @@
 }
 
 
 bool Directory::Delete(const char* dir_name, bool recursive) {
   if (!recursive) {
     return (TEMP_FAILURE_RETRY(remove(dir_name)) == 0);
   } else {
     return DeleteRecursively(dir_name);
   }
 }