proxySelector.proxies.add(Proxy.NO_PROXY)
    val routeSelector = newRouteSelector(address)
    proxySelector.assertRequests(address.url.toUri())

    // Only the origin server will be attempted.
    assertThat(routeSelector.hasNext()).isTrue()
    dns[uriHost] = dns.allocate(1)
    val selection = routeSelector.next()
    assertRoute(selection.next(), address, Proxy.NO_PROXY, dns.lookup(uriHost, 0), uriPort)

      try {
        // requireNonNull is safe, as discussed above.
        Runnable localTask = requireNonNull(task);
        task = null;
        localTask.run();
        // Now check if our task attempted to reentrantly execute the next task.
        Runnable queuedTask;
        Executor queuedExecutor;
        // Intentionally using non-short-circuit operator
        while ((queuedTask = executingTaskQueue.nextTask) != null

                        return toRead;
                    });
                })) {

            lmhosts.populate(new StringReader(content), mockContext);

            // Verify include was attempted
            assertTrue(mockedConstruction.constructed().size() > 0);

            // Access the internal table to verify main entry was added
            Field tableField = Lmhosts.class.getDeclaredField("table");

            assertThrows(Exception.class, () -> {
                unicodeString.encode(mockNdrBuffer);
            }, "Should encounter issue with deferred buffer access");

            // Verify that basic encoding was attempted
            verify(mockNdrBuffer).align(4);
            verify(mockNdrBuffer).enc_ndr_short((short) 6);
            verify(mockNdrBuffer).enc_ndr_short((short) 10);

    assertThat(responseBody2.readUtf8Line())
      .isEqualTo("response body")
    assertTrue(responseBody2.exhausted())
    body.awaitSuccess()

    // No more requests attempted!
    (call.request().body as AsyncRequestBody?)!!.assertNoMoreSinks()
  }

  @Test
  fun fullCallTimeoutAppliesToSetup() {
    enableProtocol(Protocol.HTTP_2)
    server.enqueue(
      MockResponse

      acquiredLockList.add(node);
    }
  }

  /**
   * CycleDetectingLock implementations must call this method in a {@code finally} clause after any
   * attempt to change the lock state, including both lock and unlock attempts. Failure to do so can
   * result in corrupting the acquireLocks set.
   */
  private static void lockStateChanged(CycleDetectingLock lock) {
    if (!lock.isAcquiredByCurrentThread()) {

        } catch (Exception e) {
            // Expected - exception should propagate from close()
            assertTrue(e.getMessage().contains("Intentional close failure"));
        }

        // Verify close was attempted
        assertTrue(component.isCloseCalled());
    }

    /**
     * Test destroyObject with AutoCloseable that throws exception and has listener
     */

## Version 4.5.0

_2020-04-06_

**This release fixes a severe bug where OkHttp incorrectly detected and recovered from unhealthy
connections.** Stale or canceled connections were incorrectly attempted when they shouldn't have
been, leading to rare cases of infinite retries. Please upgrade to this release!

 *  Fix: don't return stale DNS entries in `DnsOverHttps`. We were caching DNS results indefinitely

	opMultiply = "*"
	opModulo   = "%"
)

// For arithmetic operations, if both values are numeric then the
// operation shall succeed. If the types are unknown automatic type
// conversion to a number is attempted.
func (v *Value) arithOp(op string, a *Value) error {
	err := inferTypeForArithOp(v)
	if err != nil {
		return err
	}

	err = inferTypeForArithOp(a)
	if err != nil {
		return err
	}

    failover.handleFailure(channel, error);
    
    // Verify channel marked as failed
    assertEquals(ChannelState.FAILED, channel.getState());
    
    // Verify recovery attempted
    Thread.sleep(2000);
    assertTrue(channel.getState() == ChannelState.ESTABLISHED 
        || manager.getChannels().isEmpty());
}
```

### 7.2 Integration Tests
```java
@Test