Skip to content

Commit 6b52988

Browse files
committed
Apply allOptions copy everywhere
1 parent 9d028b0 commit 6b52988

File tree

3 files changed

+9
-8
lines changed

3 files changed

+9
-8
lines changed

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

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -440,9 +440,13 @@ private TransactionOption[] withReqId(
440440
if (reqId == null) {
441441
return options;
442442
}
443-
ArrayList<TransactionOption> allOptions = new ArrayList(Arrays.asList(options));
444-
allOptions.add(new Options.RequestIdOption(reqId));
445-
return allOptions.toArray(new TransactionOption[0]);
443+
if (options == null || options.length == 0) {
444+
return new TransactionOption[] {new Options.RequestIdOption(reqId)};
445+
}
446+
TransactionOption[] allOptions = new TransactionOption[options.length + 1];
447+
System.arraycopy(options, 0, allOptions, 0, options.length);
448+
allOptions[options.length] = new Options.RequestIdOption(reqId);
449+
return allOptions;
446450
}
447451

448452
private long executePartitionedUpdateWithPooledSession(

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ interface SessionTransaction {
126126
private final Clock clock;
127127
private final Map<SpannerRpc.Option, ?> options;
128128
private final ErrorHandler errorHandler;
129-
private final XGoogSpannerRequestId.RequestIdCreator requestIdCreator;
129+
private XGoogSpannerRequestId.RequestIdCreator requestIdCreator;
130130

131131
SessionImpl(SpannerImpl spanner, SessionReference sessionReference) {
132132
this(spanner, sessionReference, NO_CHANNEL_HINT);

google-cloud-spanner/src/main/java/com/google/cloud/spanner/spi/v1/GapicSpannerRpc.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2052,10 +2052,7 @@ <ReqT, RespT> GrpcCallContext newCallContext(
20522052
context = context.withChannelAffinity(affinity.intValue());
20532053
}
20542054
}
2055-
if (method != null) {
2056-
String methodName = method.getFullMethodName();
2057-
context = withRequestId(context, options);
2058-
}
2055+
context = withRequestId(context, options);
20592056
}
20602057
context = context.withExtraHeaders(metadataProvider.newExtraHeaders(resource, projectName));
20612058
if (routeToLeader && leaderAwareRoutingEnabled) {

0 commit comments

Comments
 (0)