GET - Code Search

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: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Sat Jan 18 11:58:45 UTC 2025

- 7K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/timer/SystemMonitorTargetTest.java

            // Note: This method may fail in test environments due to system dependencies
            // but we mainly want to ensure the method signature is correct
            testTarget.expired();

            // If we get here, the method executed successfully
            assertTrue("expired method executed successfully", true);
        } catch (Throwable t) {
            // In test environments, system monitoring may fail due to missing dependencies

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

- Last Modified: Sun Aug 31 08:19:00 UTC 2025

- 8.9K 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 Sep 05 11:42:10 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 Sep 05 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 Sep 05 12:43:10 UTC 2025

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

- 6.8K 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 Sep 05 12:43:10 UTC 2025

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

- 8.2K 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 Sep 07 19:28:11 UTC 2025

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

- 7.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/untar.go

			name = pathJoin(o.prefixAll, name)
		}

		// Do small files async
		n++
		if header.Size <= xioutil.MediumBlock {
			asyncWriters <- struct{}{}
			bufp := xioutil.ODirectPoolMedium.Get()
			b := (*bufp)[:header.Size]
			if _, err := io.ReadFull(tarReader, b); err != nil {
				return err
			}
			wg.Add(1)
			go func(name string, fi fs.FileInfo, b []byte) {

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

- Last Modified: Tue Feb 18 16:25:55 UTC 2025

- 6K bytes

- Viewed (2)

github.com/codelibs/fess

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

            final List<String> docIdList = new ArrayList<>();
            for (final Map<String, Object> map : documentItems) {
                final Object docId = map.get(fessConfig.getIndexFieldDocId());
                if (docId != null && docId.toString().length() > 0) {
                    docIdList.add(docId.toString());
                }
            }

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

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

- 14.9K bytes

- Viewed (0)

github.com/minio/minio

cmd/metacache-walk.go

		if contextCanceled(ctx) {
			return ctx.Err()
		}
		if opts.Limit > 0 && objsReturned >= opts.Limit {
			return nil
		}

		// Skip forward, if requested...
		sb := bytebufferpool.Get()
		defer func() {
			sb.Reset()
			bytebufferpool.Put(sb)
		}()

		forward := ""
		if len(opts.ForwardTo) > 0 && strings.HasPrefix(opts.ForwardTo, current) {

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

- Last Modified: Mon May 26 07:06:43 UTC 2025

- 12.6K bytes

- Viewed (0)

Search Options