Revert "alts: Queue ALTS handshakes once limit is reached rather than dropping. (#6884)" (#6903)

This reverts commit adc76852e0.

credentials/alts/alts_test.go

@@ -397,7 +397,7 @@ func establishAltsConnection(t *testing.T, handshakerAddress, serverAddress stri
 		if err == nil {
 			break
 		}
-		if code := status.Code(err); code == codes.Unavailable || code == codes.DeadlineExceeded {
+		if code := status.Code(err); code == codes.Unavailable {
 			// The server is not ready yet. Try again.
 			continue
 		}

credentials/alts/internal/handshaker/handshaker.go

@@ -61,6 +61,8 @@ var (
 	// control number of concurrent created (but not closed) handshakes.
 	clientHandshakes = semaphore.NewWeighted(int64(envconfig.ALTSMaxConcurrentHandshakes))
 	serverHandshakes = semaphore.NewWeighted(int64(envconfig.ALTSMaxConcurrentHandshakes))
+	// errDropped occurs when maxPendingHandshakes is reached.
+	errDropped = errors.New("maximum number of concurrent ALTS handshakes is reached")
 	// errOutOfBound occurs when the handshake service returns a consumed
 	// bytes value larger than the buffer that was passed to it originally.
 	errOutOfBound = errors.New("handshaker service consumed bytes value is out-of-bound")
@@ -154,8 +156,8 @@ func NewServerHandshaker(ctx context.Context, conn *grpc.ClientConn, c net.Conn,
 // ClientHandshake starts and completes a client ALTS handshake for GCP. Once
 // done, ClientHandshake returns a secure connection.
 func (h *altsHandshaker) ClientHandshake(ctx context.Context) (net.Conn, credentials.AuthInfo, error) {
-	if err := clientHandshakes.Acquire(ctx, 1); err != nil {
+	if !clientHandshakes.TryAcquire(1) {
-		return nil, nil, err
+		return nil, nil, errDropped
 	}
 	defer clientHandshakes.Release(1)
 
@@ -207,8 +209,8 @@ func (h *altsHandshaker) ClientHandshake(ctx context.Context) (net.Conn, credent
 // ServerHandshake starts and completes a server ALTS handshake for GCP. Once
 // done, ServerHandshake returns a secure connection.
 func (h *altsHandshaker) ServerHandshake(ctx context.Context) (net.Conn, credentials.AuthInfo, error) {
-	if err := serverHandshakes.Acquire(ctx, 1); err != nil {
+	if !serverHandshakes.TryAcquire(1) {
-		return nil, nil, err
+		return nil, nil, errDropped
 	}
 	defer serverHandshakes.Release(1)
 

credentials/alts/internal/handshaker/handshaker_test.go

@@ -193,10 +193,10 @@ func (s) TestClientHandshake(t *testing.T) {
 			}()
 		}
 
-		// Ensure that there are no errors.
+		// Ensure all errors are expected.
 		for i := 0; i < testCase.numberOfHandshakes; i++ {
-			if err := <-errc; err != nil {
+			if err := <-errc; err != nil && err != errDropped {
-				t.Errorf("ClientHandshake() = _, %v, want _, <nil>", err)
+				t.Errorf("ClientHandshake() = _, %v, want _, <nil> or %v", err, errDropped)
 			}
 		}
 
@@ -250,10 +250,10 @@ func (s) TestServerHandshake(t *testing.T) {
 			}()
 		}
 
-		// Ensure that there are no errors.
+		// Ensure all errors are expected.
 		for i := 0; i < testCase.numberOfHandshakes; i++ {
-			if err := <-errc; err != nil {
+			if err := <-errc; err != nil && err != errDropped {
-				t.Errorf("ServerHandshake() = _, %v, want _, <nil>", err)
+				t.Errorf("ServerHandshake() = _, %v, want _, <nil> or %v", err, errDropped)
 			}
 		}