From 8ec28f27d13b05b08013c763e4e075539f1235f0 Mon Sep 17 00:00:00 2001 From: Yicheng Qin Date: Mon, 2 Mar 2015 13:26:48 -0800 Subject: [PATCH] rafthttp: streamReader roundtrip -> dial --- rafthttp/stream.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/rafthttp/stream.go b/rafthttp/stream.go index 66fb38d36..18127c8bb 100644 --- a/rafthttp/stream.go +++ b/rafthttp/stream.go @@ -219,7 +219,7 @@ func startStreamReader(tr http.RoundTripper, u string, t streamType, from, to, c func (cr *streamReader) run() { for { - rc, err := cr.roundtrip() + rc, err := cr.dial() if err != nil { log.Printf("rafthttp: roundtripping error: %v", err) } else { @@ -307,7 +307,7 @@ func (cr *streamReader) isWorking() bool { return cr.closer != nil } -func (cr *streamReader) roundtrip() (io.ReadCloser, error) { +func (cr *streamReader) dial() (io.ReadCloser, error) { cr.mu.Lock() u := cr.u term := cr.msgAppTerm