Fix typos

SECURITY.md

@@ -1,3 +1,3 @@
 # Security Policy
 
-For information on gRPC Security Policy and reporting potentional security issues, please see [gRPC CVE Process](https://github.com/grpc/proposal/blob/master/P4-grpc-cve-process.md).
+For information on gRPC Security Policy and reporting potential security issues, please see [gRPC CVE Process](https://github.com/grpc/proposal/blob/master/P4-grpc-cve-process.md).

backoff/backoff.go

@@ -39,7 +39,7 @@ type Config struct {
 	MaxDelay time.Duration
 }
 
-// DefaultConfig is a backoff configuration with the default values specfied
+// DefaultConfig is a backoff configuration with the default values specified
 // at https://github.com/grpc/grpc/blob/master/doc/connection-backoff.md.
 //
 // This should be useful for callers who want to configure backoff with

balancer/grpclb/grpclb.go

@@ -219,7 +219,7 @@ type lbBalancer struct {
 	// All backends addresses, with metadata set to nil. This list contains all
 	// backend addresses in the same order and with the same duplicates as in
 	// serverlist. When generating picker, a SubConn slice with the same order
-	// but with only READY SCs will be gerenated.
+	// but with only READY SCs will be generated.
 	backendAddrsWithoutMetadata []resolver.Address
 	// Roundrobin functionalities.
 	state    connectivity.State

balancer/grpclb/grpclb_util_test.go

@@ -252,7 +252,7 @@ func (s) TestLBCache_ShutdownTimer_New_Race(t *testing.T) {
 	go func() {
 		for i := 0; i < 1000; i++ {
 			// Shutdown starts a timer with 1 ns timeout, the NewSubConn will
-			// race with with the timer.
+			// race with the timer.
 			sc.Shutdown()
 			sc, _ = ccc.NewSubConn([]resolver.Address{{Addr: "address1"}}, balancer.NewSubConnOptions{})
 		}

balancer/pickfirst/pickfirst.go

@@ -155,7 +155,7 @@ func (b *pickfirstBalancer) UpdateClientConnState(state balancer.ClientConnState
 		// Endpoints not set, process addresses until we migrate resolver
 		// emissions fully to Endpoints. The top channel does wrap emitted
 		// addresses with endpoints, however some balancers such as weighted
-		// target do not forwarrd the corresponding correct endpoints down/split
+		// target do not forward the corresponding correct endpoints down/split
 		// endpoints properly. Once all balancers correctly forward endpoints
 		// down, can delete this else conditional.
 		addrs = state.ResolverState.Addresses

balancer/rls/cache.go

@@ -47,7 +47,7 @@ type cacheEntry struct {
 	// headerData is received in the RLS response and is to be sent in the
 	// X-Google-RLS-Data header for matching RPCs.
 	headerData string
-	// expiryTime is the absolute time at which this cache entry entry stops
+	// expiryTime is the absolute time at which this cache entry stops
 	// being valid. When an RLS request succeeds, this is set to the current
 	// time plus the max_age field from the LB policy config.
 	expiryTime time.Time
@@ -223,7 +223,7 @@ func (dc *dataCache) resize(size int64) (backoffCancelled bool) {
 				backoffCancelled = true
 			}
 		}
-		dc.deleteAndcleanup(key, entry)
+		dc.deleteAndCleanup(key, entry)
 	}
 	dc.maxSize = size
 	return backoffCancelled
@@ -249,7 +249,7 @@ func (dc *dataCache) evictExpiredEntries() bool {
 		if entry.expiryTime.After(now) || entry.backoffExpiryTime.After(now) {
 			continue
 		}
-		dc.deleteAndcleanup(key, entry)
+		dc.deleteAndCleanup(key, entry)
 		evicted = true
 	}
 	return evicted
@@ -339,23 +339,23 @@ func (dc *dataCache) removeEntryForTesting(key cacheKey) {
 	if !ok {
 		return
 	}
-	dc.deleteAndcleanup(key, entry)
+	dc.deleteAndCleanup(key, entry)
 }
 
 // deleteAndCleanup performs actions required at the time of deleting an entry
 // from the data cache.
 // - the entry is removed from the map of entries
 // - current size of the data cache is update
 // - the key is removed from the LRU
-func (dc *dataCache) deleteAndcleanup(key cacheKey, entry *cacheEntry) {
+func (dc *dataCache) deleteAndCleanup(key cacheKey, entry *cacheEntry) {
 	delete(dc.entries, key)
 	dc.currentSize -= entry.size
 	dc.keys.removeEntry(key)
 }
 
 func (dc *dataCache) stop() {
 	for key, entry := range dc.entries {
-		dc.deleteAndcleanup(key, entry)
+		dc.deleteAndCleanup(key, entry)
 	}
 	dc.shutdown.Fire()
 }

balancer/rls/control_channel_test.go

@@ -62,7 +62,7 @@ func (s) TestControlChannelThrottled(t *testing.T) {
 
 	select {
 	case <-rlsReqCh:
-		t.Fatal("RouteLookup RPC invoked when control channel is throtlled")
+		t.Fatal("RouteLookup RPC invoked when control channel is throttled")
 	case <-time.After(defaultTestShortTimeout):
 	}
 }

balancer/rls/internal/keys/builder.go

@@ -218,7 +218,7 @@ type matcher struct {
 	names []string
 }
 
-// Equal reports if m and are are equivalent headerKeys.
+// Equal reports if m and a are equivalent headerKeys.
 func (m matcher) Equal(a matcher) bool {
 	if m.key != a.key {
 		return false

balancer/rls/internal/test/e2e/rls_child_policy.go

@@ -125,7 +125,7 @@ func (b *bal) Close() {
 
 // run is a dummy goroutine to make sure that child policies are closed at the
 // end of tests. If they are not closed, these goroutines will be picked up by
-// the leakcheker and tests will fail.
+// the leak checker and tests will fail.
 func (b *bal) run() {
 	<-b.done.Done()
 }

balancer/rls/picker.go

@@ -157,7 +157,7 @@ func (p *rlsPicker) delegateToChildPoliciesLocked(dcEntry *cacheEntry, info bala
 		state := (*balancer.State)(atomic.LoadPointer(&cpw.state))
 		// Delegate to the child policy if it is not in TRANSIENT_FAILURE, or if
 		// it is the last one (which handles the case of delegating to the last
-		// child picker if all child polcies are in TRANSIENT_FAILURE).
+		// child picker if all child policies are in TRANSIENT_FAILURE).
 		if state.ConnectivityState != connectivity.TransientFailure || i == len(dcEntry.childPolicyWrappers)-1 {
 			// Any header data received from the RLS server is stored in the
 			// cache entry and needs to be sent to the actual backend in the

balancer/weightedroundrobin/balancer.go

@@ -592,7 +592,7 @@ func (w *weightedSubConn) updateConnectivityState(cs connectivity.State) connect
 // account the parameters.  Returns 0 for blacked out or expired data, which
 // will cause the backend weight to be treated as the mean of the weights of the
 // other backends. If forScheduler is set to true, this function will emit
-// metrics through the mtrics registry.
+// metrics through the metrics registry.
 func (w *weightedSubConn) weight(now time.Time, weightExpirationPeriod, blackoutPeriod time.Duration, recordMetrics bool) (weight float64) {
 	w.mu.Lock()
 	defer w.mu.Unlock()

balancer/weightedtarget/weightedaggregator/aggregator.go

@@ -89,7 +89,7 @@ func New(cc balancer.ClientConn, logger *grpclog.PrefixLogger, newWRR func() wrr
 }
 
 // Start starts the aggregator. It can be called after Stop to restart the
-// aggretator.
+// aggregator.
 func (wbsa *Aggregator) Start() {
 	wbsa.mu.Lock()
 	defer wbsa.mu.Unlock()

benchmark/benchmain/main.go

@@ -109,11 +109,11 @@ var (
 	useBufconn          = flag.Bool("bufconn", false, "Use in-memory connection instead of system network I/O")
 	enableKeepalive     = flag.Bool("enable_keepalive", false, "Enable client keepalive. \n"+
 		"Keepalive.Time is set to 10s, Keepalive.Timeout is set to 1s, Keepalive.PermitWithoutStream is set to true.")
-	clientReadBufferSize  = flags.IntSlice("clientReadBufferSize", []int{-1}, "Configures the client read buffer size in bytes. If negative, use the default - may be a a comma-separated list")
-	clientWriteBufferSize = flags.IntSlice("clientWriteBufferSize", []int{-1}, "Configures the client write buffer size in bytes. If negative, use the default - may be a a comma-separated list")
-	serverReadBufferSize  = flags.IntSlice("serverReadBufferSize", []int{-1}, "Configures the server read buffer size in bytes. If negative, use the default - may be a a comma-separated list")
-	serverWriteBufferSize = flags.IntSlice("serverWriteBufferSize", []int{-1}, "Configures the server write buffer size in bytes. If negative, use the default - may be a a comma-separated list")
-	sleepBetweenRPCs      = flags.DurationSlice("sleepBetweenRPCs", []time.Duration{0}, "Configures the maximum amount of time the client should sleep between consecutive RPCs - may be a a comma-separated list")
+	clientReadBufferSize  = flags.IntSlice("clientReadBufferSize", []int{-1}, "Configures the client read buffer size in bytes. If negative, use the default - may be a comma-separated list")
+	clientWriteBufferSize = flags.IntSlice("clientWriteBufferSize", []int{-1}, "Configures the client write buffer size in bytes. If negative, use the default - may be a comma-separated list")
+	serverReadBufferSize  = flags.IntSlice("serverReadBufferSize", []int{-1}, "Configures the server read buffer size in bytes. If negative, use the default - may be a comma-separated list")
+	serverWriteBufferSize = flags.IntSlice("serverWriteBufferSize", []int{-1}, "Configures the server write buffer size in bytes. If negative, use the default - may be a comma-separated list")
+	sleepBetweenRPCs      = flags.DurationSlice("sleepBetweenRPCs", []time.Duration{0}, "Configures the maximum amount of time the client should sleep between consecutive RPCs - may be a comma-separated list")
 	connections           = flag.Int("connections", 1, "The number of connections. Each connection will handle maxConcurrentCalls RPC streams")
 	recvBufferPool        = flags.StringWithAllowedValues("recvBufferPool", recvBufferPoolNil, "Configures the shared receive buffer pool. One of: nil, simple, all", allRecvBufferPools)
 	sharedWriteBuffer     = flags.StringWithAllowedValues("sharedWriteBuffer", toggleModeOff,

benchmark/latency/latency.go

@@ -65,7 +65,7 @@ type Network struct {
 var (
 	//Local simulates local network.
 	Local = Network{0, 0, 0}
-	//LAN simulates local area network network.
+	//LAN simulates local area network.
 	LAN = Network{100 * 1024, 2 * time.Millisecond, 1500}
 	//WAN simulates wide area network.
 	WAN = Network{20 * 1024, 30 * time.Millisecond, 1500}

benchmark/latency/latency_test.go

@@ -46,9 +46,9 @@ type bufConn struct {
 func (bufConn) Close() error                       { panic("unimplemented") }
 func (bufConn) LocalAddr() net.Addr                { panic("unimplemented") }
 func (bufConn) RemoteAddr() net.Addr               { panic("unimplemented") }
-func (bufConn) SetDeadline(t time.Time) error      { panic("unimplemneted") }
-func (bufConn) SetReadDeadline(t time.Time) error  { panic("unimplemneted") }
-func (bufConn) SetWriteDeadline(t time.Time) error { panic("unimplemneted") }
+func (bufConn) SetDeadline(t time.Time) error      { panic("unimplemented") }
+func (bufConn) SetReadDeadline(t time.Time) error  { panic("unimplemented") }
+func (bufConn) SetWriteDeadline(t time.Time) error { panic("unimplemented") }
 
 func restoreHooks() func() {
 	s := sleep

benchmark/primitives/syncmap_test.go

@@ -152,7 +152,7 @@ func benchmarkIncrementUint64Map(b *testing.B, f func() incrementUint64Map) {
 	}
 }
 
-func BenchmarkMapWithSyncMutexContetion(b *testing.B) {
+func BenchmarkMapWithSyncMutexContention(b *testing.B) {
 	benchmarkIncrementUint64Map(b, newMapWithLock)
 }
 

benchmark/stats/stats.go

@@ -293,7 +293,7 @@ type RunData struct {
 	Fiftieth time.Duration
 	// Ninetieth is the 90th percentile latency.
 	Ninetieth time.Duration
-	// Ninetyninth is the 99th percentile latency.
+	// NinetyNinth is the 99th percentile latency.
 	NinetyNinth time.Duration
 	// Average is the average latency.
 	Average time.Duration

benchmark/worker/main.go

@@ -141,7 +141,7 @@ func (s *workerServer) RunClient(stream testgrpc.WorkerService_RunClientServer)
 	var bc *benchmarkClient
 	defer func() {
 		// Shut down benchmark client when stream ends.
-		logger.Infof("shuting down benchmark client")
+		logger.Infof("shutting down benchmark client")
 		if bc != nil {
 			bc.shutdown()
 		}
@@ -160,7 +160,7 @@ func (s *workerServer) RunClient(stream testgrpc.WorkerService_RunClientServer)
 		case *testpb.ClientArgs_Setup:
 			logger.Infof("client setup received:")
 			if bc != nil {
-				logger.Infof("client setup received when client already exists, shuting down the existing client")
+				logger.Infof("client setup received when client already exists, shutting down the existing client")
 				bc.shutdown()
 			}
 			bc, err = startBenchmarkClient(t.Setup)

binarylog/binarylog_end2end_test.go

@@ -78,7 +78,7 @@ func (s *testBinLogSink) Write(e *binlogpb.GrpcLogEntry) error {
 
 func (s *testBinLogSink) Close() error { return nil }
 
-// Returns all client entris if client is true, otherwise return all server
+// Returns all client entries if client is true, otherwise return all server
 // entries.
 func (s *testBinLogSink) logEntries(client bool) []*binlogpb.GrpcLogEntry {
 	logger := binlogpb.GrpcLogEntry_LOGGER_SERVER

clientconn.go

@@ -1576,7 +1576,7 @@ func (ac *addrConn) tearDown(err error) {
 		} else {
 			// Hard close the transport when the channel is entering idle or is
 			// being shutdown. In the case where the channel is being shutdown,
-			// closing of transports is also taken care of by cancelation of cc.ctx.
+			// closing of transports is also taken care of by cancellation of cc.ctx.
 			// But in the case where the channel is entering idle, we need to
 			// explicitly close the transports here. Instead of distinguishing
 			// between these two cases, it is simpler to close the transport

clientconn_test.go

@@ -642,7 +642,7 @@ func (s) TestConnectParamsWithMinConnectTimeout(t *testing.T) {
 	defer conn.Close()
 
 	if got := conn.dopts.minConnectTimeout(); got != mct {
-		t.Errorf("unexpect minConnectTimeout on the connection: %v, want %v", got, mct)
+		t.Errorf("unexpected minConnectTimeout on the connection: %v, want %v", got, mct)
 	}
 }
 

credentials/alts/internal/conn/aeadrekey.go

@@ -49,7 +49,7 @@ func (k KeySizeError) Error() string {
 
 // newRekeyAEAD creates a new instance of aes128gcm with rekeying.
 // The key argument should be 44 bytes, the first 32 bytes are used as a key
-// for HKDF-expand and the remainining 12 bytes are used as a random mask for
+// for HKDF-expand and the remaining 12 bytes are used as a random mask for
 // the counter.
 func newRekeyAEAD(key []byte) (*rekeyAEAD, error) {
 	k := len(key)

credentials/alts/internal/conn/aes128gcmrekey.go

@@ -51,7 +51,7 @@ type aes128gcmRekey struct {
 
 // NewAES128GCMRekey creates an instance that uses aes128gcm with rekeying
 // for ALTS record. The key argument should be 44 bytes, the first 32 bytes
-// are used as a key for HKDF-expand and the remainining 12 bytes are used
+// are used as a key for HKDF-expand and the remaining 12 bytes are used
 // as a random mask for the counter.
 func NewAES128GCMRekey(side core.Side, key []byte) (ALTSRecordCrypto, error) {
 	inCounter := NewInCounter(side, overflowLenAES128GCMRekey)

credentials/alts/internal/conn/record_test.go

@@ -248,7 +248,7 @@ func testWriteLargeData(t *testing.T, rp string) {
 	// buffer size.
 	clientConn, serverConn := newConnPair(rp, nil, nil)
 	// Message size is intentionally chosen to not be multiple of
-	// payloadLengthLimtit.
+	// payloadLengthLimit.
 	msgSize := altsWriteBufferMaxSize + (100 * 1024)
 	clientMsg := make([]byte, msgSize)
 	for i := 0; i < msgSize; i++ {

credentials/local/local.go

@@ -108,7 +108,7 @@ func (c *localTC) Clone() credentials.TransportCredentials {
 }
 
 // OverrideServerName overrides the server name used to verify the hostname on the returned certificates from the server.
-// Since this feature is specific to TLS (SNI + hostname verification check), it does not take any effet for local credentials.
+// Since this feature is specific to TLS (SNI + hostname verification check), it does not take any effect for local credentials.
 func (c *localTC) OverrideServerName(serverNameOverride string) error {
 	c.info.ServerName = serverNameOverride
 	return nil

credentials/sts/sts.go

@@ -367,7 +367,7 @@ type requestParameters struct {
 	ActorTokenType string `json:"actor_token_type,omitempty"`
 }
 
-// nesponseParameters stores all attributes sent as JSON in a successful STS
+// responseParameters stores all attributes sent as JSON in a successful STS
 // response. These attributes are defined in
 // https://tools.ietf.org/html/rfc8693#section-2.2.1.
 type responseParameters struct {

examples/examples_test.sh

@@ -188,7 +188,7 @@ for example in ${EXAMPLES[@]}; do
         $(cat $CLIENT_LOG)
         "
     else
-        pass "client successfully communitcated with server"
+        pass "client successfully communicated with server"
     fi
 
     # Check server log for expected output if expecting an

examples/features/load_balancing/README.md

@@ -61,8 +61,8 @@ this is examples/load_balancing (from :50051)
 
 The second client is configured to use `round_robin`. `round_robin` connects to
 all the addresses it sees, and sends an RPC to each backend one at a time in
-order. E.g. the first RPC will be sent to backend-1, the second RPC will be be
-sent to backend-2, and the third RPC will be be sent to backend-1 again.
+order. E.g. the first RPC will be sent to backend-1, the second RPC will be
+sent to backend-2, and the third RPC will be sent to backend-1 again.
 
 ```
 this is examples/load_balancing (from :50051)

examples/features/multiplex/client/main.go

@@ -72,7 +72,7 @@ func main() {
 
 	fmt.Println()
 	fmt.Println("--- calling routeguide.RouteGuide/GetFeature ---")
-	// Make a routeguild client with the same ClientConn.
+	// Make a routeguide client with the same ClientConn.
 	rgc := ecpb.NewEchoClient(conn)
 	callUnaryEcho(rgc, "this is examples/multiplex")
 }

examples/features/orca/client/main.go

@@ -59,7 +59,7 @@ func main() {
 	ticker := time.NewTicker(time.Second)
 	for range ticker.C {
 		func() {
-			// Use an anonymous function to ensure context cancelation via defer.
+			// Use an anonymous function to ensure context cancellation via defer.
 			ctx, cancel := context.WithTimeout(context.Background(), time.Second)
 			defer cancel()
 			if _, err := c.UnaryEcho(ctx, &pb.EchoRequest{Message: "test echo message"}); err != nil {

gcp/observability/logging.go

@@ -248,7 +248,7 @@ type binaryMethodLogger struct {
 	clientSide bool
 }
 
-// buildGCPLoggingEntry converts the binary log log entry into a gcp logging
+// buildGCPLoggingEntry converts the binary log entry into a gcp logging
 // entry.
 func (bml *binaryMethodLogger) buildGCPLoggingEntry(ctx context.Context, c iblog.LogEntryConfig) gcplogging.Entry {
 	binLogEntry := bml.mlb.Build(c)

gcp/observability/logging_test.go

@@ -548,7 +548,7 @@ func (s) TestServerRPCEventsLogAll(t *testing.T) {
 // Client and Server RPC Events configured to log. Both sides should log and
 // share the exporter, so the exporter should receive the collective amount of
 // calls for both a client stream (corresponding to a Client RPC Event) and a
-// server stream (corresponding ot a Server RPC Event). The specificity of the
+// server stream (corresponding to a Server RPC Event). The specificity of the
 // entries are tested in previous tests.
 func (s) TestBothClientAndServerRPCEvents(t *testing.T) {
 	fle := &fakeLoggingExporter{

gcp/observability/observability_test.go

@@ -191,7 +191,7 @@ func (s) TestRefuseStartWithInvalidPatterns(t *testing.T) {
 	}
 }
 
-// TestRefuseStartWithExcludeAndWildCardAll tests the sceanrio where an
+// TestRefuseStartWithExcludeAndWildCardAll tests the scenario where an
 // observability configuration is provided with client RPC event specifying to
 // exclude, and which matches on the '*' wildcard (any). This should cause an
 // error when trying to start the observability system.

grpclog/grpclog.go

@@ -103,7 +103,7 @@ func Fatalf(format string, args ...any) {
 }
 
 // Fatalln logs to the FATAL log. Arguments are handled in the manner of fmt.Println.
-// It calle os.Exit()) with exit code 1.
+// It calls os.Exit() with exit code 1.
 func Fatalln(args ...any) {
 	grpclog.Logger.Fatalln(args...)
 	// Make sure fatal logs will exit.