leader - Code Search

cmd/bitrot-whole.go

			return 0, err
		}
	}
	if len(b.buf) < len(buf) {
		return 0, errLessData
	}
	n = copy(buf, b.buf)
	b.buf = b.buf[n:]
	return n, nil
}

// Returns whole-file bitrot reader.
func newWholeBitrotReader(disk StorageAPI, volume, filePath string, algo BitrotAlgorithm, tillOffset int64, sum []byte) *wholeBitrotReader {
	return &wholeBitrotReader{
		disk:       disk,
		volume:     volume,

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

- Last Modified: Wed Jan 31 02:11:45 GMT 2024

- 2.7K bytes

- Click Count (0)

github.com/minio/minio

internal/bucket/replication/datatypes.go

// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package replication

//go:generate msgp -file=$GOFILE

// StatusType of Replication for x-amz-replication-status header
type StatusType string

// Type - replication type enum
type Type int

const (
	// Pending - replication is pending.
	Pending StatusType = "PENDING"

	// Completed - replication completed ok.

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

- Last Modified: Thu Apr 03 06:45:06 GMT 2025

- 2.3K bytes

- Click Count (0)

github.com/minio/minio

internal/config/lambda/event/event.go

type Identity struct {
	Type        string `json:"type"`
	PrincipalID string `json:"principalId"`
	AccessKeyID string `json:"accessKeyId"`
}

// UserRequest user request headers
type UserRequest struct {
	URL     string      `json:"url"`
	Headers http.Header `json:"headers"`
}

// GetObjectContext provides the necessary details to perform
// download of the object, and return back the processed response
// to the server.

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

- Last Modified: Tue Mar 07 16:12:41 GMT 2023

- 2.6K bytes

- Click Count (0)

github.com/square/okhttp

android-test/src/androidDeviceTest/java/okhttp/android/test/sni/SniOverrideTest.kt

          } catch (e: Exception) {
            false
          }
        }.build()

    val request =
      Request
        .Builder()
        .url("https://sni.cloudflaressl.com/cdn-cgi/trace")
        .header("Host", "cloudflare-dns.com")
        .build()
    client.newCall(request).execute().use { response ->
      assertThat(response.code).isEqualTo(200)
      assertThat(response.protocol).isEqualTo(Protocol.HTTP_2)

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

- Last Modified: Mon Jan 26 07:38:51 GMT 2026

- 3.6K bytes

- Click Count (0)

github.com/golang/go

src/cmd/asm/main.go

			flags.D = append(flags.D, "GOEXPERIMENT_"+exp)
		}
	}

	var ok, diag bool
	var failedFile string
	for _, f := range flag.Args() {
		lexer := lex.NewLexer(f)
		parser := asm.NewParser(ctxt, architecture, lexer)
		ctxt.DiagFunc = func(format string, args ...any) {
			diag = true
			log.Printf(format, args...)
		}
		if *flags.SymABIs {
			ok = parser.ParseSymABIs(buf)
		} else {

Created: Tue Apr 07 11:13:11 GMT 2026

- Last Modified: Thu Apr 02 17:07:18 GMT 2026

- 3K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_top_level_security_scheme_in_openapi.py

@app.get("/", dependencies=[Depends(bearer_scheme)])
async def get_root():
    return {"message": "Hello, World!"}


client = TestClient(app)


def test_get_root():
    response = client.get("/", headers={"Authorization": "Bearer token"})
    assert response.status_code == 200, response.text
    assert response.json() == {"message": "Hello, World!"}


def test_get_root_no_token():
    response = client.get("/")

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Mon Nov 24 19:03:06 GMT 2025

- 1.9K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb2/io/Smb2ReadResponseTest.java

    void testReadBytesWireFormatBasicStructure() throws Exception {
        // Given - Create a complete SMB2 message with header
        byte[] buffer = new byte[512];
        int headerStart = 0;
        int bodyStart = Smb2Constants.SMB2_HEADER_LENGTH;

        // Write SMB2 header (64 bytes)
        // Protocol ID
        System.arraycopy(new byte[] { (byte) 0xFE, 'S', 'M', 'B' }, 0, buffer, headerStart, 4);

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

- Last Modified: Sun Aug 31 08:00:57 GMT 2025

- 22.1K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/dict/stopwords/StopwordsFile.java

        final List<StopwordsItem> itemList = new ArrayList<>();
        try (BufferedReader reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) {
            long id = 0;
            String line = null;
            while ((line = reader.readLine()) != null) {
                if (line.length() == 0 || line.charAt(0) == '#') {
                    if (updater != null) {

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

- Last Modified: Thu Nov 20 07:09:00 GMT 2025

- 13K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/chat/chat.jsp

<link href="${fe:url('/css/chat.css')}" rel="stylesheet" type="text/css" />
</head>
<body>
	<jsp:include page="../header.jsp" />
	<main class="container">
		<div class="row">
			<div class="col-12 col-lg-10 offset-lg-1">
				<div class="card shadow-sm">
					<div class="card-header d-flex justify-content-between align-items-center">
						<div id="statusArea" class="status-lozenge status-ready" role="status" aria-live="polite">

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

- Last Modified: Sun Mar 15 06:21:57 GMT 2026

- 10.4K bytes

- Click Count (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/io/ResourceBundleUtil.java

     * Returns the bundle. Returns <code>null</code> if not found.
     *
     * @param name the resource bundle name (must not be {@literal null} or empty)
     * @param locale the locale
     * @param classLoader the class loader (must not be {@literal null} or empty)
     * @return {@link ResourceBundle}
     * @see ResourceBundle#getBundle(String, Locale, ClassLoader)
     */

Created: Fri Apr 03 20:58:12 GMT 2026

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

- 5.3K bytes

- Click Count (0)

Search Options