Make the HTTP server close non-persistent connections

runtime/bin/http_impl.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.
 
 class _HttpHeaders implements HttpHeaders {
   _HttpHeaders() : _headers = new Map<String, List<String>>();
 
   List<String> operator[](String name) {
     name = name.toLowerCase();
     return _headers[name];
@@ skipping 299 matching lines @@
     bool allWritten = true;
     if (_contentLength < 0) {
       // Terminate the content if transfer encoding is chunked.
       allWritten = _httpConnection._write(_Const.END_CHUNKED);
     } else {
       if (_bodyBytesWritten < _contentLength) {
         throw new HttpException("Sending less than specified content length");
       }
       assert(_bodyBytesWritten == _contentLength);
     }
+    if (!persistentConnection) _httpConnection._close();
     return allWritten;
   }
 
   bool _writeHeaders() {
     _headers._mutable = false;
     _headers._write(_httpConnection);
     // Terminate header.
     return _writeCRLF();
   }
 
@@ skipping 417 matching lines @@
   }
 
   bool _writeFrom(List<int> buffer, [int offset, int len]) {
     if (!_error && !_closing) {
       return _socket.outputStream.writeFrom(buffer, offset, len);
     }
   }
 
   bool _close() {
     _closing = true;
+    _socket.outputStream.close();
+  }
+
+  bool _destroy() {
+    _closing = true;
     _socket.close();
   }
 
   void _onData() {
     int available = _socket.available();
     if (available == 0) {
       return;
     }
 
     List<int> buffer = new Uint8List(available);
     int bytesRead = _socket.readList(buffer, 0, available);
     if (bytesRead > 0) {
       int parsed = _httpParser.writeList(buffer, 0, bytesRead);
       if (!_httpParser.upgrade) {
         if (parsed != bytesRead) {
           if (_socket != null) {
             // TODO(sgjesse): Error handling.
-            _close();
+            _destroy();
           }
         }
       }
     }
   }
 
   void _onClosed() {
     _closing = true;
     _onConnectionClosed(null);
   }
@@ skipping 71 matching lines @@
       if (_request != null && _request._streamErrorHandler != null) {
         _request._streamErrorHandler(e);
       }
       if (_response != null && _response._streamErrorHandler != null) {
         _response._streamErrorHandler(e);
       }
     }
 
     // If currently not processing any request just close the socket.
     if (_httpParser.isIdle) {
-      _close();
+      _destroy();
       if (onClosed != null && e == null) {
         // Don't call onClosed if onError has been called.
         onClosed();
       }
       return;
     }
 
     // Processing a request.
     if (e == null) {
       // Indicate connection close to the HTTP parser.
@@ skipping 666 matching lines @@
 }
 
 
 class _DetachedSocket implements DetachedSocket {
   _DetachedSocket(this._socket, this._unparsedData);
   Socket get socket() => _socket;
   List<int> get unparsedData() => _unparsedData;
   Socket _socket;
   List<int> _unparsedData;
 }