Fix socket leak in HttpServer, when the connection is closed while receiving data.

sdk/lib/io/http_parser.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;
 
 // Global constants.
 class _Const {
   // Bytes for "HTTP".
   static const HTTP = const [72, 84, 84, 80];
@@ skipping 711 matching lines @@
     if (_state == _State.CLOSED || _state == _State.FAILURE) return;
 
     if (_incoming != null) {
       if (_state != _State.UPGRADED &&
           !(_state == _State.START && !_requestParser) &&
           !(_state == _State.BODY && !_chunked && _transferLength == -1)) {
         _bodyController.addError(
               new HttpParserException(
                   "Connection closed while receiving data"));
       }
-      _closeIncoming();
+      _closeIncoming(true);
       _controller.close();
       return;
     }
     // If the connection is idle the HTTP stream is closed.
     if (_state == _State.START) {
       if (!_requestParser) {
         error(new HttpParserException(
                     "Connection closed before full header was received"));
       }
       _controller.close();
@@ skipping 159 matching lines @@
           if (incoming != _incoming) return;
           assert(_bodyPaused);
           _bodyPaused = false;
           _pauseStateChanged();
         },
         onCancel: () {
           if (incoming != _incoming) return;
           if (_socketSubscription != null) {
             _socketSubscription.cancel();
           }
-          _closeIncoming();
+          _closeIncoming(true);
           _controller.close();
         });
     incoming = _incoming = new _HttpIncoming(
         _headers, transferLength, _bodyController.stream);
     _bodyPaused = true;
     _pauseStateChanged();
   }
 
-  void _closeIncoming() {
+  void _closeIncoming([bool closing = false]) {
     // Ignore multiple close (can happend in re-entrance).
     if (_incoming == null) return;
     var tmp = _incoming;
-    tmp.close();
+    tmp.close(closing);
     _incoming = null;
     if (_bodyController != null) {
       _bodyController.close();
       _bodyController = null;
     }
     _bodyPaused = false;
     _pauseStateChanged();
   }
 
   void _pauseStateChanged() {
@@ skipping 61 matching lines @@
   StreamController<_HttpIncoming> _controller;
   StreamController<List<int>> _bodyController;
 }
 
 
 class HttpParserException implements Exception {
   const HttpParserException([String this.message = ""]);
   String toString() => "HttpParserException: $message";
   final String message;
 }