File tree 2 files changed +6
-3
lines changed
src/main/java/com/ning/http/client/providers/grizzly 2 files changed +6
-3
lines changed Original file line number Diff line number Diff line change 96
96
import java .io .UnsupportedEncodingException ;
97
97
import java .net .InetSocketAddress ;
98
98
import java .net .URI ;
99
- import java .net .URL ;
100
99
import java .net .URLEncoder ;
101
100
import java .nio .ByteBuffer ;
102
101
import java .security .NoSuchAlgorithmException ;
Original file line number Diff line number Diff line change @@ -360,6 +360,7 @@ final class IdleConnectionQueue {
360
360
361
361
final TimeoutResolver resolver = new TimeoutResolver ();
362
362
final long timeout ;
363
+ final AtomicInteger count = new AtomicInteger (0 );
363
364
364
365
// ---------------------------------------------------- Constructors
365
366
@@ -377,9 +378,11 @@ void offer(final Connection c) {
377
378
resolver .setTimeoutMs (c , System .currentTimeMillis () + timeout );
378
379
}
379
380
queue .offer (c );
381
+ count .incrementAndGet ();
380
382
}
381
383
382
384
Connection poll () {
385
+ count .decrementAndGet ();
383
386
return queue .poll ();
384
387
}
385
388
@@ -388,15 +391,16 @@ boolean remove(final Connection c) {
388
391
resolver .removeTimeout (c );
389
392
390
393
}
394
+ count .decrementAndGet ();
391
395
return queue .remove (c );
392
396
}
393
397
394
398
int size () {
395
- return queue . size ();
399
+ return count . get ();
396
400
}
397
401
398
402
boolean isEmpty () {
399
- return queue . isEmpty ( );
403
+ return ( count . get () == 0 );
400
404
}
401
405
402
406
void destroy () {
You can’t perform that action at this time.
0 commit comments