- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for readAs (0.33 sec)
-
cmd/erasure-object.go
} ctx = lkctx.Context() // Release lock when the metadata is verified, and reader // is ready to be read. // // This is possible to be lock free because // - xl.meta for inlined objects has already read the data // into memory, any mutation on xl.meta subsequently is // inconsequential to the overall read operation. // - xl.meta metadata is still verified for quorum under lock()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 80.4K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
if isCompressed { wantEncryption := crypto.Requested(r.Header) || isEncrypted s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption) idxCb = cb defer s2c.Close() reader = etag.Wrap(s2c, reader) length = -1 } srcInfo.Reader, err = hash.NewReader(ctx, reader, length, "", "", actualPartSize) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 39.5K bytes - Viewed (0) -
cmd/object-handlers.go
compressMetadata[ReservedMetadataPrefix+"actual-size"] = strconv.FormatInt(actualSize, 10) reader = etag.NewReader(ctx, reader, nil, nil) wantEncryption := crypto.Requested(r.Header) s2c, cb := newS2CompressReader(reader, actualSize, wantEncryption) dstOpts.IndexCB = cb defer s2c.Close() reader = etag.Wrap(s2c, reader) length = -1 } else { delete(srcInfo.UserDefined, ReservedMetadataPrefix+"compression")
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 120.6K bytes - Viewed (0) -
cmd/erasure-multipart.go
} // We can safely allow RenameFile errors up to len(er.getDisks()) - writeQuorum // otherwise return failure. Cleanup successful renames. return evalDisks(disks, errs), err } // PutObjectPart - reads incoming stream and internally erasure codes // them. This call is similar to single put operation but it is part // of the multipart transaction. // // Implements S3 compatible Upload Part API.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 47.3K bytes - Viewed (0) -
cmd/object-api-interface.go
if etag != "" { header.Set("ETag", etag) } Range := &HTTPRangeSpec{Start: startOffset, End: startOffset + length} reader, err := api.GetObjectNInfo(ctx, bucket, object, Range, header, opts) if err != nil { return err } defer reader.Close() _, err = xioutil.Copy(writer, reader) return err
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 17.5K bytes - Viewed (0) -
apache-maven/pom.xml
</dependency> <dependency> <groupId>org.apache.maven</groupId> <artifactId>maven-logging</artifactId> </dependency> <dependency> <groupId>org.jline</groupId> <artifactId>jline-reader</artifactId> </dependency> <dependency> <groupId>org.jline</groupId> <artifactId>jline-terminal-jni</artifactId> </dependency> <dependency> <groupId>org.jline</groupId>
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Sat Sep 06 21:30:13 UTC 2025 - 12.7K bytes - Viewed (0) -
pom.xml
<user>${packaging.fess.user}</user> <group>${packaging.fess.group}</group> </mapper> </data> <!-- Add readme files --> <data> <type>files</type> <paths> <path>${project.basedir}/LICENSE</path> <path>${project.basedir}/README.md</path> </paths> <dst>${packaging.fess.home.dir}</dst> <mapper> <type>perm</type>
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Sep 04 05:22:58 UTC 2025 - 49.6K bytes - Viewed (0)