File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -622,7 +622,7 @@ func recvBufferPool(bufferPool SharedBufferPool) ServerOption {
622
622
// workload (assuming a QPS of a few thousand requests/sec).
623
623
const serverWorkerResetThreshold = 1 << 16
624
624
625
- // serverWorkers blocks on a *transport.Stream channel forever and waits for
625
+ // serverWorker blocks on a *transport.Stream channel forever and waits for
626
626
// data to be fed by serveStreams. This allows multiple requests to be
627
627
// processed by the same goroutine, removing the need for expensive stack
628
628
// re-allocations (see the runtime.morestack problem [1]).
Original file line number Diff line number Diff line change @@ -1182,12 +1182,12 @@ func (a *csAttempt) finish(err error) {
1182
1182
a .mu .Unlock ()
1183
1183
}
1184
1184
1185
- // newClientStream creates a ClientStream with the specified transport, on the
1185
+ // newNonRetryClientStream creates a ClientStream with the specified transport, on the
1186
1186
// given addrConn.
1187
1187
//
1188
1188
// It's expected that the given transport is either the same one in addrConn, or
1189
1189
// is already closed. To avoid race, transport is specified separately, instead
1190
- // of using ac.transpot .
1190
+ // of using ac.transport .
1191
1191
//
1192
1192
// Main difference between this and ClientConn.NewStream:
1193
1193
// - no retry
You can’t perform that action at this time.
0 commit comments