code review 4538088: http,io,net: sendfile support

src/pkg/http/server.go

 // Copyright 2009 The Go Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style
 // license that can be found in the LICENSE file.
 
 // HTTP server.  See RFC 2616.
 
 // TODO(rsc):
 //      logging
 //      post support
 
@@ skipping 99 matching lines @@
         header        Header   // reply header parameters
         written       int64    // number of bytes written in body
         contentLength int64    // explicitly-declared Content-Length; or -1
         status        int      // status code passed to WriteHeader
 
         // close connection after this reply.  set on request and
         // updated after response from handler if there's a
         // "Connection: keep-alive" response header and a
         // Content-Length.
         closeAfterReply bool
+}
+
+func (r *response) ReadFrom(src io.Reader) (int64, os.Error) {
+        if !r.chunking {
+                if rf, ok := r.conn.rwc.(io.ReaderFrom); ok {
+                        r.Flush()
+                        return rf.ReadFrom(src)
+                }
+        }
+        return io.BufferedCopy(r, src)
+}
+
+func (r *response) ReadNFrom(src io.Reader, n int64) (int64, os.Error) {
+        if !r.chunking {
+                if rf, ok := r.conn.rwc.(io.ReaderNFrom); ok {
+                        r.Flush()
+                        return rf.ReadNFrom(src, n)
+                }
+        }
+        return io.BufferedCopyn(r, src, n)
 }
 
 // Create new connection from rwc.
 func newConn(rwc net.Conn, handler Handler) (c *conn, err os.Error) {
         c = new(conn)
         c.remoteAddr = rwc.RemoteAddr().String()
         c.handler = handler
         c.rwc = rwc
         br := bufio.NewReader(rwc)
         bw := bufio.NewWriter(rwc)
@@ skipping 857 matching lines @@
 func (tw *timeoutWriter) WriteHeader(code int) {
         tw.mu.Lock()
         if tw.timedOut || tw.wroteHeader {
                 tw.mu.Unlock()
                 return
         }
         tw.wroteHeader = true
         tw.mu.Unlock()
         tw.w.WriteHeader(code)
 }