deleted = true;
            } catch (SmbException e) {
                if (i < 2) {
                    log.debug("Retry delete in move, attempt {}", i + 1);
                    Thread.sleep(500);
                } else {
                    log.warn("Could not delete source after move, but continuing");
                    deleted = true; // Proceed anyway
                }
            }
        }

        scheduleReconnection(getContext().getConfig().getWitnessReconnectDelay());
    }

    /**
     * Handle client move events
     */
    private void handleClientMove(WitnessNotification notification) {
        // Server is asking client to move to different node
        log.info("Client move requested for resource: {}", notification.getResourceName());

    public void clear() {
      multimap.clear();
    }
  }

  /**
   * Returns a multimap containing the mappings in {@code unfiltered} whose keys satisfy a
   * predicate. The returned multimap is a live view of {@code unfiltered}; changes to one affect
   * the other.
   *
   * <p>The resulting multimap's views have iterators that don't support {@code remove()}, but all

      int maxSize() {
        return saturatedAdd(maxSize(set1), maxSize(set2));
      }
    };
  }

  /**
   * Returns the elements of {@code unfiltered} that satisfy a predicate. The returned set is a live
   * view of {@code unfiltered}; changes to one affect the other.
   *
   * <p>The resulting set's iterator does not support {@code remove()}, but all other set methods

 *  Fix: Don't evict incomplete entries when iterating the cache. We had a bug where iterating
    `Cache.urls()` would prevent in-flight entries from being written.


## Version 3.14.3

_2019-09-10_

 *  Fix: Don't lose HTTP/2 flow control bytes when incoming data races with a stream close. If this
    happened enough then eventually the connection would stall.

    void setValue(S segment, E entry, V value);
  }

  /**
   * An entry in a hash table of a {@link Segment}.
   *
   * <p>Entries in the map can be in the following states:
   *
   * <p>Valid: - Live: valid key/value are set
   *
   * <p>Invalid: - Collected: key/value was partially collected, but not yet cleaned up
   */
  interface InternalEntry<K, V, E extends InternalEntry<K, V, E>> {

 *   <li>MAX_TOTAL_CONNECTION_PROPERTY: Maximum total connections.</li>
 *   <li>TIME_TO_LIVE_TIME_UNIT_PROPERTY: Time to live unit for connections.</li>
 *   <li>TIME_TO_LIVE_PROPERTY: Time to live for connections.</li>
 * </ul>
 *
 */
public class HcHttpClient extends AbstractCrawlerClient {

    /**
     * Constructs a new HcHttpClient.
     */

     */
    public EntraIdAuthenticator() {
        // Default constructor
    }

    // New configuration keys for Entra ID
    /** Configuration key for Entra ID state time-to-live. */
    protected static final String ENTRAID_STATE_TTL = "entraid.state.ttl";

    /** Configuration key for Entra ID authority URL. */
    protected static final String ENTRAID_AUTHORITY = "entraid.authority";

* Allow conformance tests to run on non-GCE providers ([#26932](https://github.com/kubernetes/kubernetes/pull/26932), [@aaronlevy](https://github.com/aaronlevy))
* AWS kube-up: move to Docker 1.11.2 ([#27676](https://github.com/kubernetes/kubernetes/pull/27676), [@justinsb](https://github.com/justinsb))

        .testEquals();
  }

  private interface Loser<E extends Throwable> {
    void lose() throws E;
  }

  public <T extends Loser<AssertionError>> void testMethod_exceptionTypes()
      throws NoSuchMethodException {
    Method failMethod = Loser.class.getMethod("lose");
    Invokable<T, ?> invokable = new TypeToken<T>(getClass()) {}.method(failMethod);