- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Hencke (0.2 sec)
-
cmd/erasure-multipart.go
} var checksumCombined []byte // However, in case of encryption, the persisted part ETags don't match // what we have sent to the client during PutObjectPart. The reason is // that ETags are encrypted. Hence, the client will send a list of complete // part ETags of which non can match the ETag of any part. For example // ETag (client): 30902184f4e62dd8f98f0aaff810c626
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/admin-handlers.go
if err != nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL) return } setEventStreamHeaders(w) // Trace Publisher and peer-trace-client uses nonblocking send and hence does not wait for slow receivers. // Keep 100k buffered channel. // If receiver cannot keep up with that we drop events. traceCh := make(chan []byte, 100000) peers, _ := newPeerRestClients(globalEndpoints)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
internal/ioutil/ioutil.go
// the end, this is performed by the caller before // closing 'w'. if err = disk.DisableDirectIO(file); err != nil { return written, err } // buf is not aligned, hence use writeUnaligned() // for the remainder un, err = w.Write(buf[len(buf)-remain:]) nw += int64(un) } if nw > 0 { written += nw } if err != nil { return written, err
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
cmd/erasure-decode.go
} bufIdx := p.readerToBuf[i] if p.buf[bufIdx] == nil { // Reading first time on this disk, hence the buffer needs to be allocated. // Subsequent reads will reuse this buffer. p.buf[bufIdx] = make([]byte, p.shardSize) } // For the last shard, the shardsize might be less than previous shard sizes. // Hence the following statement ensures that the buffer size is reset to the right size.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
internal/pubsub/pubsub.go
maxSubscribers int32 // not atomics: subs []*Sub[T] sync.RWMutex } // Publish message to the subscribers. // Note that publish is always non-blocking send so that we don't block on slow receivers. // Hence receivers should use buffered channel so as not to miss the published events. func (ps *PubSub[T, M]) Publish(item T) { ps.RLock() defer ps.RUnlock() for _, sub := range ps.subs {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
cmd/bitrot-streaming.go
// sequent of operations: // 1) pipe.Write() // 2) pipe.Close() // Now pipe.Close() can return before the data is read on the other end of the pipe and written to the disk // Hence an immediate Read() on the file can return incorrect data. if b.canClose != nil { b.canClose.Wait() } return err } // newStreamingBitrotWriterBuffer returns streaming bitrot writer implementation.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/bucket-metadata.go
if b.Created.IsZero() { configs, err := b.getAllLegacyConfigs(ctx, objectAPI) if err != nil { return b, err } if len(configs) > 0 { // Old bucket without bucket metadata. Hence we migrate existing settings. if err = b.convertLegacyConfigs(ctx, objectAPI, configs); err != nil { return b, err } } } if parse { // nothing to update, parse and proceed.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 16.5K bytes - Viewed (0) -
internal/etag/etag.go
// single-part object is equal to the object's content MD5. // Formatting the SSE-S3 ETag before decryption will result // in a random-looking ETag which an S3 client will not accept. // // Hence, a caller has to check: // // if method == SSE-S3 { // ETag, err := Decrypt(key, ETag) // if err != nil { // } // } // ETag = ETag.Format() func (e ETag) Format() ETag { if !e.IsEncrypted() {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 13.3K bytes - Viewed (0) -
internal/crypto/doc.go
// // ### SSE-S3 and KMS // // SSE-S3 requires that the KMS provides two functions: // // 1. Generate(KeyID) -> (Key, EncKey) // // 2. Unseal(KeyID, EncKey) -> Key // // 1. Encrypt: // Input: KeyID, bucket, object, metadata, object_data // - Key, EncKey := Generate(KeyID) // - IV := Random({0,1}²⁵⁶) // - ObjectKey := SHA256(Key, Random({0,1}²⁵⁶))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Aug 26 19:52:29 GMT 2022 - 5K bytes - Viewed (0) -
buildscripts/checkdeps.sh
GO_VERSION="1.16" OSX_VERSION="10.8" KNAME=$(uname -s) ARCH=$(uname -m) case "${KNAME}" in SunOS) ARCH=$(isainfo -k) ;; esac } ## FIXME: ## In OSX, 'readlink -f' option does not exist, hence ## we have our own readlink -f behavior here. ## Once OSX has the option, below function is good enough. ## ## readlink() { ## return /bin/readlink -f "$1" ## } ## readlink() { TARGET_FILE=$1
Shell Script - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri May 26 05:07:25 GMT 2023 - 3.4K bytes - Viewed (0)