11package datadog .communication .http ;
22
3- import static datadog .common . socket .SocketUtils .discoverApmSocket ;
3+ import static datadog .communication . http .SocketUtils .discoverApmSocket ;
44import static java .util .concurrent .TimeUnit .MILLISECONDS ;
55import static java .util .concurrent .TimeUnit .SECONDS ;
66
@@ -68,6 +68,7 @@ public static OkHttpClient buildHttpClient(
6868 final long timeoutMillis ) {
6969 return buildHttpClient (
7070 unixDomainSocketPath ,
71+ Config .get ().isJdkSocketEnabled (),
7172 namedPipe ,
7273 null ,
7374 isHttp ,
@@ -77,7 +78,8 @@ public static OkHttpClient buildHttpClient(
7778 null ,
7879 null ,
7980 null ,
80- timeoutMillis );
81+ timeoutMillis ,
82+ Config .get ().isAgentConfiguredUsingDefault ());
8183 }
8284
8385 public static OkHttpClient buildHttpClient (
@@ -93,6 +95,7 @@ public static OkHttpClient buildHttpClient(
9395 final long timeoutMillis ) {
9496 return buildHttpClient (
9597 discoverApmSocket (config ),
98+ config .isJdkSocketEnabled (),
9699 config .getAgentNamedPipe (),
97100 dispatcher ,
98101 isPlainHttp (url ),
@@ -102,13 +105,15 @@ public static OkHttpClient buildHttpClient(
102105 proxyPort ,
103106 proxyUsername ,
104107 proxyPassword ,
105- timeoutMillis );
108+ timeoutMillis ,
109+ config .isAgentConfiguredUsingDefault ());
106110 }
107111
108112 public abstract static class CustomListener extends EventListener {}
109113
110114 private static OkHttpClient buildHttpClient (
111115 final String unixDomainSocketPath ,
116+ final boolean useJdkUnixDomainSocket ,
112117 final String namedPipe ,
113118 final Dispatcher dispatcher ,
114119 final boolean isHttp ,
@@ -118,7 +123,8 @@ private static OkHttpClient buildHttpClient(
118123 final Integer proxyPort ,
119124 final String proxyUsername ,
120125 final String proxyPassword ,
121- final long timeoutMillis ) {
126+ final long timeoutMillis ,
127+ final boolean agentConfiguredUsingDefault ) {
122128 final OkHttpClient .Builder builder = new OkHttpClient .Builder ();
123129
124130 try {
@@ -144,7 +150,9 @@ private static OkHttpClient buildHttpClient(
144150 dispatcher != null ? dispatcher : new Dispatcher (RejectingExecutorService .INSTANCE ));
145151
146152 if (unixDomainSocketPath != null ) {
147- builder .socketFactory (new UnixDomainSocketFactory (new File (unixDomainSocketPath )));
153+ builder .socketFactory (
154+ new UnixDomainSocketFactory (
155+ new File (unixDomainSocketPath ), useJdkUnixDomainSocket , agentConfiguredUsingDefault ));
148156 log .debug ("Using UnixDomainSocket as http transport" );
149157 } else if (namedPipe != null ) {
150158 builder .socketFactory (new NamedPipeSocketFactory (namedPipe ));
0 commit comments