must only be L455: * accessed by the connection closer task. L456: */ L457: var concurrentCallCapacity: Int = 0 L458: } L459: L460: companion object { L461: fun get(connectionPool: ConnectionPool): RealConnectionPool = connectionPool.delegate L462: L463: private var addressStatesUpdater = L464: AtomicReferenceFieldUpdater.newUpdater( L465: RealConnectionPool::class.java, L466: Map::class.java, L467: "addressStates", L468: ) L469: } L470:}...

disconnectHalfway: Boolean, L878: expectedByteCount: Long, L879: socket: Socket, L880: ): Sink { L881: var result: Sink = this L882: L883: if (policy.throttlePeriodNanos > 0L) { L884: result = L885: ThrottledSink( L886: delegate = result, L887: bytesPerPeriod = policy.throttleBytesPerPeriod, L888: periodDelayNanos = policy.throttlePeriodNanos, L889: ) L890: } L891: L892: if (disconnectHalfway) { L893: val halfwayByteCount = L894: ...

ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(serializedForm)); L409: L410: ImmutableSet<?> deserialized = (ImmutableSet<?>) in.readObject(); L411: EnumSet<?> delegate = (EnumSet<?>) in.readObject(); L412: L413: assertEquals(original, deserialized); L414: assertTrue(delegate.remove(SomeEnum.A)); L415: assertTrue(deserialized.contains(SomeEnum.A)); L416: } L417: L418: @J2ktIncompatible L419: @GwtIncompatible // java serialization not supported in GWT. L420:...

headers. */ L63: val originalRequest: Request, L64: val forWebSocket: Boolean, L65:) : Call, Cloneable { L66: internal val lock: ReentrantLock = ReentrantLock() L67: L68: private val connectionPool: RealConnectionPool = client.connectionPool.delegate L69: L70: internal val eventListener: EventListener = client.eventListenerFactory.create(this) L71: L72: private val timeout = L73: object : AsyncTimeout() { L74: override fun timedOut() { L75: this@RealCall.cancel() L76: }...

L44:import org.checkerframework.checker.nullness.qual.Nullable; L45: L46:/** L47: * Tests for {@link Queues}. L48: * L49: * @author Dimitris Andreou L50: */ L51:public class QueuesTest extends TestCase { L52: /* L53: * All the following tests relate to BlockingQueue methods in Queues. L54: */ L55: L56: public static List<BlockingQueue<Object>> blockingQueues() { L57: return ImmutableList.<BlockingQueue<Object>>of( L58: new LinkedBlockingQueue<Object>(), L59: new LinkedBlo...

L1471: val startNanos = System.nanoTime() L1472: assertFailsWith<InterruptedIOException> { L1473: stream.takeHeaders() L1474: } L1475: val elapsedNanos = System.nanoTime() - startNanos L1476: awaitWatchdogIdle() L1477: // 200ms delta L1478: assertThat(TimeUnit.NANOSECONDS.toMillis(elapsedNanos).toDouble()) L1479: .isCloseTo(500.0, 200.0) L1480: assertThat(connection.openStreamCount()).isEqualTo(0) L1481: L1482: // Verify the peer received what was expected. L1483:...

five framework-embedded messages (don't change key names) L63:# - - - - - - - - - -/ L64:errors.login.failure=La connexion a échoué. L65:errors.app.illegal.transition=Veuillez réessayer en raison d'une transition illégale. L66:errors.app.db.already.deleted=d'autres peuvent être mis à jour, alors réessayez. L67:errors.app.db.already.updated=d'autres peuvent être mis à jour, alors réessayez. L68:errors.app.db.already.exists=données déjà existantes, alors réessayez. L69:errors.app.double.submit.request=Votre...

@Override L1442: public List<String> create(final String[] elements) { L1443: final List<String> delegate = newArrayList(elements); L1444: return new ForwardingList<String>() { L1445: @Override L1446: protected List<String> delegate() { L1447: return delegate; L1448: } L1449: L1450: @Override L1451: public boolean removeAll(Collection<?> c) {...

valid ; ; NV8 # 10.0 OBSERVER EYE SYMBOL L2588:2400..2424 ; valid ; ; NV8 # 1.1 SYMBOL FOR NULL..SYMBOL FOR NEWLINE L2589:2425..2426 ; valid ; ; NV8 # 3.0 SYMBOL FOR DELETE FORM TWO..SYMBOL FOR SUBSTITUTE FORM TWO L2590:2427..243F ; disallowed # NA <reserved-2427>..<reserved-243F> L2591:2440..244A ; valid ; ; NV8 # 1.1 OCR HOOK..OCR DOUBLE BACKSLASH L2592:244B..245F...

@Override L1442: public List<String> create(final String[] elements) { L1443: final List<String> delegate = newArrayList(elements); L1444: return new ForwardingList<String>() { L1445: @Override L1446: protected List<String> delegate() { L1447: return delegate; L1448: } L1449: L1450: @Override L1451: public boolean removeAll(Collection<?> c) {...