update state checking

mutianf · mutianf · commit e883101fa19d · 2026-05-19T09:58:00.000-04:00
diff --git a/java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/VRpcImpl.java b/java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/VRpcImpl.java
@@ -168,8 +168,7 @@ public void start(ReqT req, VRpcCallContext ctx, VRpcListener<RespT> listener) {
 
   void handleSessionClose(VRpcResult result) {
     synchronized (lock) {
-      if (state != State.STARTED && state != State.CANCELLED) {
-        logger.warning("tried to close a vRPC after it was already closed state: " + state);
+      if (state == State.CLOSED) {
         return;
       }
       state = State.CLOSED;

Original file line number	Diff line number	Diff line change
`@@ -168,8 +168,7 @@ public void start(ReqT req, VRpcCallContext ctx, VRpcListener<RespT> listener) {`
`168`	`168`
`169`	`169`	`void handleSessionClose(VRpcResult result) {`
`170`	`170`	`synchronized (lock) {`
`171`		`- if (state != State.STARTED && state != State.CANCELLED) {`
`172`		`- logger.warning("tried to close a vRPC after it was already closed state: " + state);`
	`171`	`+ if (state == State.CLOSED) {`
`173`	`172`	`return;`
`174`	`173`	`}`
`175`	`174`	`state = State.CLOSED;`