zIndex - Code Search

src/main/java/org/codelibs/fess/opensearch/config/cbean/cq/bs/BsRelatedQueryCQ.java

import org.opensearch.index.query.RangeQueryBuilder;
import org.opensearch.index.query.RegexpQueryBuilder;
import org.opensearch.index.query.SpanTermQueryBuilder;
import org.opensearch.index.query.TermQueryBuilder;
import org.opensearch.index.query.TermsQueryBuilder;
import org.opensearch.index.query.WildcardQueryBuilder;
import org.opensearch.index.query.functionscore.FunctionScoreQueryBuilder;

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Sat Mar 15 06:53:53 UTC 2025

- 57.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/opensearch/config/cbean/cq/bs/BsRoleTypeCQ.java

import org.opensearch.index.query.RangeQueryBuilder;
import org.opensearch.index.query.RegexpQueryBuilder;
import org.opensearch.index.query.SpanTermQueryBuilder;
import org.opensearch.index.query.TermQueryBuilder;
import org.opensearch.index.query.TermsQueryBuilder;
import org.opensearch.index.query.WildcardQueryBuilder;
import org.opensearch.index.query.functionscore.FunctionScoreQueryBuilder;

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Sat Mar 15 06:53:53 UTC 2025

- 55.3K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java

        }
    }

    private ChannelInfo selectRoundRobin(Collection<ChannelInfo> channels) {
        List<ChannelInfo> list = new ArrayList<>(channels);
        int index = Math.abs(roundRobinCounter.getAndIncrement() % list.size());
        return list.get(index);
    }

    private ChannelInfo selectLeastLoaded(Collection<ChannelInfo> channels) {
        ChannelInfo leastLoadedChannel = null;

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 30 05:58:03 UTC 2025

- 8.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/helper/KeyMatchHelper.java

import org.codelibs.fess.util.DocumentUtil;
import org.opensearch.index.query.BoolQueryBuilder;
import org.opensearch.index.query.QueryBuilder;
import org.opensearch.index.query.QueryBuilders;
import org.opensearch.index.query.functionscore.FunctionScoreQueryBuilder.FilterFunctionBuilder;
import org.opensearch.index.query.functionscore.ScoreFunctionBuilder;
import org.opensearch.index.query.functionscore.ScoreFunctionBuilders;

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Thu Aug 07 03:06:29 UTC 2025

- 10K bytes

- Viewed (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/misc/AssertionUtil.java

        }
    }

    /**
     * Asserts that the index is valid.
     *
     * @param argName
     *            The name of the argument that must not be {@code null}.
     * @param argValue
     *            The value of the index.
     * @param arraySize
     *            The length of the array the index refers to.
     * @throws ClIllegalArgumentException

Registered: Fri Sep 05 20:58:11 UTC 2025

- Last Modified: Thu Jul 31 08:16:49 UTC 2025

- 12.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/perf-tests.go

	}

	errStr := ""
	var wg sync.WaitGroup
	for index := range globalNotificationSys.peerClients {
		if globalNotificationSys.peerClients[index] == nil {
			continue
		}
		go func(index int) {
			for i := 0; i < connectionsPerPeer; i++ {
				wg.Add(1)
				go func() {
					defer wg.Done()
					err := globalNotificationSys.peerClients[index].DevNull(ctx, r)
					if err != nil {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 11.7K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

  private fun startNextTask(): SerialTask? {
    taskRunner.assertLockHeld()

    val index = serialTaskQueue.indexOfFirst { it.isReady() }
    if (index == -1) return null

    val nextTask = serialTaskQueue.removeAt(index)
    currentTask = nextTask
    contextSwitchCount++
    nextTask.start()
    return nextTask
  }

  private interface SerialTask {

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Wed May 28 23:28:25 UTC 2025

- 11.9K bytes

- Viewed (0)

github.com/apache/maven

compat/maven-compat/src/site/site.xml

  <edit>${project.scm.url}</edit>

  <body>
    <menu name="Overview">
      <item name="Introduction" href="index.html"/>
      <item name="Javadocs" href="apidocs/index.html"/>
      <item name="Source Xref" href="xref/index.html"/>
      <!--item name="FAQ" href="faq.html"/-->
    </menu>
  </body>

Registered: Sun Sep 07 03:35:12 UTC 2025

- Last Modified: Fri Mar 21 04:56:21 UTC 2025

- 1.3K bytes

- Viewed (0)

github.com/google/guava

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

    ImmutableSet<E> result = elementSet;
    return (result == null) ? elementSet = new ElementSet<>(entries, this) : result;
  }

  @Override
  Entry<E> getEntry(int index) {
    return entries.get(index);
  }

  @Override
  boolean isPartialView() {
    return false;
  }

  @Override
  public int size() {
    return Ints.saturatedCast(size);
  }

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Tue Apr 08 13:05:15 UTC 2025

- 3.2K bytes

- Viewed (0)

github.com/golang/go

src/cmd/asm/internal/asm/endtoend_test.go

		// giving the absolute form.
		if len(f) > 0 && strings.Contains(printed, "(PC)") {
			index := len(f) - 1
			suf := "(PC)"
			for !strings.HasSuffix(f[index], suf) {
				index--
				suf = "(PC),"
			}
			str := f[index]
			n, err := strconv.Atoi(str[:len(str)-len(suf)])
			if err == nil {
				f[index] = fmt.Sprintf("%d%s", seq+n, suf)
			}
		}

		if len(f) == 1 {
			printed = f[0]

Registered: Tue Sep 09 11:13:09 UTC 2025

- Last Modified: Wed Mar 26 01:02:50 UTC 2025

- 11.9K bytes

- Viewed (0)

Search Options