From 9db3ca85c7ffb0b02e577271f99b301d742ef521 Mon Sep 17 00:00:00 2001 From: iamqizhao Date: Mon, 5 Oct 2015 17:52:00 -0700 Subject: [PATCH] gofmt -w --- server.go | 8 ++++---- stream.go | 2 +- transport/http2_server.go | 18 +++++++++--------- 3 files changed, 14 insertions(+), 14 deletions(-) diff --git a/server.go b/server.go index 77960fe08..5c20dd4be 100644 --- a/server.go +++ b/server.go @@ -397,10 +397,10 @@ func (s *Server) processUnaryRPC(t transport.ServerTransport, stream *transport. func (s *Server) processStreamingRPC(t transport.ServerTransport, stream *transport.Stream, srv *service, sd *StreamDesc, trInfo *traceInfo) (err error) { ss := &serverStream{ - t: t, - s: stream, - p: &parser{s: stream}, - codec: s.opts.codec, + t: t, + s: stream, + p: &parser{s: stream}, + codec: s.opts.codec, trInfo: trInfo, } if trInfo != nil { diff --git a/stream.go b/stream.go index a10e691d4..e396b1fa3 100644 --- a/stream.go +++ b/stream.go @@ -298,7 +298,7 @@ type serverStream struct { codec Codec statusCode codes.Code statusDesc string - trInfo *traceInfo + trInfo *traceInfo mu sync.Mutex // protects trInfo.tr after the service handler runs. } diff --git a/transport/http2_server.go b/transport/http2_server.go index ba79808d0..000e374d5 100644 --- a/transport/http2_server.go +++ b/transport/http2_server.go @@ -117,15 +117,15 @@ func newHTTP2Server(conn net.Conn, maxStreams uint32, authInfo credentials.AuthI } var buf bytes.Buffer t := &http2Server{ - conn: conn, - authInfo: authInfo, - framer: framer, - hBuf: &buf, - hEnc: hpack.NewEncoder(&buf), - maxStreams: maxStreams, - controlBuf: newRecvBuffer(), - fc: &inFlow{limit: initialConnWindowSize}, - sendQuotaPool: newQuotaPool(defaultWindowSize), + conn: conn, + authInfo: authInfo, + framer: framer, + hBuf: &buf, + hEnc: hpack.NewEncoder(&buf), + maxStreams: maxStreams, + controlBuf: newRecvBuffer(), + fc: &inFlow{limit: initialConnWindowSize}, + sendQuotaPool: newQuotaPool(defaultWindowSize), //tracing: tracing, state: reachable, writableChan: make(chan int, 1),