Durrant - Code Search

cmd/http-stats.go

	if stats == nil {
		return
	}
	stats.Lock()
	defer stats.Unlock()
	if val, ok := stats.apiStats[api]; ok && val > 0 {
		stats.apiStats[api]--
	}
}

// Get returns the current counter on input API string
func (stats *HTTPAPIStats) Get(api string) int {
	if stats == nil {
		return 0
	}

	stats.RLock()
	defer stats.RUnlock()

	val, ok := stats.apiStats[api]
	if ok {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue Sep 24 17:13:00 GMT 2024

- 11.4K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/reflect/ClassPathTest.java

    File jarFile = new File("base/some.jar");
    // with/relative/directory is the Class-Path value in the mf file.
    Manifest manifest = manifestClasspath("current.jar");
    assertThat(ClassPath.getClassPathFromManifest(jarFile, manifest))
        .containsExactly(fullpath("base/current.jar"));
  }

  public void testGetClassPathFromManifest_absoluteDirectory() throws IOException {
    if (isWindows()) {

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Dec 11 21:00:51 GMT 2025

- 25.7K bytes

- Click Count (0)

github.com/minio/minio

cmd/admin-heal-ops.go

	// time-duration to keep heal sequence state after it
	// completes.
	keepHealSeqStateDuration = time.Minute * 10

	// nopHeal is a no operating healing action to
	// wait for the current healing operation to finish
	nopHeal = ""
)

var (
	errHealIdleTimeout   = errors.New("healing results were not consumed for too long")
	errHealStopSignalled = errors.New("heal stop signaled")

Created: Sun Dec 28 19:28:13 GMT 2025

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

- 25.4K bytes

- Click Count (0)

github.com/minio/minio

cmd/iam-object-store.go

	"github.com/minio/pkg/v3/sync/errgroup"
	"github.com/puzpuzpuz/xsync/v3"
)

// IAMObjectStore implements IAMStorageAPI
type IAMObjectStore struct {
	// Protect access to storage within the current server.
	sync.RWMutex

	*iamCache

	usersSysType UsersSysType

	objAPI ObjectLayer
}

func newIAMObjectStore(objAPI ObjectLayer, usersSysType UsersSysType) *IAMObjectStore {
	return &IAMObjectStore{

Created: Sun Dec 28 19:28:13 GMT 2025

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

- 26.6K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/dcerpc/DcerpcHandle.java

     */
    protected int max_xmit = 4280;
    /**
     * Maximum receive buffer size for DCERPC messages
     */
    protected int max_recv = max_xmit;
    /**
     * The current state of the DCERPC connection
     */
    protected int state = 0;
    /**
     * The security provider for authentication and message protection
     */

Created: Sat Dec 20 13:44:44 GMT 2025

- Last Modified: Sat Aug 16 01:32:48 GMT 2025

- 11.7K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java

            }
        });

        handle.setNotificationFuture(future);
    }

    /**
     * Determine optimal polling interval based on directory activity and failure count
     *
     * Current strategy is based on failure count. In the future, this could be enhanced to consider:
     * - Recent event frequency (successful notifications)
     * - Time since last successful notification

Created: Sat Dec 20 13:44:44 GMT 2025

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

- 13.7K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb/SmbFileInputStreamTest.java

    }

    @Nested
    @DisplayName("Happy path")
    class HappyPath {

        @Test
        @DisplayName("readDirect over SMB2 returns bytes read and uses current offset")
        void readDirectSmb2Happy() throws Exception {
            SmbFileInputStream in = newStream();

            // Arrange SMB2 response to return 3 bytes

Created: Sat Dec 20 13:44:44 GMT 2025

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

- 12.8K bytes

- Click Count (0)

github.com/apache/maven

compat/maven-repository-metadata/src/test/java/org/apache/maven/artifact/repository/metadata/MetadataTest.java

        sv.setExtension(extension);
        sv.setVersion(version);
        sv.setUpdated(formatDate(timestamp, false));
        versioning.addSnapshotVersion(sv);

        // make the new snapshot the current one
        versioning.setSnapshot(snapshot);
        versioning.setLastUpdatedTimestamp(timestamp);
        return sv;
    }

    // the format written by Maven 2

Created: Sun Dec 28 03:35:09 GMT 2025

- Last Modified: Fri Oct 25 12:31:46 GMT 2024

- 13.7K bytes

- Click Count (0)

github.com/minio/minio

internal/http/headers.go

	MinIOSourceObjectLegalHoldTimestamp = "X-Minio-Source-Replication-LegalHold-Timestamp"
	// Header indicates a Tag operation was performed on one/more peers successfully, though the
	// current cluster does not have the object yet. This is in a site/bucket replication scenario.
	MinIOTaggingProxied = "X-Minio-Tagging-Proxied"
	// Header indicates the actual replicated object size

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Wed May 07 15:37:12 GMT 2025

- 10.8K bytes

- Click Count (0)

github.com/gradle/gradle

build-logic/buildquality/src/main/kotlin/gradlebuild/incubation/action/IncubatingApiReportWorkAction.kt

       <meta xmlns:xslthl="http://xslthl.sf.net" content="width=device-width, initial-scale=1" name="viewport">
       <link xmlns:xslthl="http://xslthl.sf.net" type="text/css" rel="stylesheet" href="https://docs.gradle.org/current/userguide/base.css">

    </head>
    <body>
       <h1>Incubating APIs for  $title</h1>
    """
            )
            val versions = versionsDates()

Created: Wed Dec 31 11:36:14 GMT 2025

- Last Modified: Mon Jun 02 09:57:54 GMT 2025

- 14.1K bytes

- Click Count (0)

Search Options