gofmt -w

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,
+		t:      t,
-		s:       stream,
+		s:      stream,
-		p:       &parser{s: stream},
+		p:      &parser{s: stream},
-		codec:   s.opts.codec,
+		codec:  s.opts.codec,
 		trInfo: trInfo,
 	}
 	if trInfo != nil {

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.
 }

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,
+		conn:          conn,
-		authInfo:        authInfo,
+		authInfo:      authInfo,
-		framer:          framer,
+		framer:        framer,
-		hBuf:            &buf,
+		hBuf:          &buf,
-		hEnc:            hpack.NewEncoder(&buf),
+		hEnc:          hpack.NewEncoder(&buf),
-		maxStreams:      maxStreams,
+		maxStreams:    maxStreams,
-		controlBuf:      newRecvBuffer(),
+		controlBuf:    newRecvBuffer(),
-		fc:              &inFlow{limit: initialConnWindowSize},
+		fc:            &inFlow{limit: initialConnWindowSize},
-		sendQuotaPool:   newQuotaPool(defaultWindowSize),
+		sendQuotaPool: newQuotaPool(defaultWindowSize),
 		//tracing:         tracing,
 		state:           reachable,
 		writableChan:    make(chan int, 1),