- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 187 for reader_r (0.13 sec)
-
cmd/post-policy-fan-out.go
if err != nil { errs[idx] = err return } reader, err = reader.WithEncryption(hr, &objectEncryptionKey) if err != nil { errs[idx] = err return } } objInfo, err := objectAPI.PutObject(ctx, bucket, req.Key, reader, ObjectOptions{ Versioned: globalBucketVersioningSys.PrefixEnabled(bucket, req.Key),
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 3.5K bytes - Viewed (0) -
internal/crypto/key_test.go
package crypto import ( "bytes" "crypto/rand" "encoding/hex" "io" "testing" "github.com/minio/minio/internal/logger" ) var shortRandom = func(limit int64) io.Reader { return io.LimitReader(rand.Reader, limit) } func recoverTest(i int, shouldPass bool, t *testing.T) { if err := recover(); err == nil && !shouldPass { t.Errorf("Test %d should fail but passed successfully", i)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 6.7K bytes - Viewed (0) -
src/archive/zip/zip_test.go
} } type repeatedByte struct { off int64 b byte n int64 } // rleBuffer is a run-length-encoded byte buffer. // It's an io.Writer (like a bytes.Buffer) and also an io.ReaderAt, // allowing random-access reads. type rleBuffer struct { buf []repeatedByte } func (r *rleBuffer) Size() int64 { if len(r.buf) == 0 { return 0 } last := &r.buf[len(r.buf)-1]
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 19.6K bytes - Viewed (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/classanalysis/AnalyzeAndShade.kt
fun visitClassFile(file: Path) { try { val reader = ClassReader(Files.newInputStream(file)) val details = classes[reader.className] details.visited = true val classWriter = ClassWriter(0) reader.accept( ClassRemapper( classWriter,
Registered: Wed Oct 30 11:36:09 UTC 2024 - Last Modified: Mon Oct 28 12:55:30 UTC 2024 - 6.8K bytes - Viewed (0) -
internal/http/request-recorder.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package http import ( "bytes" "io" ) // RequestRecorder - records the // of a given io.Reader type RequestRecorder struct { // Data source to record io.Reader // Response body should be logged LogBody bool // internal recording buffer buf bytes.Buffer // total bytes read including header size bytesRead int }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Apr 12 21:37:19 UTC 2023 - 1.8K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental_reader.h
// streamz->GetCell("label-value")->IncrementBy(1); // // The test code can then read and test the value of that counter: // // auto* reader = TFE_MonitoringNewCounterReader("name"); // test(); // int64_t value = TFE_MonitoringReadCounter1(reader, "label-value"); // Opaque handle to a reader. typedef struct TFE_MonitoringCounterReader TFE_MonitoringCounterReader; // Returns a handle to be used for reading values from streamz counter. The
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Thu Apr 20 03:14:47 UTC 2023 - 2.3K bytes - Viewed (0) -
internal/hash/reader_test.go
} } // Tests hash reader checksum verification. func TestHashReaderVerification(t *testing.T) { testCases := []struct { desc string src io.Reader size int64 actualSize int64 md5hex, sha256hex string err error }{ 0: {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 18 17:00:54 UTC 2023 - 10.3K bytes - Viewed (0) -
internal/auth/credentials.go
accessKey, err = GenerateAccessKey(accessKeyMaxLen, rand.Reader) if err != nil { return "", "", err } secretKey, err = GenerateSecretKey(secretKeyMaxLen, rand.Reader) if err != nil { return "", "", err } return accessKey, secretKey, nil } // GenerateAccessKey returns a new access key generated randomly using // the given io.Reader. If random is nil, crypto/rand.Reader is used.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue May 28 17:14:16 UTC 2024 - 12K 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 Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Aug 31 18:25:48 UTC 2024 - 39.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/badword/ApiAdminBadwordAction.java
validateApi(body, messages -> {}); CommonPoolUtil.execute(() -> { try (Reader reader = new BufferedReader(new InputStreamReader(body.badWordFile.getInputStream(), getCsvEncoding()))) { badWordService.importCsv(reader); suggestHelper.storeAllBadWords(false); } catch (final Exception e) {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 8.4K bytes - Viewed (0)