Skip to content

Commit 4b2886e

Browse files
author
Stephane Landelle
committed
Revert back some invalid nanoTime usage, close AsyncHttpClient#280
1 parent 91fa184 commit 4b2886e

File tree

7 files changed

+10
-21
lines changed

7 files changed

+10
-21
lines changed

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 org.slf4j.Logger;
@@ -476,7 +475,7 @@ public RealmBuilder clone(Realm clone) {
476475
private void newCnonce() {
477476
try {
478477
MessageDigest md = MessageDigest.getInstance("MD5");
479-
byte[] b = md.digest(String.valueOf(millisTime()).getBytes("ISO-8859-1"));
478+
byte[] b = md.digest(String.valueOf(System.currentTimeMillis()).getBytes("ISO-8859-1"));
480479
cnonce = toHexString(b);
481480
} catch (Exception e) {
482481
throw new SecurityException(e);

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 static com.ning.http.util.MiscUtil.isNonEmpty;
4342

4443
import java.io.UnsupportedEncodingException;
@@ -517,7 +516,7 @@ private static byte[] createBlob(byte[] clientChallenge, byte[] targetInformatio
517516
byte[] blobSignature = new byte[]{(byte) 0x01, (byte) 0x01, (byte) 0x00, (byte) 0x00};
518517
byte[] reserved = new byte[]{(byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00};
519518
byte[] unknown1 = new byte[]{(byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00};
520-
long time = millisTime();
519+
long time = System.currentTimeMillis();
521520
time += 11644473600000l; // milliseconds from January 1, 1601 -> epoch.
522521
time *= 10000; // tenths of a microsecond.
523522
// convert to little-endian byte array.

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

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

19-
import static com.ning.http.util.DateUtil.millisTime;
20-
2119
import com.ning.http.client.FluentStringsMap;
2220
import com.ning.http.client.Request;
2321
import com.ning.http.client.RequestBuilderBase;
@@ -79,15 +77,15 @@ public OAuthSignatureCalculator(ConsumerKey consumerAuth, RequestToken userAuth)
7977
mac = new ThreadSafeHMAC(consumerAuth, userAuth);
8078
this.consumerAuth = consumerAuth;
8179
this.userAuth = userAuth;
82-
random = new Random(System.identityHashCode(this) + millisTime());
80+
random = new Random(System.identityHashCode(this) + System.currentTimeMillis());
8381
}
8482

8583
//@Override // silly 1.5; doesn't allow this for interfaces
8684

8785
public void calculateAndAddSignature(String baseURL, Request request, RequestBuilderBase<?> requestBuilder) {
8886
String method = request.getMethod(); // POST etc
8987
String nonce = generateNonce();
90-
long timestamp = millisTime() / 1000L;
88+
long timestamp = System.currentTimeMillis() / 1000L;
9189
String signature = calculateSignature(method, baseURL, timestamp, nonce, request.getParams(), request.getQueryParams());
9290
String headerValue = constructAuthHeader(signature, nonce, timestamp);
9391
requestBuilder.setHeader(HEADER_AUTHORIZATION, headerValue);

src/main/java/com/ning/http/client/providers/grizzly/GrizzlyAsyncHttpProvider.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 static com.ning.http.util.MiscUtil.isNonEmpty;
1817

1918
import com.ning.org.jboss.netty.handler.codec.http.CookieDecoder;
@@ -428,7 +427,7 @@ void touchConnection(final Connection c, final Request request) {
428427
if (config != null) {
429428
final long timeout = config.getRequestTimeoutInMs();
430429
if (timeout > 0) {
431-
final long newTimeout = millisTime() + timeout;
430+
final long newTimeout = System.currentTimeMillis() + timeout;
432431
if (resolver != null) {
433432
resolver.setTimeoutMillis(c, newTimeout);
434433
}
@@ -437,7 +436,7 @@ void touchConnection(final Connection c, final Request request) {
437436
final long timeout = clientConfig.getRequestTimeoutInMs();
438437
if (timeout > 0) {
439438
if (resolver != null) {
440-
resolver.setTimeoutMillis(c, millisTime() + timeout);
439+
resolver.setTimeoutMillis(c, System.currentTimeMillis() + timeout);
441440
}
442441
}
443442
}

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

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

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

16-
import static com.ning.http.util.DateUtil.millisTime;
17-
1816
import com.ning.http.client.AsyncHttpClientConfig;
1917
import com.ning.http.client.ConnectionsPool;
2018

@@ -312,7 +310,7 @@ private class DelayedRunnable implements Runnable {
312310
@Override
313311
public void run() {
314312
while (isStarted) {
315-
final long currentTimeMs = millisTime();
313+
final long currentTimeMs = System.currentTimeMillis();
316314

317315
for (final IdleConnectionQueue delayQueue : queues) {
318316
if (delayQueue.queue.isEmpty()) continue;
@@ -383,7 +381,7 @@ public IdleConnectionQueue(final long timeout) {
383381

384382
void offer(final Connection c) {
385383
if (timeout >= 0) {
386-
resolver.setTimeoutMs(c, millisTime() + timeout);
384+
resolver.setTimeoutMs(c, System.currentTimeMillis() + timeout);
387385
}
388386
queue.offer(c);
389387
count.incrementAndGet();

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;
@@ -499,7 +497,7 @@ public static Cookie parseCookie(String value) {
499497

500498
public static int convertExpireField(String timestring) {
501499
String trimmedTimeString = removeQuote(timestring.trim());
502-
long now = millisTime();
500+
long now = System.currentTimeMillis();
503501
Date date = null;
504502

505503
for (SimpleDateFormat sdf : simpleDateFormat.get()) {

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

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

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

16-
import static com.ning.http.util.DateUtil.millisTime;
17-
1816
import com.ning.http.client.Cookie;
1917
import com.ning.http.client.FluentCaseInsensitiveStringsMap;
2018
import com.ning.http.client.HttpResponseHeaders;
@@ -40,7 +38,7 @@ public void testCookieParseExpires() {
4038
SimpleDateFormat sdf = new SimpleDateFormat("EEE, dd-MMM-yyyy HH:mm:ss z", Locale.US);
4139
sdf.setTimeZone(TimeZone.getTimeZone("GMT"));
4240

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

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

0 commit comments

Comments
 (0)