Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion gapic-libraries-bom/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
<groupId>com.google.cloud</groupId>
<artifactId>gapic-libraries-bom</artifactId>
<packaging>pom</packaging>
<version>1.85.1</version><!-- {x-version-update:google-cloud-java:current} -->
<version>1.85.0</version><!-- {x-version-update:google-cloud-java:current} -->
<name>Google Cloud Java BOM</name>
<description>
BOM for the libraries in google-cloud-java repository. Users should not
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,16 +42,20 @@ public class XGoogSpannerRequestId {
@VisibleForTesting
static final long VERSION = 1; // The version of the specification being implemented.

private static final String STATIC_PREFIX = VERSION + "." + RAND_PROCESS_ID + ".";

private final long nthClientId;
private final long nthRequest;
private long nthChannelId;
private long attempt;
private final String instancePrefix;

XGoogSpannerRequestId(long nthClientId, long nthChannelId, long nthRequest, long attempt) {
this.nthClientId = nthClientId;
this.nthChannelId = nthChannelId;
this.nthRequest = nthRequest;
this.attempt = attempt;
this.instancePrefix = STATIC_PREFIX + nthClientId + ".";
}

public static XGoogSpannerRequestId of(
Expand Down Expand Up @@ -122,26 +126,27 @@ private static String generateRandProcessId() {

/** Returns the string representation of this RequestId as it should be sent to Spanner. */
public String getHeaderValue() {
return String.format(
"%d.%s.%d.%d.%d.%d",
XGoogSpannerRequestId.VERSION,
XGoogSpannerRequestId.RAND_PROCESS_ID,
this.nthClientId,
this.nthChannelId,
this.nthRequest,
this.attempt);
return new StringBuilder(64)
Comment thread
olavloite marked this conversation as resolved.
Outdated
.append(this.instancePrefix)
.append(this.nthChannelId)
.append('.')
.append(this.nthRequest)
.append('.')
.append(this.attempt)
.toString();
}

@Override
public String toString() {
return String.format(
"%d.%s.%d.%s.%d.%d",
XGoogSpannerRequestId.VERSION,
XGoogSpannerRequestId.RAND_PROCESS_ID,
this.nthClientId,
this.nthChannelId < 0 ? "x" : String.valueOf(this.nthChannelId),
this.nthRequest,
this.attempt);
StringBuilder sb = new StringBuilder(64);
Comment thread
olavloite marked this conversation as resolved.
Outdated
sb.append(this.instancePrefix);
if (this.nthChannelId < 0) {
sb.append('x');
} else {
sb.append(this.nthChannelId);
}
sb.append('.').append(this.nthRequest).append('.').append(this.attempt);
return sb.toString();
}

public String debugToString() {
Expand Down
Loading