collected - Code Search

src/main/java/org/codelibs/fess/ldap/LdapManager.java

        // (member:1.2.840.113556.1.4.1941:=%s)
        if (subRoleSet.isEmpty()) {
            return;
        }
        String filter = subRoleSet.stream().map(s -> String.format(groupFilter, s)).collect(Collectors.joining());
        if (subRoleSet.size() > 1) {
            filter = "(|" + filter + ")";
        }

        if (logger.isDebugEnabled()) {
            logger.debug("Group filter: {}", filter);

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Jan 02 08:06:20 GMT 2026

- 85.2K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/AtomicLongMapTest.java

package com.google.common.util.concurrent;

import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;
import com.google.common.collect.ImmutableMap;
import com.google.common.testing.NullPointerTester;
import com.google.common.testing.SerializableTester;
import java.util.HashSet;
import java.util.Map;
import java.util.Random;
import java.util.Set;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Aug 07 16:05:33 GMT 2025

- 17.5K bytes

- Click Count (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/helper/SystemHelperTest.java

        assertEquals("", systemHelper.abbreviateLongText(""));
        assertEquals(4000, systemHelper.abbreviateLongText(Stream.generate(() -> "a").limit(4000).collect(Collectors.joining())).length());
        assertEquals(4000, systemHelper.abbreviateLongText(Stream.generate(() -> "a").limit(4001).collect(Collectors.joining())).length());
    }

    @Test
    public void test_getLanguageItems() {

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Sat Mar 28 06:59:19 GMT 2026

- 44.4K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/primitives/IntsTest.java

import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;
import com.google.common.base.Converter;
import com.google.common.collect.testing.Helpers;
import com.google.common.testing.NullPointerTester;
import com.google.common.testing.SerializableTester;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Sun Mar 08 01:43:32 GMT 2026

- 29.4K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/collect/MinMaxPriorityQueue.java

 * limitations under the License.
 */

package com.google.common.collect;

import static com.google.common.base.Preconditions.checkArgument;
import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.base.Preconditions.checkPositionIndex;
import static com.google.common.base.Preconditions.checkState;
import static com.google.common.collect.CollectPreconditions.checkRemove;
import static java.lang.Math.max;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 13:11:08 GMT 2026

- 34K bytes

- Click Count (0)

github.com/minio/minio

cmd/global-heal.go

		return healEntryResult{
			bytes: sz,
		}
	}

	healEntrySkipped := func(sz uint64) healEntryResult {
		return healEntryResult{
			bytes:   sz,
			skipped: true,
		}
	}

	// Collect updates to tracker from concurrent healEntry calls
	results := make(chan healEntryResult, 1000)
	quitting := make(chan struct{})
	defer func() {
		close(results)
		<-quitting
	}()

	go func() {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Apr 04 13:49:12 GMT 2025

- 16.2K bytes

- Click Count (0)

github.com/codelibs/fess-suggest

src/main/java/org/codelibs/fess/suggest/settings/SuggestSettings.java

import org.codelibs.fess.suggest.exception.SuggestSettingsException;
import org.codelibs.fess.suggest.exception.SuggesterException;
import org.opensearch.action.get.GetResponse;
import org.opensearch.common.collect.Tuple;
import org.opensearch.common.xcontent.XContentType;
import org.opensearch.common.xcontent.json.JsonXContent;
import org.opensearch.core.xcontent.XContentBuilder;
import org.opensearch.index.IndexNotFoundException;

Created: Fri Apr 17 09:08:13 GMT 2026

- Last Modified: Sat Mar 14 02:35:38 GMT 2026

- 18.7K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/ACETest.java

            assertTrue(ACE.GENERIC_EXECUTE > 0, "GENERIC_EXECUTE should be positive");
            assertTrue(ACE.GENERIC_WRITE > 0, "GENERIC_WRITE should be positive");

            // Test ordering (corrected for actual bit values)
            assertTrue(ACE.GENERIC_ALL < ACE.GENERIC_EXECUTE, "GENERIC_ALL should be less than GENERIC_EXECUTE");

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 24.4K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/MultiChannelManager.java

            SmbTransportImpl transport = new SmbTransportImpl(context, serverUniAddress, port, localAddress, localPort, forceSigning);

            // Ensure the transport is connected and ready
            transport.ensureConnected();

            // Verify multi-channel capability (SMB3+ required)

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sun Aug 31 08:00:57 GMT 2025

- 20.5K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/collect/Table.java

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.google.common.collect;

import com.google.common.annotations.GwtCompatible;
import com.google.errorprone.annotations.CanIgnoreReturnValue;
import com.google.errorprone.annotations.CompatibleWith;
import com.google.errorprone.annotations.DoNotMock;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Tue Jul 08 18:32:10 GMT 2025

- 10.5K bytes

- Click Count (0)

Search Options