Skip to content

Commit e49843a

Browse files
Address review comments
1 parent 44a8642 commit e49843a

2 files changed

Lines changed: 13 additions & 12 deletions

File tree

communication/src/main/java/datadog/communication/ddagent/SharedCommunicationObjects.java

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -60,9 +60,9 @@ public void createRemaining(Config config) {
6060
}
6161

6262
httpClientTimeout =
63-
!config.isCiVisibilityEnabled()
64-
? TimeUnit.SECONDS.toMillis(config.getAgentTimeout())
65-
: config.getCiVisibilityBackendApiTimeoutMillis();
63+
config.isCiVisibilityEnabled()
64+
? config.getCiVisibilityBackendApiTimeoutMillis()
65+
: TimeUnit.SECONDS.toMillis(config.getAgentTimeout());
6666

6767
forceClearTextHttpForIntakeClient = config.isForceClearTextHttpForIntakeClient();
6868

@@ -78,10 +78,7 @@ public void createRemaining(Config config) {
7878
String namedPipe = config.getAgentNamedPipe();
7979
agentHttpClient =
8080
OkHttpUtils.buildHttpClient(
81-
agentUrl != null && "http".equals(agentUrl.scheme()),
82-
unixDomainSocket,
83-
namedPipe,
84-
httpClientTimeout);
81+
OkHttpUtils.isPlainHttp(agentUrl), unixDomainSocket, namedPipe, httpClientTimeout);
8582
}
8683
}
8784

@@ -228,9 +225,9 @@ public String get() {
228225
}
229226

230227
public OkHttpClient getIntakeHttpClient() {
231-
OkHttpClient intakeHttpClient = this.intakeHttpClient;
232-
if (intakeHttpClient != null) {
233-
return intakeHttpClient;
228+
OkHttpClient client = this.intakeHttpClient;
229+
if (client != null) {
230+
return client;
234231
}
235232

236233
synchronized (this) {

communication/src/main/java/datadog/communication/http/OkHttpUtils.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ public final class OkHttpUtils {
5858
SystemProperties.getOrDefault("java.vm.vendor", "unknown");
5959

6060
public static OkHttpClient buildHttpClient(final HttpUrl url, final long timeoutMillis) {
61-
return buildHttpClient(url != null && "http".equals(url.scheme()), null, null, timeoutMillis);
61+
return buildHttpClient(isPlainHttp(url), null, null, timeoutMillis);
6262
}
6363

6464
public static OkHttpClient buildHttpClient(
@@ -95,7 +95,7 @@ public static OkHttpClient buildHttpClient(
9595
discoverApmSocket(config),
9696
config.getAgentNamedPipe(),
9797
dispatcher,
98-
url != null && "http".equals(url.scheme()),
98+
isPlainHttp(url),
9999
retryOnConnectionFailure,
100100
maxRunningRequests,
101101
proxyHost,
@@ -392,4 +392,8 @@ private static void closeQuietly(Response response) {
392392
// ignore
393393
}
394394
}
395+
396+
public static boolean isPlainHttp(final HttpUrl url) {
397+
return url != null && "http".equalsIgnoreCase(url.scheme());
398+
}
395399
}

0 commit comments

Comments
 (0)