diff --git a/rsload.go b/rsload.go index ce8d3c8..28a852f 100644 --- a/rsload.go +++ b/rsload.go @@ -155,68 +155,6 @@ func main() { requests.send(w, responses) } - // go func() { - // w := bufio.NewWriterSize(conn, 16384) - // defer func() { - // close(sent) - // fmt.Println("All data transferred. Waiting for the last reply...") - // }() - // requests := &chunk{vals: make([]value, 0, chunk_size)} - // for m := range c { - // if !m.ok() { - // fmt.Fprintf(os.Stderr, "InputError: %v\n", m.err()) - // continue - // } - // if _, err := m.val().Write(w); err != nil { - // fmt.Fprintf(os.Stderr, "WriteError: %v\n", err) - // } - - // requests.vals = append(requests.vals, m.val()) - // if len(requests.vals) == cap(requests.vals) { - // requests.t = time.Now() - // if err := w.Flush(); err != nil { - // fmt.Fprintf(os.Stderr, "FlushError: %v\n", err) - // } - // sent <- requests - // requests = &chunk{vals: make([]value, 0, chunk_size)} - // } - // } - // if len(requests.vals) > 0 { - // if err := w.Flush(); err != nil { - // fmt.Fprintf(os.Stderr, "FlushError: %v\n", err) - // } - // sent <- requests - // } - // }() - - // id := 1 - // for requests := range sent { - // for _, request := range requests.vals { - // response := <-responses - // if response.ok() { - // switch r := response.val().(type) { - // case ErrorVal: - // if options.verbose { - // fmt.Fprintf(os.Stderr, "%q -> %q\n", request, response.val()) - // } else { - // fmt.Fprintln(os.Stderr, r) - // } - // errors++ - // default: - // if options.verbose { - // fmt.Fprintf(os.Stdout, "%q -> %q\n", request, response.val()) - // } - // replies++ - // } - // } else { - // fmt.Fprintf(os.Stderr, "ResponseError: %v\n", response.err()) - // } - // } - // elapsed := time.Since(requests.t) - // fmt.Fprintf(os.Stdout, "%d %d %v %v\n", id, len(requests.vals), elapsed, - // time.Duration(int64(elapsed)/int64(len(requests.vals)))) - // id++ - // } // fmt.Println("Last reply received from server.") // fmt.Printf("errors: %d, replies: %d\n", errors, replies) }