get3 - Code Search

api/maven-api-core/src/test/java/org/apache/maven/api/feature/FeaturesTest.java

        assertFalse(Features.deployBuildPom(properties));

        // Verify the map wasn't modified
        assertEquals(1, properties.size());
        assertEquals("false", properties.get(Constants.MAVEN_DEPLOY_BUILD_POM));
    }

    @Test
    void testDeployBuildPomWithOtherProperties() {
        // Test that other properties don't interfere
        Map<String, Object> properties = Map.of(

Registered: Sun Dec 28 03:35:09 UTC 2025

- Last Modified: Fri Jul 04 19:42:23 UTC 2025

- 7.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure-server-pool.go

	go func() {
		updateTicker := time.NewTicker(30 * time.Second)
		defer updateTicker.Stop()
		var lastUpdate time.Time

		// We need to merge since we will get the same buckets from each pool.
		// Therefore to get the exact bucket sizes we must merge before we can convert.
		var allMerged dataUsageCache

		update := func() {
			mu.Lock()
			defer mu.Unlock()

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Sun Sep 28 20:59:21 UTC 2025

- 89.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/go/GoAction.java

                final SearchLogHelper searchLogHelper = ComponentUtil.getSearchLogHelper();
                final ClickLog clickLog = new ClickLog();
                clickLog.setUrlId((String) doc.get(fessConfig.getIndexFieldId()));
                clickLog.setUrl(url);
                clickLog.setRequestedAt(systemHelper.getCurrentTimeAsLocalDateTime());

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Dec 11 09:47:03 UTC 2025

- 9K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/opensearch/user/bsbhv/BsRoleBhv.java

        try {
            final RESULT result = entityType.newInstance();
            result.setName(DfTypeUtil.toString(source.get("name")));
            return updateEntity(source, result);
        } catch (InstantiationException | IllegalAccessException e) {
            final String msg = "Cannot create a new instance: " + entityType.getName();

Registered: Sat Dec 20 09:19:18 UTC 2025

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

- 8.8K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/index.jsp

<link href="${fe:url('/css/style.css')}" rel="stylesheet" type="text/css" />
<link href="${fe:url('/css/font-awesome.min.css')}" rel="stylesheet"
	type="text/css" />
</head>
<body>
	<la:form action="/search" method="get" styleId="searchForm">
		${fe:facetForm()}${fe:geoForm()}
		<header>
			<nav class="navbar navbar-expand-md navbar-dark fixed-top bg-dark">
				<div id="content" class="container">
					<div class="navbar-brand"></div>

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Nov 20 05:40:20 UTC 2025

- 7K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpHeaders.kt

    if (headerName.equals(name(h), ignoreCase = true)) {
      val header = Buffer().writeUtf8(value(h))
      try {
        header.readChallengeHeader(result)
      } catch (e: EOFException) {
        Platform.get().log("Unable to parse challenge", Platform.WARN, e)
      }
    }
  }
  return result
}

@Throws(EOFException::class)
private fun Buffer.readChallengeHeader(result: MutableList<Challenge>) {

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Mon May 05 16:01:00 UTC 2025

- 7.2K bytes

- Viewed (0)

github.com/google/guava

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

    }

    assertEquals(1, logHandler.getStoredLogRecords().size());
    assertEquals(
        "Exception while executing callback: MyListener custom-label",
        logHandler.getStoredLogRecords().get(0).getMessage());
  }

  public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
    Object listener = new Object();
    ExecutorService service = newFixedThreadPool(4);

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Fri Jul 11 18:52:30 UTC 2025

- 8.2K bytes

- Viewed (0)

github.com/google/guava

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

    }

    assertEquals(1, logHandler.getStoredLogRecords().size());
    assertEquals(
        "Exception while executing callback: MyListener custom-label",
        logHandler.getStoredLogRecords().get(0).getMessage());
  }

  public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
    Object listener = new Object();
    ExecutorService service = newFixedThreadPool(4);

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Fri Jul 11 18:52:30 UTC 2025

- 8.2K bytes

- Viewed (0)

github.com/google/guava

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

 * value and the old value.
 *
 * <p>Keys and values may be null. All optional multimap methods are supported, and all returned
 * views are modifiable.
 *
 * <p>The lists returned by {@link #get}, {@link #removeAll}, and {@link #replaceValues} all
 * implement {@link java.util.RandomAccess}.
 *
 * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Fri Dec 05 23:15:58 UTC 2025

- 6.8K bytes

- Viewed (0)

github.com/minio/minio

docs/sts/assume-role.md

- To be able to easily get the temporary credentials to upload to a prefix. Make it possible for a client to upload a whole folder using the session. The server side applications need not create a presigned URL and serve to the client for each file. Since, the client would have...

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Tue Aug 12 18:20:36 UTC 2025

- 7.2K bytes

- Viewed (0)

Search Options