Skip to content
This repository was archived by the owner on Jul 21, 2023. It is now read-only.

Commit 1404672

Browse files
author
Stephane Landelle
committed
Revert back some invalid nanoTime usage, close AsyncHttpClient#280
1 parent 736b0cc commit 1404672

File tree

7 files changed

+9
-17
lines changed

7 files changed

+9
-17
lines changed

api/src/main/java/com/ning/http/client/Realm.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
*/
1717
package com.ning.http.client;
1818

19-
import static com.ning.http.util.DateUtil.millisTime;
2019
import static com.ning.http.util.MiscUtil.isNonEmpty;
2120

2221
import java.io.UnsupportedEncodingException;
@@ -483,7 +482,7 @@ public RealmBuilder clone(Realm clone) {
483482
private void newCnonce() {
484483
try {
485484
MessageDigest md = MessageDigest.getInstance("MD5");
486-
byte[] b = md.digest(String.valueOf(millisTime()).getBytes("ISO-8859-1"));
485+
byte[] b = md.digest(String.valueOf(System.currentTimeMillis()).getBytes("ISO-8859-1"));
487486
cnonce = toHexString(b);
488487
} catch (Exception e) {
489488
throw new SecurityException(e);

api/src/main/java/com/ning/http/client/ntlm/NTLMEngine.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,6 @@
3838

3939
package com.ning.http.client.ntlm;
4040

41-
import static com.ning.http.util.DateUtil.millisTime;
4241
import com.ning.http.util.Base64;
4342

4443
import javax.crypto.Cipher;
@@ -514,7 +513,7 @@ private static byte[] createBlob(byte[] clientChallenge, byte[] targetInformatio
514513
byte[] blobSignature = new byte[]{(byte) 0x01, (byte) 0x01, (byte) 0x00, (byte) 0x00};
515514
byte[] reserved = new byte[]{(byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00};
516515
byte[] unknown1 = new byte[]{(byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00};
517-
long time = millisTime();
516+
long time = System.currentTimeMillis();
518517
time += 11644473600000l; // milliseconds from January 1, 1601 -> epoch.
519518
time *= 10000; // tenths of a microsecond.
520519
// convert to little-endian byte array.

api/src/main/java/com/ning/http/client/oauth/OAuthSignatureCalculator.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
*/
1717
package com.ning.http.client.oauth;
1818

19-
import static com.ning.http.util.DateUtil.millisTime;
2019
import com.ning.http.client.FluentStringsMap;
2120
import com.ning.http.client.Request;
2221
import com.ning.http.client.RequestBuilderBase;
@@ -78,15 +77,15 @@ public OAuthSignatureCalculator(ConsumerKey consumerAuth, RequestToken userAuth)
7877
mac = new ThreadSafeHMAC(consumerAuth, userAuth);
7978
this.consumerAuth = consumerAuth;
8079
this.userAuth = userAuth;
81-
random = new Random(System.identityHashCode(this) + millisTime());
80+
random = new Random(System.identityHashCode(this) + System.currentTimeMillis());
8281
}
8382

8483
//@Override // silly 1.5; doesn't allow this for interfaces
8584

8685
public void calculateAndAddSignature(String baseURL, Request request, RequestBuilderBase<?> requestBuilder) {
8786
String method = request.getMethod(); // POST etc
8887
String nonce = generateNonce();
89-
long timestamp = millisTime() / 1000L;
88+
long timestamp = System.currentTimeMillis() / 1000L;
9089
String signature = calculateSignature(method, baseURL, timestamp, nonce, request.getParams(), request.getQueryParams());
9190
String headerValue = constructAuthHeader(signature, nonce, timestamp);
9291
requestBuilder.setHeader(HEADER_AUTHORIZATION, headerValue);

api/src/main/java/com/ning/http/util/AsyncHttpProviderUtils.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,8 +12,6 @@
1212
*/
1313
package com.ning.http.util;
1414

15-
import static com.ning.http.util.DateUtil.millisTime;
16-
1715
import java.io.ByteArrayInputStream;
1816
import java.io.FileNotFoundException;
1917
import java.io.IOException;
@@ -547,7 +545,7 @@ public static int convertExpireField(String timestring) {
547545
for (SimpleDateFormat sdf : simpleDateFormat.get()) {
548546
Date date = sdf.parse(trimmedTimeString, new ParsePosition(0));
549547
if (date != null) {
550-
long now = millisTime();
548+
long now = System.currentTimeMillis();
551549
long maxAgeMillis = date.getTime() - now;
552550
return (int) (maxAgeMillis / 1000) + (maxAgeMillis % 1000 != 0 ? 1 : 0);
553551
}

providers/grizzly/src/main/java/com/ning/http/client/providers/grizzly/GrizzlyAsyncHttpProvider.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@
1313

1414
package com.ning.http.client.providers.grizzly;
1515

16-
import static com.ning.http.util.DateUtil.millisTime;
1716
import com.ning.org.jboss.netty.handler.codec.http.CookieDecoder;
1817
import com.ning.http.client.AsyncHandler;
1918
import com.ning.http.client.AsyncHttpClientConfig;
@@ -429,7 +428,7 @@ void touchConnection(final Connection c, final Request request) {
429428
int requestTimeout = AsyncHttpProviderUtils.requestTimeout(clientConfig, request);
430429
if (requestTimeout > 0) {
431430
if (resolver != null) {
432-
resolver.setTimeoutMillis(c, millisTime() + requestTimeout);
431+
resolver.setTimeoutMillis(c, System.currentTimeMillis() + requestTimeout);
433432
}
434433
}
435434

providers/grizzly/src/main/java/com/ning/http/client/providers/grizzly/GrizzlyConnectionsPool.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@
1313

1414
package com.ning.http.client.providers.grizzly;
1515

16-
import static com.ning.http.util.DateUtil.millisTime;
1716
import com.ning.http.client.AsyncHttpClientConfig;
1817
import com.ning.http.client.ConnectionsPool;
1918

@@ -310,7 +309,7 @@ private class DelayedRunnable implements Runnable {
310309
@Override
311310
public void run() {
312311
while (isStarted) {
313-
final long currentTimeMs = millisTime();
312+
final long currentTimeMs = System.currentTimeMillis();
314313

315314
for (final IdleConnectionQueue delayQueue : queues) {
316315
if (delayQueue.queue.isEmpty()) continue;
@@ -381,7 +380,7 @@ public IdleConnectionQueue(final long timeout) {
381380

382381
void offer(final Connection c) {
383382
if (timeout >= 0) {
384-
resolver.setTimeoutMs(c, millisTime() + timeout);
383+
resolver.setTimeoutMs(c, System.currentTimeMillis() + timeout);
385384
}
386385
queue.offer(c);
387386
count.incrementAndGet();

providers/netty/src/test/java/com/ning/http/client/providers/netty/NettyAsyncResponseTest.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@
1313

1414
package com.ning.http.client.providers.netty;
1515

16-
import static com.ning.http.util.DateUtil.millisTime;
1716
import com.ning.http.client.Cookie;
1817
import com.ning.http.client.FluentCaseInsensitiveStringsMap;
1918
import com.ning.http.client.HttpResponseHeaders;
@@ -39,7 +38,7 @@ public void testCookieParseExpires() {
3938
SimpleDateFormat sdf = new SimpleDateFormat("EEE, dd-MMM-yyyy HH:mm:ss z", Locale.US);
4039
sdf.setTimeZone(TimeZone.getTimeZone("GMT"));
4140

42-
Date date = new Date(millisTime() + 60000); // sdf.parse( dateString );
41+
Date date = new Date(System.currentTimeMillis() + 60000); // sdf.parse( dateString );
4342
final String cookieDef = String.format("efmembercheck=true; expires=%s; path=/; domain=.eclipse.org", sdf.format(date));
4443

4544
NettyResponse response = new NettyResponse(new ResponseStatus(null, null, null), new HttpResponseHeaders(null, null, false) {

0 commit comments

Comments
 (0)