- Sort Score
- Num 10 results
- Language All
Results 251 - 260 of 411 for readLen (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/tier_gen.go
package cmd import ( "github.com/minio/madmin-go/v3" "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *TierConfigMgr) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001--
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3.9K bytes - Click Count (0) -
internal/bucket/encryption/bucket-sse-config.go
XMLName xml.Name `xml:"ServerSideEncryptionConfiguration"` Rules []Rule `xml:"Rule"` } // ParseBucketSSEConfig - Decodes given XML to a valid default bucket encryption config func ParseBucketSSEConfig(r io.Reader) (*BucketSSEConfig, error) { var config BucketSSEConfig err := xml.NewDecoder(r).Decode(&config) if err != nil { return nil, err } // Validates server-side encryption config rules
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 4.9K bytes - Click Count (0) -
cmd/post-policy_test.go
} writer.Write([]byte("hello world")) // Close before creating the new request. w.Close() // Set the body equal to the created policy. reader := bytes.NewReader(buf.Bytes()) req, err := http.NewRequest(http.MethodPost, makeTestTargetURL(endPoint, bucketName, "", nil), reader) if err != nil { return nil, err } // Set form content-type. req.Header.Set("Content-Type", w.FormDataContentType())
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 30.6K bytes - Click Count (0) -
src/archive/tar/common.go
// other fields in Header take precedence over PAXRecords. PAXRecords map[string]string // Format specifies the format of the tar header. // // This is set by Reader.Next as a best-effort guess at the format. // Since the Reader liberally reads some non-compliant files, // it is possible for this to be FormatUnknown. // // If the format is unspecified when Writer.WriteHeader is called,
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Oct 07 19:46:36 GMT 2025 - 24.5K bytes - Click Count (0) -
impl/maven-core/src/test/remote-repo/org/apache/maven/its/plugins/maven-it-plugin/0.1/maven-it-plugin-0.1.jar
false false false true process-test-classes org.apache.maven.plugin.coreit.EMojo java per-lookup once-per-session it Does nothing. compile false true false false false true org.apache.maven.plugin.coreit.ItMojo java per-lookup once-per-session xpp3-reader Does nothing. false true false false false true generate-sources org.apache.maven.plugin.coreit.CMojo java per-lookup once-per-session models java.lang.String[] false true version java.lang.String false true ${version} xpp3-writer Does nothing. false...
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 13.2K bytes - Click Count (0) -
internal/s3select/csv/args.go
CommentCharacter string `xml:"Comments"` AllowQuotedRecordDelimiter bool `xml:"AllowQuotedRecordDelimiter"` unmarshaled bool } // IsEmpty - returns whether reader args is empty or not. func (args *ReaderArgs) IsEmpty() bool { return !args.unmarshaled } // UnmarshalXML - decodes XML data. func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 20 18:31:45 GMT 2024 - 5.7K bytes - Click Count (0) -
CONTRIBUTING.md
- Auto-generated files (e.g., by code generators). - Minor configuration files (e.g., `.gitignore`). - Documentation samples and code snippets (e.g., `.java`, `.kt`, `.groovy`, `.kts`). - Release notes (e.g., `.md`). - READMEs (e.g., `.md`). #### Copyright Header for Source Files: ``` /* * Copyright [YEAR OF FILE CREATION] Gradle and contributors. * * Licensed under the Apache License, Version 2.0 (the "License");
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Tue Nov 25 06:57:22 GMT 2025 - 19K bytes - Click Count (0) -
cmd/http-tracer.go
// http stats requests and audit if enabled. respRecorder := xhttp.NewResponseRecorder(w) // Setup a http request body recorder reqRecorder := &xhttp.RequestRecorder{Reader: r.Body} r.Body = reqRecorder // Create tracing data structure and associate it to the request context tc := mcontext.TraceCtxt{ AmzReqID: w.Header().Get(xhttp.AmzRequestID),
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Sep 24 17:13:00 GMT 2024 - 6K bytes - Click Count (0) -
cmd/batch-handlers_gen.go
// Code generated by github.com/tinylib/msgp DO NOT EDIT. package cmd import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *BatchJobPrefix) DecodeMsg(dc *msgp.Reader) (err error) { var zb0002 uint32 zb0002, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err) return } if cap((*z)) >= int(zb0002) { (*z) = (*z)[:zb0002] } else {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 20.4K bytes - Click Count (0) -
cmd/erasure_test.go
{dataBlocks: 8, parityBlocks: 4, missingData: 2, missingParity: 2, reconstructParity: false, shouldFail: false}, } func TestErasureEncodeDecode(t *testing.T) { data := make([]byte, 256) if _, err := io.ReadFull(rand.Reader, data); err != nil { t.Fatalf("Failed to read random data: %v", err) } for i, test := range erasureEncodeDecodeTests { buffer := make([]byte, len(data), 2*len(data)) copy(buffer, data)Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 4.8K bytes - Click Count (0)