This repository was archived by the owner on Apr 7, 2026. It is now read-only.
File tree Expand file tree Collapse file tree
google-cloud-spanner/src/main/java/com/google/cloud/spanner Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -567,6 +567,7 @@ MultiplexedSessionMaintainer getMaintainer() {
567567 }
568568
569569 ApiFuture <SessionReference > getCurrentSessionReferenceFuture () {
570+ System .out .println ("Accessing Multiplexed Session " + Instant .now ());
570571 return ApiFutures .catchingAsync (
571572 this .multiplexedSessionReference .get (),
572573 Throwable .class ,
@@ -583,6 +584,7 @@ private void maybeRetrySessionCreation() {
583584 if (isValid ()
584585 && isMultiplexedSessionsSupported ()
585586 && retryingSessionCreation .compareAndSet (false , true )) {
587+ System .out .println ("Retrying Multiplexed Session " + Instant .now ());
586588 SettableApiFuture <SessionReference > settableApiFuture = SettableApiFuture .create ();
587589 asyncCreateMultiplexedSession (settableApiFuture );
588590 multiplexedSessionReference .set (settableApiFuture );
Original file line number Diff line number Diff line change 2727import com .google .common .collect .ImmutableMap ;
2828import com .google .common .collect .Maps ;
2929import io .opentelemetry .api .common .Attributes ;
30+ import java .time .Instant ;
3031import java .util .ArrayList ;
3132import java .util .Collections ;
3233import java .util .List ;
@@ -271,6 +272,7 @@ void createMultiplexedSession(SessionConsumer consumer) {
271272 * GRPC channel. In case of an error during the gRPC calls, an exception will be thrown.
272273 */
273274 SessionImpl createMultiplexedSession () {
275+ System .out .println ("Creating Multiplexed Session " + Instant .now ());
274276 ISpan span =
275277 spanner
276278 .getTracer ()
You can’t perform that action at this time.
0 commit comments