fix a few typos
This commit is contained in:
@ -122,7 +122,7 @@ func newTestServer() *server {
|
|||||||
return &server{startedErr: make(chan error, 1)}
|
return &server{startedErr: make(chan error, 1)}
|
||||||
}
|
}
|
||||||
|
|
||||||
// start starts server. Other goroutines should block on s.startedErr for futher operations.
|
// start starts server. Other goroutines should block on s.startedErr for further operations.
|
||||||
func (s *server) start(t *testing.T, port int, maxStreams uint32) {
|
func (s *server) start(t *testing.T, port int, maxStreams uint32) {
|
||||||
var err error
|
var err error
|
||||||
if port == 0 {
|
if port == 0 {
|
||||||
|
@ -52,10 +52,10 @@ var (
|
|||||||
// ErrUnspecTarget indicates that the target address is unspecified.
|
// ErrUnspecTarget indicates that the target address is unspecified.
|
||||||
ErrUnspecTarget = errors.New("grpc: target is unspecified")
|
ErrUnspecTarget = errors.New("grpc: target is unspecified")
|
||||||
// ErrNoTransportSecurity indicates that there is no transport security
|
// ErrNoTransportSecurity indicates that there is no transport security
|
||||||
// being set for ClientConn. Users should either set one or explicityly
|
// being set for ClientConn. Users should either set one or explicitly
|
||||||
// call WithInsecure DialOption to disable security.
|
// call WithInsecure DialOption to disable security.
|
||||||
ErrNoTransportSecurity = errors.New("grpc: no transport security set (use grpc.WithInsecure() explicitly or set credentials)")
|
ErrNoTransportSecurity = errors.New("grpc: no transport security set (use grpc.WithInsecure() explicitly or set credentials)")
|
||||||
// ErrCredentialsMisuse indicates that users want to transmit security infomation
|
// ErrCredentialsMisuse indicates that users want to transmit security information
|
||||||
// (e.g., oauth2 token) which requires secure connection on an insecure
|
// (e.g., oauth2 token) which requires secure connection on an insecure
|
||||||
// connection.
|
// connection.
|
||||||
ErrCredentialsMisuse = errors.New("grpc: the credentials require transport level security (use grpc.WithTransportAuthenticator() to set)")
|
ErrCredentialsMisuse = errors.New("grpc: the credentials require transport level security (use grpc.WithTransportAuthenticator() to set)")
|
||||||
|
@ -333,7 +333,7 @@ func TestReconnectTimeout(t *testing.T) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
// Block untill reconnect times out.
|
// Block until reconnect times out.
|
||||||
<-waitC
|
<-waitC
|
||||||
if err := conn.Close(); err != grpc.ErrClientConnClosing {
|
if err := conn.Close(); err != grpc.ErrClientConnClosing {
|
||||||
t.Fatalf("%v.Close() = %v, want %v", conn, err, grpc.ErrClientConnClosing)
|
t.Fatalf("%v.Close() = %v, want %v", conn, err, grpc.ErrClientConnClosing)
|
||||||
|
@ -118,7 +118,7 @@ func NewServerHandlerTransport(w http.ResponseWriter, r *http.Request) (ServerTr
|
|||||||
|
|
||||||
// serverHandlerTransport is an implementation of ServerTransport
|
// serverHandlerTransport is an implementation of ServerTransport
|
||||||
// which replies to exactly one gRPC request (exactly one HTTP request),
|
// which replies to exactly one gRPC request (exactly one HTTP request),
|
||||||
// using the net/http.Handler interface. This http.Handler is guranteed
|
// using the net/http.Handler interface. This http.Handler is guaranteed
|
||||||
// at this point to be speaking over HTTP/2, so it's able to speak valid
|
// at this point to be speaking over HTTP/2, so it's able to speak valid
|
||||||
// gRPC.
|
// gRPC.
|
||||||
type serverHandlerTransport struct {
|
type serverHandlerTransport struct {
|
||||||
|
@ -134,7 +134,7 @@ func (h *testStreamHandler) handleStreamMalformedStatus(t *testing.T, s *Stream)
|
|||||||
h.t.WriteStatus(s, codes.Internal, "\n")
|
h.t.WriteStatus(s, codes.Internal, "\n")
|
||||||
}
|
}
|
||||||
|
|
||||||
// start starts server. Other goroutines should block on s.readyChan for futher operations.
|
// start starts server. Other goroutines should block on s.readyChan for further operations.
|
||||||
func (s *server) start(t *testing.T, port int, maxStreams uint32, ht hType) {
|
func (s *server) start(t *testing.T, port int, maxStreams uint32, ht hType) {
|
||||||
var err error
|
var err error
|
||||||
if port == 0 {
|
if port == 0 {
|
||||||
|
Reference in New Issue
Block a user