Add runner logs

Author: sakthivelmanii

google-cloud-spanner/src/main/java/com/google/cloud/spanner/AsyncResultSetImpl.java

@@ -340,6 +340,7 @@ public void run() {
   private class ProduceRowsRunnable implements Runnable {
     @Override
     public void run() {
+      System.out.println("ProduceRowsRunnable");
       boolean stop = false;
       boolean hasNext = false;
       try {
@@ -515,6 +516,7 @@ private void initiateProduceRows() {
       }
       produceRowsInitiated = true;
     }
+    System.out.println("initiateProduceRows");
     this.service.execute(new ProduceRowsRunnable());
   }
 

google-cloud-spanner/src/main/java/com/google/cloud/spanner/GrpcResultSet.java

@@ -78,6 +78,7 @@ public boolean next() throws SpannerException {
     if (error != null) {
       throw newSpannerException(error);
     }
+    System.out.println("GrpcResultSet next");
     try {
       if (currRow == null) {
         metadata = iterator.getMetadata();

google-cloud-spanner/src/main/java/com/google/cloud/spanner/ResumableStreamIterator.java

@@ -226,6 +226,7 @@ public boolean isWithBeginTransaction() {
   @Override
   @InternalApi
   public boolean initiateStreaming(AsyncResultSet.StreamMessageListener streamMessageListener) {
+    System.out.println("Inside initiateStreaming");
     this.streamMessageListener = streamMessageListener;
     startGrpcStreaming();
     return true;
@@ -317,6 +318,7 @@ && prepareIteratorForRetryOnDifferentGrpcChannel()) {
   }
 
   private void startGrpcStreaming() {
+    System.out.println("Starting Stream");
     if (stream == null) {
       span.addAnnotation(
           "Starting/Resuming stream",
@@ -325,6 +327,7 @@ private void startGrpcStreaming() {
       try (IScope scope = tracer.withSpan(span)) {
         // When start a new stream set the Span as current to make the gRPC Span a child of
         // this Span.
+        System.out.println("Creating Stream");
         stream = checkNotNull(startStream(resumeToken, streamMessageListener));
       }
     }

google-cloud-spanner/src/test/java/com/google/cloud/spanner/MockSpannerServiceImpl.java

@@ -651,6 +651,7 @@ private ByteString generateTransactionName(String session) {
       counter = new AtomicLong();
       transactionCounters.put(session, counter);
     }
+    System.out.printf("Generating session using Session ID %s\n", session);
     return ByteString.copyFromUtf8(
         String.format("%s/transactions/%d", session, counter.incrementAndGet()));
   }
@@ -1658,6 +1659,7 @@ public void read(final ReadRequest request, StreamObserver<ResultSet> responseOb
   @Override
   public void streamingRead(
       final ReadRequest request, StreamObserver<PartialResultSet> responseObserver) {
+    System.out.println("StreamingRead");
     requests.add(request);
     Preconditions.checkNotNull(request.getSession());
     Session session = getSession(request.getSession());
@@ -1999,6 +2001,8 @@ private void ensureMostRecentTransaction(Session session, ByteString transaction
       if (index > -1) {
         long id = Long.parseLong(transactionId.toStringUtf8().substring(index + 1));
         if (id != counter.get()) {
+          System.out.printf(
+              "Session ID %s TransactionId %s\n", session.getName(), transactionId.toStringUtf8());
           throw Status.FAILED_PRECONDITION
               .withDescription(
                   String.format(

google-cloud-spanner/src/test/java/com/google/cloud/spanner/RetryOnInvalidatedSessionTest.java

@@ -60,7 +60,10 @@
 import org.junit.AfterClass;
 import org.junit.Before;
 import org.junit.BeforeClass;
+import org.junit.Rule;
 import org.junit.Test;
+import org.junit.rules.TestWatcher;
+import org.junit.runner.Description;
 import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
 import org.junit.runners.Parameterized.Parameter;
@@ -75,6 +78,25 @@ public Long apply(StructReader input) {
     }
   }
 
+  @Rule
+  public TestWatcher testWatcher =
+      new TestWatcher() {
+        @Override
+        protected void succeeded(Description description) {
+          System.out.println("Succeeded test " + description.getMethodName());
+        }
+
+        @Override
+        protected void failed(Throwable e, Description description) {
+          System.out.println("Failed test " + description.getMethodName());
+        }
+
+        @Override
+        protected void starting(Description description) {
+          System.out.println("Starting test " + description.getMethodName());
+        }
+      };
+
   private static final ToLongTransformer TO_LONG = new ToLongTransformer();
 
   @Parameter(0)