remove onVRpcStarted

Change-Id: I1064ff6be95987c994360119c832e9e55abe60e5

Author: mutianf

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/SessionList.java

@@ -111,7 +111,7 @@ public Optional<SessionHandle> checkoutSession(AfeHandle afeHandle) {
         handle -> {
           poolStats.readyCount--;
           poolStats.inUseCount++;
-
+          inUseSessions.add(handle);
           if (handle.afe.get().sessions.isEmpty()) {
             afesWithReadySessions.remove(afeHandle);
           }
@@ -194,11 +194,6 @@ void onSessionStarted() {
       poolStats.readyCount++;
     }
 
-    void onVRpcStarted() {
-      // Pool stats and AFE list are updated in SessionList#checkoutSession
-      inUseSessions.add(this);
-    }
-
     /**
      * The session is returned to the pool after use. This undoes what SessionList#checkoutSession
      */

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/session/SessionPoolImpl.java

@@ -577,7 +577,6 @@ private <ReqT extends Message, RespT extends Message> VRpc<ReqT, RespT> newRealC
     return new ForwardingVRpc<ReqT, RespT>(handle.getSession().newCall(desc)) {
       @Override
       public void start(ReqT req, VRpcCallContext ctx, VRpcListener<RespT> listener) {
-        handle.onVRpcStarted();
         final Stopwatch stopwatch = Stopwatch.createStarted();
         super.start(
             req,

google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/stub/SessionDeadlineTest.java

@@ -34,6 +34,7 @@
 import io.grpc.ServerCall;
 import io.grpc.ServerCallHandler;
 import io.grpc.ServerInterceptor;
+import io.grpc.netty.shaded.io.grpc.netty.NettyServerBuilder;
 import io.grpc.stub.StreamObserver;
 import java.io.IOException;
 import java.util.concurrent.ExecutionException;
@@ -52,7 +53,7 @@ public class SessionDeadlineTest {
   public void setUp() throws IOException {
     fakeDataService = new FakeDataService();
     server =
-        io.grpc.netty.shaded.io.grpc.netty.NettyServerBuilder.forPort(0)
+        NettyServerBuilder.forPort(0)
             .addService(fakeDataService)
             .intercept(new ResponseHeaderInterceptor())
             .build()