Introduce optional 'bool shared' parameter to ServerSocket.bind() ...

dart/sdk/lib/io/secure_server_socket.dart

 // 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.
 
 part of dart.io;
 
 /**
  * The [SecureServerSocket] is a server socket, providing a stream of high-level
  * [Socket]s.
  *
  * See [SecureSocket] for more info.
  */
 class SecureServerSocket extends Stream<SecureSocket> {
   final RawSecureServerSocket _socket;
 
-  SecureServerSocket._(this._socket);
+  /**
+   * Whether the underlying socket of this [SecureServerSocket] might
+   * potentially be shared.
+   */
+  final bool shared;
+
+  SecureServerSocket._(this._socket, this.shared);
 
   /**
    * Returns a future for a [SecureServerSocket]. When the future
    * completes the server socket is bound to the given [address] and
    * [port] and has started listening on it.
    *
    * The [address] can either be a [String] or an
    * [InternetAddress]. If [address] is a [String], [bind] will
    * perform a [InternetAddress.lookup] and use the first value in the
    * list. To listen on the loopback adapter, which will allow only
@@ skipping 33 matching lines @@
    * was received, the result will be null.
    */
   static Future<SecureServerSocket> bind(
       address,
       int port,
       String certificateName,
       {int backlog: 0,
        bool v6Only: false,
        bool requestClientCertificate: false,
        bool requireClientCertificate: false,
-       List<String> supportedProtocols}) {
+       List<String> supportedProtocols,
+       bool shared: false}) {
     return RawSecureServerSocket.bind(
         address,
         port,
         certificateName,
         backlog: backlog,
         v6Only: v6Only,
         requestClientCertificate: requestClientCertificate,
         requireClientCertificate: requireClientCertificate,
-        supportedProtocols: supportedProtocols).then(
-            (serverSocket) => new SecureServerSocket._(serverSocket));
+        supportedProtocols: supportedProtocols,
+        shared: shared).then(
+            (serverSocket) => new SecureServerSocket._(serverSocket, shared));
   }
 
   StreamSubscription<SecureSocket> listen(void onData(SecureSocket socket),
                                           {Function onError,
                                            void onDone(),
                                            bool cancelOnError}) {
     return _socket.map((rawSocket) => new SecureSocket._(rawSocket))
                   .listen(onData,
                           onError: onError,
                           onDone: onDone,
@@ skipping 29 matching lines @@
 class RawSecureServerSocket extends Stream<RawSecureSocket> {
   RawServerSocket _socket;
   StreamController<RawSecureSocket> _controller;
   StreamSubscription<RawSocket> _subscription;
   final String certificateName;
   final bool requestClientCertificate;
   final bool requireClientCertificate;
   final List<String> supportedProtocols;
   bool _closed = false;
 
+  /**
+   * Whether the underlying socket of this [RawSecureServerSocket] might
+   * potentially be shared.
+   */
+  final bool shared;
+
   RawSecureServerSocket._(RawServerSocket serverSocket,
                           this.certificateName,
                           this.requestClientCertificate,
                           this.requireClientCertificate,
-                          this.supportedProtocols) {
+                          this.supportedProtocols,
+                          this.shared) {
     _socket = serverSocket;
     _controller = new StreamController<RawSecureSocket>(
         sync: true,
         onListen: _onSubscriptionStateChange,
         onPause: _onPauseStateChange,
         onResume: _onPauseStateChange,
         onCancel: _onSubscriptionStateChange);
   }
 
   /**
@@ skipping 40 matching lines @@
    * was received, the result will be null.
    */
   static Future<RawSecureServerSocket> bind(
       address,
       int port,
       String certificateName,
       {int backlog: 0,
        bool v6Only: false,
        bool requestClientCertificate: false,
        bool requireClientCertificate: false,
-       List<String> supportedProtocols}) {
-    return RawServerSocket.bind(address, port, backlog: backlog, v6Only: v6Only)
+       List<String> supportedProtocols,
+       bool shared: false}) {
+    return RawServerSocket.bind(
+        address, port, backlog: backlog, v6Only: v6Only, shared: shared)
         .then((serverSocket) => new RawSecureServerSocket._(
             serverSocket,
             certificateName,
             requestClientCertificate,
             requireClientCertificate,
-            supportedProtocols));
+            supportedProtocols,
+            shared));
   }
 
   StreamSubscription<RawSecureSocket> listen(void onData(RawSecureSocket s),
                                              {Function onError,
                                               void onDone(),
                                               bool cancelOnError}) {
     return _controller.stream.listen(onData,
                                      onError: onError,
                                      onDone: onDone,
                                      cancelOnError: cancelOnError);
@@ skipping 72 matching lines @@
                                      onError: _onError);
     } else {
       close();
     }
   }
 
   void set _owner(owner) { (_socket as dynamic)._owner = owner; }
 }