get - Code Search

cmd/bucket-stats.go

func (rl ReplicationLatency) merge(other ReplicationLatency) (newReplLatency ReplicationLatency) {
	newReplLatency.UploadHistogram = rl.UploadHistogram.Merge(other.UploadHistogram)
	return newReplLatency
}

// Get upload latency of each object size range
func (rl ReplicationLatency) getUploadLatency() (ret map[string]uint64) {
	ret = make(map[string]uint64)
	avg := rl.UploadHistogram.GetAvgData()
	for k, v := range avg {

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

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

- 13.5K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

          try {
            shutDown();
          } catch (Exception ignored) {
            restoreInterruptIfIsInterruptedException(ignored);
            logger
                .get()
                .log(
                    Level.WARNING,
                    "Error while attempting to shut down the service after failure.",
                    ignored);
          }
          notifyFailed(t);

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

- Last Modified: Sat Aug 09 01:14:59 GMT 2025

- 27.7K bytes

- Click Count (0)

github.com/codelibs/fess

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

                    itemList.add(map);
                }
            }
        } else {
            for (final LabelTypeItem item : labelList) {
                final Set<String> permissions = stream(item.getPermissions()).get(stream -> stream.collect(Collectors.toSet()));
                for (final String roleValue : roleSet) {
                    if (permissions.contains(roleValue)) {

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

- Last Modified: Fri Nov 28 16:29:12 GMT 2025

- 14.8K bytes

- Click Count (0)

github.com/square/okhttp

.github/workflows/build.yml

          sudo udevadm control --reload-rules
          sudo udevadm trigger --name-match=kvm

      - name: Verify KVM
        run: |
          sudo apt-get install -y cpu-checker
          kvm-ok || echo "KVM is not accelerated"
          kvm-ok || exit 1

      - name: Setup Gradle
        uses: gradle/actions/setup-gradle@v5

      - name: Gradle cache

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Mar 10 16:19:02 GMT 2026

- 11.6K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb/DirFileEntryAdapterIteratorTest.java

        assertTrue(iterator.hasNext(), "Third hasNext should return true");

        SmbResource result = iterator.next();
        assertNotNull(result, "Should still be able to get element");
        assertEquals("file1.txt", result.getName());

        assertFalse(iterator.hasNext(), "Should not have more elements");

        // Verify delegate.next() was only called once

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

- Last Modified: Thu Aug 14 07:14:38 GMT 2025

- 14.4K bytes

- Click Count (0)

github.com/minio/minio

cmd/net.go

	}
	return xh.Name, xh.Port.String()
}

// mustGetLocalIPs returns IPs of local interface
func mustGetLocalIPs() (ipList []net.IP) {
	ifs, err := net.Interfaces()
	logger.FatalIf(err, "Unable to get IP addresses of this host")

	for _, interf := range ifs {
		addrs, err := interf.Addrs()
		if err != nil {
			continue
		}
		if runtime.GOOS == "windows" && interf.Flags&net.FlagUp == 0 {
			continue
		}

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

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

- 9.6K bytes

- Click Count (1)

github.com/apache/maven

impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/ModelVersionUtilsTest.java

    @Nested
    @DisplayName("Schema Location Operations")
    class SchemaLocationOperationTests {

        @ParameterizedTest
        @ValueSource(strings = {"4.0.0", "4.1.0", "4.2.0"})
        @DisplayName("should get schema location for model version")
        void shouldGetSchemaLocationForModelVersion(String targetVersion) {
            String schemaLocation = ModelVersionUtils.getSchemaLocationForModelVersion(targetVersion);

Created: Sun Apr 05 03:35:12 GMT 2026

- Last Modified: Tue Nov 18 18:03:26 GMT 2025

- 19.6K bytes

- Click Count (0)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.9.md

Windows version of the kubelet.exe calls `GetPhysicallyInstalledSystemMemory` to get the physical memory installed on Windows machines and reports it as part of node metrics to heapster. This API call fails for VMware and VirtualBox virtualization environments. This issue is not present in bare metal Windows deployments, in Hyper-V, or on some of the popular public cloud providers.

*   If you run `kubectl get po` while the API server in unreachable, a misleading error is returned: `the...

Created: Fri Apr 03 09:05:14 GMT 2026

- Last Modified: Tue Nov 16 10:46:27 GMT 2021

- 313.7K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/admin/dict/kuromoji/AdminDictKuromojiAction.java

        validate(form, messages -> {}, this::asDictIndexHtml);
        pageNumber.ifPresent(num -> {
            kuromojiPager.setCurrentPageNumber(pageNumber.get());
        }).orElse(() -> {
            kuromojiPager.setCurrentPageNumber(0);
        });
        return asHtml(path_AdminDictKuromoji_AdminDictKuromojiJsp).renderWith(data -> {
            searchPaging(data, form);

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

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

- 21.5K bytes

- Click Count (0)

github.com/codelibs/fess

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

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

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

- Last Modified: Thu Nov 13 05:54:52 GMT 2025

- 14.2K bytes

- Click Count (0)

Search Options