- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 1,384 for leader (0.07 sec)
-
docs/debugging/xl-meta/main.go
} type version struct { Idx int Header json.RawMessage Metadata json.RawMessage } versions := make([]version, hdr.versions) headerVer := hdr.headerVer err = decodeVersions(v, hdr.versions, func(idx int, hdr, meta []byte) error { var header xlMetaV2VersionHeaderV2 if _, err := header.UnmarshalMsg(hdr, headerVer); err != nil { return err }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 40.4K bytes - Viewed (0) -
cmd/test-utils_test.go
// Get hashed payload. hashedPayload := req.Header.Get("x-amz-content-sha256") if hashedPayload == "" { return "", fmt.Errorf("Invalid hashed payload") } // Set x-amz-date. req.Header.Set("x-amz-date", currTime.Format(iso8601Format)) // Get header map. headerMap := make(map[string][]string) for k, vv := range req.Header { // If request header key is not in ignored headers, then add it.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 77K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/entraid/EntraIdAuthenticator.java
} try (CurlResponse response = Curl.post(url) .header("Authorization", "Bearer " + user.getAuthenticationResult().accessToken()) .header("Accept", "application/json") .header("Content-type", "application/json") .body("{\"securityEnabledOnly\":false}") .execute()) {Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 13 02:21:17 UTC 2025 - 56.7K bytes - Viewed (0) -
cmd/generic-handlers_test.go
} } var isHTTPHeaderSizeTooLargeTests = []struct { header http.Header shouldFail bool }{ {header: generateHeader(0, 0), shouldFail: false}, {header: generateHeader(1024, 0), shouldFail: false}, {header: generateHeader(2048, 0), shouldFail: false}, {header: generateHeader(8*1024+1, 0), shouldFail: true}, {header: generateHeader(0, 1024), shouldFail: false}, {header: generateHeader(0, 2048), shouldFail: true},Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6.2K bytes - Viewed (0) -
cmd/admin-handlers.go
r.URL.Path, w.Header().Get(xhttp.AmzRequestID), w.Header().Get(xhttp.AmzRequestHostID))) } else { errorRespJSON = encodeResponseJSON(APIErrorResponse{ Code: hr.apiErr.Code, Message: hr.errBody, Resource: r.URL.Path, RequestID: w.Header().Get(xhttp.AmzRequestID), HostID: globalDeploymentID(), })
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 99.7K bytes - Viewed (0) -
cmd/bucket-metadata.go
if err != nil { return output, metabytes, err } outbuf := bytes.NewBuffer(nil) objectKey := crypto.GenerateKey(key.Plaintext, rand.Reader) sealedKey := objectKey.Seal(key.Plaintext, crypto.GenerateIV(rand.Reader), crypto.S3.String(), bucket, "") crypto.S3.CreateMetadata(metadata, key.KeyID, key.Ciphertext, sealedKey)Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 18.2K bytes - Viewed (0) -
src/main/java/org/codelibs/core/collection/SLinkedList.java
static final long serialVersionUID = 1L; private transient Entry header = new Entry(null, null, null); private transient int size = 0; /** * Creates an {@link SLinkedList}. */ public SLinkedList() { header.next = header; header.previous = header; } /** * Returns the first element. * * @return the first elementRegistered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Thu Jun 19 09:12:22 UTC 2025 - 10.5K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/ReaderUtil.java
} /** * Reads text from the given {@link Reader}. * <p> * The {@link Reader} is not closed by this method. * </p> * * @param reader * the character input stream to read from (must not be {@literal null}) * @return the text read from the reader */ public static String readText(final Reader reader) { assertArgumentNotNull("reader", reader);Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 4.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/ioctl/Smb2IoctlResponseTest.java
byte[] header = buildHeader(NtStatus.NT_STATUS_INVALID_PARAMETER); byte[] body = buildErrorBody(2, 3, new byte[] { (byte) 0xAA, (byte) 0xBB, (byte) 0xCC }); byte[] packet = new byte[header.length + body.length]; System.arraycopy(header, 0, packet, 0, header.length); System.arraycopy(body, 0, packet, header.length, body.length);
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 10.9K bytes - Viewed (0) -
cmd/erasure-object.go
} // GetObjectNInfo - returns object info and an object // Read(Closer). When err != nil, the returned reader is always nil. func (er erasureObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (gr *GetObjectReader, err error) { if !opts.NoAuditLog { auditObjectErasureSet(ctx, "GetObject", object, &er) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 24 04:05:31 UTC 2025 - 80.4K bytes - Viewed (0)