Skip to content

Commit eaf801d

Browse files
committed
Rename Dns related methods into hostname
1 parent fecb116 commit eaf801d

File tree

7 files changed

+46
-44
lines changed

7 files changed

+46
-44
lines changed

client/src/main/java/org/asynchttpclient/handler/AsyncHandlerExtensions.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -29,27 +29,27 @@ public interface AsyncHandlerExtensions {
2929
// ////////// DNS /////////////////
3030

3131
/**
32-
* Notify the callback before DNS resolution
32+
* Notify the callback before hostname resolution
3333
*
3434
* @param name the name to be resolved
3535
*/
36-
void onDnsResolution(String name);
36+
void onHostnameResolutionAttempt(String name);
3737

3838
/**
39-
* Notify the callback after DNS resolution was successful.
39+
* Notify the callback after hostname resolution was successful.
4040
*
4141
* @param name the name to be resolved
4242
* @param addresses the resolved addresses
4343
*/
44-
void onDnsResolutionSuccess(String name, List<InetSocketAddress> addresses);
44+
void onHostnameResolutionSuccess(String name, List<InetSocketAddress> addresses);
4545

4646
/**
47-
* Notify the callback after DNS resolution failed.
47+
* Notify the callback after hostname resolution failed.
4848
*
4949
* @param name the name to be resolved
5050
* @param cause the failure cause
5151
*/
52-
void onDnsResolutionFailure(String name, Throwable cause);
52+
void onHostnameResolutionFailure(String name, Throwable cause);
5353

5454
// ////////////// TCP CONNECT ////////
5555

client/src/main/java/org/asynchttpclient/handler/ExtendedAsyncHandler.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,15 +24,15 @@
2424
public abstract class ExtendedAsyncHandler<T> implements AsyncHandler<T>, AsyncHandlerExtensions {
2525

2626
@Override
27-
public void onDnsResolution(String name) {
27+
public void onHostnameResolutionAttempt(String name) {
2828
}
2929

3030
@Override
31-
public void onDnsResolutionSuccess(String name, List<InetSocketAddress> addresses) {
31+
public void onHostnameResolutionSuccess(String name, List<InetSocketAddress> addresses) {
3232
}
3333

3434
@Override
35-
public void onDnsResolutionFailure(String name, Throwable cause) {
35+
public void onHostnameResolutionFailure(String name, Throwable cause) {
3636
}
3737

3838
@Override

client/src/main/java/org/asynchttpclient/resolver/RequestNameResolver.java

Lines changed: 21 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -58,30 +58,32 @@ public Future<List<InetSocketAddress>> resolve(Request request, ProxyServer prox
5858
}
5959

6060
if (asyncHandlerExtensions != null)
61-
asyncHandlerExtensions.onDnsResolution(name);
61+
asyncHandlerExtensions.onHostnameResolutionAttempt(name);
6262

6363
final Future<List<InetSocketAddress>> whenResolved = request.getNameResolver().resolve(name, port);
6464

6565
if (asyncHandlerExtensions == null)
6666
return whenResolved;
6767

68-
Promise<List<InetSocketAddress>> promise = ImmediateEventExecutor.INSTANCE.newPromise();
69-
70-
whenResolved.addListener(new SimpleGenericFutureListener<List<InetSocketAddress>>() {
71-
72-
@Override
73-
protected void onSuccess(List<InetSocketAddress> addresses) throws Exception {
74-
asyncHandlerExtensions.onDnsResolutionSuccess(name, addresses);
75-
promise.setSuccess(addresses);
76-
}
77-
78-
@Override
79-
protected void onFailure(Throwable t) throws Exception {
80-
asyncHandlerExtensions.onDnsResolutionFailure(name, t);
81-
promise.setFailure(t);
82-
}
83-
});
84-
85-
return promise;
68+
else {
69+
Promise<List<InetSocketAddress>> promise = ImmediateEventExecutor.INSTANCE.newPromise();
70+
71+
whenResolved.addListener(new SimpleGenericFutureListener<List<InetSocketAddress>>() {
72+
73+
@Override
74+
protected void onSuccess(List<InetSocketAddress> addresses) throws Exception {
75+
asyncHandlerExtensions.onHostnameResolutionSuccess(name, addresses);
76+
promise.setSuccess(addresses);
77+
}
78+
79+
@Override
80+
protected void onFailure(Throwable t) throws Exception {
81+
asyncHandlerExtensions.onHostnameResolutionFailure(name, t);
82+
promise.setFailure(t);
83+
}
84+
});
85+
86+
return promise;
87+
}
8688
}
8789
}

client/src/test/java/org/asynchttpclient/BasicHttpTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1396,8 +1396,8 @@ public void testNewConnectionEventsFired() throws Exception {
13961396

13971397
Object[] expectedEvents = new Object[] {//
13981398
CONNECTION_POOL_EVENT,//
1399-
DNS_RESOLUTION_EVENT,//
1400-
DNS_RESOLUTION_SUCCESS_EVENT,//
1399+
HOSTNAME_RESOLUTION_EVENT,//
1400+
HOSTNAME_RESOLUTION_SUCCESS_EVENT,//
14011401
CONNECTION_OPEN_EVENT,//
14021402
CONNECTION_SUCCESS_EVENT,//
14031403
REQUEST_SEND_EVENT,//

client/src/test/java/org/asynchttpclient/BasicHttpsTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -138,8 +138,8 @@ public void testNormalEventsFired() throws Exception {
138138

139139
Object[] expectedEvents = new Object[] { //
140140
CONNECTION_POOL_EVENT,//
141-
DNS_RESOLUTION_EVENT,//
142-
DNS_RESOLUTION_SUCCESS_EVENT,//
141+
HOSTNAME_RESOLUTION_EVENT,//
142+
HOSTNAME_RESOLUTION_SUCCESS_EVENT,//
143143
CONNECTION_OPEN_EVENT,//
144144
CONNECTION_SUCCESS_EVENT,//
145145
TLS_HANDSHAKE_EVENT,//

client/src/test/java/org/asynchttpclient/netty/handler/NettyReactiveStreamsTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -127,11 +127,11 @@ public ReplayedSimpleAsyncHandler(CountDownLatch replaying, SimpleSubscriber<Htt
127127
this.replaying = replaying;
128128
}
129129
@Override
130-
public void onDnsResolution(String name) {}
130+
public void onHostnameResolutionAttempt(String name) {}
131131
@Override
132-
public void onDnsResolutionSuccess(String name, List<InetSocketAddress> addresses) {}
132+
public void onHostnameResolutionSuccess(String name, List<InetSocketAddress> addresses) {}
133133
@Override
134-
public void onDnsResolutionFailure(String name, Throwable cause) {}
134+
public void onHostnameResolutionFailure(String name, Throwable cause) {}
135135
@Override
136136
public void onTcpConnect(InetSocketAddress address) {}
137137
@Override

client/src/test/java/org/asynchttpclient/test/EventCollectingHandler.java

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -37,9 +37,9 @@ public class EventCollectingHandler extends AsyncCompletionHandlerBase implement
3737
public static final String HEADERS_WRITTEN_EVENT = "HeadersWritten";
3838
public static final String CONTENT_WRITTEN_EVENT = "ContentWritten";
3939
public static final String CONNECTION_OPEN_EVENT = "ConnectionOpen";
40-
public static final String DNS_RESOLUTION_EVENT = "DnsResolution";
41-
public static final String DNS_RESOLUTION_SUCCESS_EVENT = "DnsResolutionSuccess";
42-
public static final String DNS_RESOLUTION_FAILURE_EVENT = "DnsResolutionFailure";
40+
public static final String HOSTNAME_RESOLUTION_EVENT = "HostnameResolution";
41+
public static final String HOSTNAME_RESOLUTION_SUCCESS_EVENT = "HostnameResolutionSuccess";
42+
public static final String HOSTNAME_RESOLUTION_FAILURE_EVENT = "HostnameResolutionFailure";
4343
public static final String CONNECTION_SUCCESS_EVENT = "ConnectionSuccess";
4444
public static final String CONNECTION_FAILURE_EVENT = "ConnectionFailure";
4545
public static final String TLS_HANDSHAKE_EVENT = "TlsHandshake";
@@ -110,18 +110,18 @@ public void onTcpConnectFailure(InetSocketAddress address, Throwable t) {
110110
}
111111

112112
@Override
113-
public void onDnsResolution(String name) {
114-
firedEvents.add(DNS_RESOLUTION_EVENT);
113+
public void onHostnameResolutionAttempt(String name) {
114+
firedEvents.add(HOSTNAME_RESOLUTION_EVENT);
115115
}
116116

117117
@Override
118-
public void onDnsResolutionSuccess(String name, List<InetSocketAddress> addresses) {
119-
firedEvents.add(DNS_RESOLUTION_SUCCESS_EVENT);
118+
public void onHostnameResolutionSuccess(String name, List<InetSocketAddress> addresses) {
119+
firedEvents.add(HOSTNAME_RESOLUTION_SUCCESS_EVENT);
120120
}
121121

122122
@Override
123-
public void onDnsResolutionFailure(String name, Throwable cause) {
124-
firedEvents.add(DNS_RESOLUTION_FAILURE_EVENT);
123+
public void onHostnameResolutionFailure(String name, Throwable cause) {
124+
firedEvents.add(HOSTNAME_RESOLUTION_FAILURE_EVENT);
125125
}
126126

127127
@Override

0 commit comments

Comments
 (0)