Merge services into a shared IOService in dart:io, and use a native port.

sdk/lib/io/link.dart

 // Copyright (c) 2013, 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.
 
 part of dart.io;
 
 /**
  * [Link] objects are references to filesystem links.
  *
  */
@@ skipping 107 matching lines @@
    *
    * If the link does not exist, or is not a link, throws a LinkException.
    */
   String targetSync();
 }
 
 
 class _Link extends FileSystemEntity implements Link {
   final String path;
 
-  SendPort _fileService;
-
   _Link(String this.path) {
     if (path is! String) {
       throw new ArgumentError('${Error.safeToString(path)} '
                               'is not a String');
     }
   }
 
 
   String toString() => "Link: '$path'";
 
   Future<bool> exists() => FileSystemEntity.isLink(path);
 
   bool existsSync() => FileSystemEntity.isLinkSync(path);
 
   Link get absolute => new Link(_absolutePath);
 
   Future<FileStat> stat() => FileStat.stat(path);
 
   FileStat statSync() => FileStat.statSync(path);
 
   Future<Link> create(String target) {
-    _ensureFileService();
     if (Platform.operatingSystem == 'windows') {
       target = _makeWindowsLinkTarget(target);
     }
-    List request = new List(3);
-    request[0] = _CREATE_LINK_REQUEST;
-    request[1] = path;
-    request[2] = target;
-    return _fileService.call(request).then((response) {
-      if (_isErrorResponse(response)) {
-        throw _exceptionFromResponse(
-            response, "Cannot create link to target '$target'", path);
-      }
-      return this;
-    });
+    return IOService.dispatch(FILE_CREATE_LINK, [path, target])
+        .then((response) {
+          if (_isErrorResponse(response)) {
+            throw _exceptionFromResponse(
+                response, "Cannot create link to target '$target'", path);
+          }
+          return this;
+        });
   }
 
   void createSync(String target) {
     if (Platform.operatingSystem == 'windows') {
       target = _makeWindowsLinkTarget(target);
     }
     var result = _File._createLink(path, target);
     throwIfError(result, "Cannot create link", path);
   }
 
@@ skipping 26 matching lines @@
     // Atomically changing a link can be done by creating the new link, with
     // a different name, and using the rename() posix call to move it to
     // the old name atomically.
     return delete().then((_) => create(target));
   }
 
   Future<Link> _delete({bool recursive: false}) {
     if (recursive) {
       return new Directory(path).delete(recursive: true).then((_) => this);
     }
-    _ensureFileService();
-    List request = new List(2);
-    request[0] = _DELETE_LINK_REQUEST;
-    request[1] = path;
-    return _fileService.call(request).then((response) {
+    return IOService.dispatch(FILE_DELETE_LINK, [path]).then((response) {
       if (_isErrorResponse(response)) {
         throw _exceptionFromResponse(response, "Cannot delete link", path);
       }
       return this;
     });
   }
 
   void _deleteSync({bool recursive: false}) {
     if (recursive) {
       return new Directory(path).deleteSync(recursive: true);
     }
     var result = _File._deleteLinkNative(path);
     throwIfError(result, "Cannot delete link", path);
   }
 
   Future<Link> rename(String newPath) {
-    _ensureFileService();
-    List request = new List(3);
-    request[0] = _RENAME_LINK_REQUEST;
-    request[1] = path;
-    request[2] = newPath;
-    return _fileService.call(request).then((response) {
-      if (_isErrorResponse(response)) {
-        throw _exceptionFromResponse(
-            response, "Cannot rename link to '$newPath'", path);
-      }
-      return new Link(newPath);
-    });
+    return IOService.dispatch(FILE_RENAME_LINK, [path, newPath])
+        .then((response) {
+          if (_isErrorResponse(response)) {
+            throw _exceptionFromResponse(
+                response, "Cannot rename link to '$newPath'", path);
+          }
+          return new Link(newPath);
+        });
   }
 
   Link renameSync(String newPath) {
     var result = _File._renameLink(path, newPath);
     throwIfError(result, "Cannot rename link '$path' to '$newPath'");
     return new Link(newPath);
   }
 
   Future<String> target() {
-    _ensureFileService();
-    List request = new List(2);
-    request[0] = _LINK_TARGET_REQUEST;
-    request[1] = path;
-    return _fileService.call(request).then((response) {
+    return IOService.dispatch(FILE_LINK_TARGET, [path]).then((response) {
       if (_isErrorResponse(response)) {
         throw _exceptionFromResponse(
             response, "Cannot get target of link", path);
       }
       return response;
     });
   }
 
   String targetSync() {
     var result = _File._linkTarget(path);
     throwIfError(result, "Cannot read link", path);
     return result;
   }
 
   static throwIfError(Object result, String msg, [String path = ""]) {
     if (result is OSError) {
       throw new LinkException(msg, path, result);
     }
   }
 
   bool _isErrorResponse(response) {
     return response is List && response[0] != _SUCCESS_RESPONSE;
   }
 
-  void _ensureFileService() {
-    if (_fileService == null) {
-      _fileService = _FileUtils._newServicePort();
-    }
-  }
-
   _exceptionFromResponse(response, String message, String path) {
     assert(_isErrorResponse(response));
     switch (response[_ERROR_RESPONSE_ERROR_TYPE]) {
       case _ILLEGAL_ARGUMENT_RESPONSE:
         return new ArgumentError();
       case _OSERROR_RESPONSE:
         var err = new OSError(response[_OSERROR_RESPONSE_MESSAGE],
                               response[_OSERROR_RESPONSE_ERROR_CODE]);
         return new LinkException(message, path, err);
       default:
@@ skipping 23 matching lines @@
       if (path != null) {
         sb.write(", path = $path");
       }
     }
     return sb.toString();
   }
   final String message;
   final String path;
   final OSError osError;
 }