- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for wrap (0.12 sec)
-
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 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
internal/grid/types.go
}() enc := json.NewEncoder(buf) err = enc.Encode(j.val) if err != nil { return b, err } return msgp.AppendBytes(b, buf.Bytes()), nil } // UnmarshalMsg will JSON marshal the value and wrap as a msgp byte array. // Nil values are supported. func (j *JSON[T]) UnmarshalMsg(bytes []byte) ([]byte, error) { if bytes, err := msgp.ReadNilBytes(bytes); err == nil { if j.val != nil { j.p.pool.Put(j.val)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
internal/http/server.go
listenErrCallback(srv.Addrs[i], listenErrs[i]) } else { interfaceFound = true } } if !interfaceFound { return nil, errors.New("no available interface found") } // Wrap given handler to do additional // * return 503 (service unavailable) if the server in shutdown. wrappedHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { // If server is in shutdown.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
func diskHealthReader(ctx context.Context, r io.Reader) io.Reader { // Check if context has a disk health check. tracker, ok := ctx.Value(healthDiskCtxKey{}).(*healthDiskCtxValue) if !ok { // No need to wrap return r } return &diskHealthWrapper{r: r, tracker: tracker} } // diskHealthWriter provides a wrapper that will update disk health on // ctx, on every successful write.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/object-handlers.go
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") delete(srcInfo.UserDefined, ReservedMetadataPrefix+"actual-size") reader = gr }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
internal/hash/reader.go
} if r.size >= 0 && size >= 0 && r.size != size { return nil, SizeMismatch{Want: r.size, Got: size} } r.checksum = MD5 r.contentSHA256 = SHA256 if r.size < 0 && size >= 0 { r.src = etag.Wrap(ioutil.HardLimitReader(r.src, size), r.src) r.size = size } if r.actualSize <= 0 && actualSize >= 0 { r.actualSize = actualSize } return r, nil } if size >= 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.8K bytes - Viewed (0) -
internal/etag/reader.go
// // the ETag computed over the content. // reader := etag.Wrap(encryptedContent, content) func Wrap(wrapped, content io.Reader) io.Reader { if t, ok := content.(Tagger); ok { return wrapReader{ Reader: wrapped, Tagger: t, } } return wrapReader{ Reader: wrapped, } } // A Reader wraps an io.Reader and computes the // MD5 checksum of the read content as ETag. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/admin-handler-utils.go
} return toAPIErrorCode(ctx, err) } // wraps export error for more context func exportError(ctx context.Context, err error, fname, entity string) APIError { if entity == "" { return toAPIError(ctx, fmt.Errorf("error exporting %s with: %w", fname, err)) } return toAPIError(ctx, fmt.Errorf("error exporting %s from %s with: %w", entity, fname, err)) } // wraps import error for more context
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 8.2K bytes - Viewed (0) -
buildscripts/minio-upgrade.sh
#!/bin/bash trap 'cleanup $LINENO' ERR # shellcheck disable=SC2120 cleanup() { MINIO_VERSION=dev docker-compose \ -f "buildscripts/upgrade-tests/compose.yml" \ rm -s -f docker volume prune -f } verify_checksum_after_heal() { local sum1 sum1=$(curl -s "$2" | sha256sum) mc admin heal --json -r "$1" >/dev/null # test after healing local sum1_heal sum1_heal=$(curl -s "$2" | sha256sum)
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 11:39:55 GMT 2024 - 2.2K bytes - Viewed (0) -
cmd/naughty-disk_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "io" "sync" "time" "github.com/minio/madmin-go/v3" ) // naughtyDisk wraps a POSIX disk and returns programmed errors // specified by the developer. The purpose is to simulate errors // that are hard to simulate in practice like DiskNotFound. // Programmed errors are stored in errors field.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0)