}

  public void testDefaultExecutorIsShutdownWhenServiceFails() throws Exception {
    AtomicReference<ScheduledExecutorService> executor = Atomics.newReference();
    AbstractScheduledService service =
        new AbstractScheduledService() {
          @Override
          protected void startUp() throws Exception {
            throw new Exception("Failed");
          }

          @Override

  }

  public void testDefaultExecutorIsShutdownWhenServiceFails() throws Exception {
    AtomicReference<ScheduledExecutorService> executor = Atomics.newReference();
    AbstractScheduledService service =
        new AbstractScheduledService() {
          @Override
          protected void startUp() throws Exception {
            throw new Exception("Failed");
          }

          @Override

     * host with the same IP address.
     *
     * @param addr
     *            the address to query
     * @return resolved addresses
     * @throws UnknownHostException
     *             if address cannot be resolved
     */
    NetbiosAddress[] getNbtAllByAddress(NetbiosAddress addr) throws UnknownHostException;

    /**
     * Retrieve all addresses of a host by it's address. NetBIOS hosts can

            if (token == null) {
                if (len == 0) {
                    return new byte[0];
                }
                throw new CIFSException("token is null but len > 0");
            }
            if (off < 0 || len < 0 || off > token.length || off + len > token.length) {
                throw new CIFSException("invalid offset/length");
            }

        runner.ensureYellow();
    }

    @AfterClass
    public static void afterClass() throws Exception {
        runner.close();
        runner.clean();
    }

    @Before
    public void before() throws Exception {
        runner.admin().indices().prepareDelete("_all").execute().actionGet();
        runner.refresh();

     *
     * @throws IOException thrown by {@code SmbFileInputStream} constructor
     */
    @Override
    public InputStream getInputStream() throws IOException {
        return new SmbFileInputStream(this);
    }

    /**
     * This URLConnection method just returns a new {@code SmbFileOutputStream} created with this file.
     *

     * @return {@link Class}
     * @throws EmptyArgumentException
     *             If the class name is {@literal null} or empty.
     * @throws ClassNotFoundRuntimeException
     *             If a {@link ClassNotFoundException} occurs.
     * @see #forName(String)
     */
    public static Class<?> convertClass(final String className) throws ClassNotFoundRuntimeException {

  @Override
  protected void setUp() throws Exception {
    super.setUp();

    future = SettableFuture.create();
    tester = new ListenableFutureTester(future);
    tester.setUp();
  }

  public void testDefaultState() throws Exception {
    assertThrows(TimeoutException.class, () -> future.get(5, MILLISECONDS));
  }

  public void testSetValue() throws Exception {
    assertTrue(future.set("value"));

        public void encode(NdrBuffer _dst) throws NdrException {
            _dst.align(4);
            _dst.enc_ndr_referent(this.entry_path, 1);

            if (this.entry_path != null) {
                _dst = _dst.deferred;
                _dst.enc_ndr_string(this.entry_path);

            }
        }

        @Override
        public void decode(NdrBuffer _src) throws NdrException {
            _src.align(4);

    public void test_refresh_onEmptyIndex() throws Exception {
        Suggester suggester = createSuggester();
        suggester.createIndexIfNothing();

        // Should not throw
        assertNotNull(suggester.refresh());
    }

    @Test
    public void test_shutdown() throws Exception {
        Suggester suggester = createSuggester();

        // Should not throw
        suggester.shutdown();
    }