assertEquals("abcd", normalizer.normalize("ａｂｃｄ", null));
        assertEquals("みかん", normalizer.normalize("みかん", null));
        assertEquals("みかん ﾘﾝｺﾞ", normalizer.normalize("みかん　リンゴ", null));
    }

    public void test_AnyLower() {
        ICUNormalizer normalizer = new ICUNormalizer("Any-Lower");
        assertEquals("abcd", normalizer.normalize("ABCD", null));
    }

    public void test_HalfwidthFullwidth() {

        deferred.resolve(new SuggestResponse("first", 0, Collections.emptyList(), 0, null));
        // Second resolve (should be ignored)
        deferred.resolve(new SuggestResponse("second", 0, Collections.emptyList(), 0, null));
        // Third resolve (should be ignored)
        deferred.resolve(new SuggestResponse("third", 0, Collections.emptyList(), 0, null));

        Thread.sleep(100);

    assertThat(entry("bar", 2).toString()).isEqualTo("bar x 2");
  }

  public void testToStringNull() {
    assertThat(entry(NE, 1).toString()).isEqualTo("null");
    assertThat(entry(NE, 2).toString()).isEqualTo("null x 2");
  }

  public void testEquals() {
    assertEquals(control("foo", 1), entry("foo", 1));
    assertEquals(control("bar", 2), entry("bar", 2));

                    final Map<String, SearchHits> innerHits = searchHit.getInnerHits();
                    if (innerHits != null) {
                        final SearchHits innerSearchHits = innerHits.get(fessConfig.getQueryCollapseInnerHitsName());
                        if (innerSearchHits != null) {
                            final long totalHits = innerSearchHits.getTotalHits().value();
                            if (totalHits > 1) {

        IndexUpdateCallback callback = new TestIndexUpdateCallback();

        // Execute with null config
        dataStore.store(null, callback, params);

        assertTrue(storeCalled.get());
    }

    @Test
    public void test_store_withNullCallback() {
        // Test store with null callback
        final AtomicBoolean storeCalled = new AtomicBoolean(false);

        dataStore = new DataStore() {

          check(waitingCoordinatorTask != null)

          // Queue a task to resume the waiting coordinator.
          serialTaskQueue +=
            object : SerialTask {
              override fun start() {
                taskRunner.assertLockHeld()
                val coordinatorTask = waitingCoordinatorTask
                if (coordinatorTask != null) {
                  waitingCoordinatorNotified = true

        }

        @Override
        public String getServerName() {
            return null;
        }

        @Override
        public int getServerPort() {
            return 0;
        }

        @Override
        public java.io.BufferedReader getReader() {
            return null;
        }

        @Override
        public String getRemoteAddr() {
            return null;

     */
    public SecureCredentialStorage(char[] masterPassword, byte[] salt) throws GeneralSecurityException {
        if (masterPassword == null || masterPassword.length == 0) {
            throw new IllegalArgumentException("Master password cannot be null or empty");
        }
        if (salt == null || salt.length != SALT_SIZE) {
            throw new IllegalArgumentException("Invalid salt");
        }

        this.salt = salt.clone();

        Smb2NegotiateResponse r = null;
        byte[] negoReqBuffer = null;
        byte[] negoRespBuffer = null;
        try {
            smb2neg.setRequestCredits(Math.max(1, this.desiredCredits - this.credits.availablePermits()));

            final int reqLen = negotiateWrite(smb2neg, first != null);

        if (pluginDescriptorV4 == null) {
            synchronized (this) {
                if (pluginDescriptorV4 == null) {
                    pluginDescriptorV4 = org.apache.maven.api.plugin.descriptor.PluginDescriptor.newBuilder()
                            .namespaceUri(null)
                            .modelEncoding(null)
                            .name(name)