- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for buffers (0.03 sec)
-
cmd/object-handlers_test.go
}{ {byteData: generateBytesData(6 * humanize.KiByte)}, } h := md5.New() h.Write(bytesData[0].byteData) bytesData[0].md5sum = hex.EncodeToString(h.Sum(nil)) buffers := []*bytes.Buffer{ new(bytes.Buffer), new(bytes.Buffer), } bucketInfo, err := obj.GetBucketInfo(context.Background(), bucketName, BucketOptions{}) if err != nil {Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 163.1K bytes - Viewed (0) -
cmd/server_test.go
c.Assert(err, nil) c.Assert(response.StatusCode, http.StatusOK) var buffer bytes.Buffer // data to be written into buffer. data := "1234567890" // seed the random number generator once. rand.Seed(3) // generate a random number between 13 and 200. randInt := getRandomRange(13, 200, -1) // write into buffer till length of the buffer is greater than the generated random number. for i := 0; i <= randInt; i += 10 {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118.1K bytes - Viewed (0) -
cmd/admin-handlers.go
if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } // Convert local entries to JSON go func() { var buf bytes.Buffer enc := json.NewEncoder(&buf) for { select { case <-ctx.Done(): return case li := <-logCh: if !li.SendLog(node, logKind) { continue } buf.Reset()Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 99.6K bytes - Viewed (0) -
tensorflow/c/c_api.cc
result = session->Run(run_options_proto, input_pairs, output_tensor_names, target_oper_names, &outputs, &run_metadata_proto); // Serialize back to upstream client, who now owns the new buffer if (run_metadata != nullptr) { status->status = MessageToBuffer(run_metadata_proto, run_metadata); if (!status->status.ok()) return; } } else {
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Tue May 13 06:30:43 UTC 2025 - 102.3K bytes - Viewed (0) -
cmd/object-handlers.go
} const ( compressionAlgorithmV1 = "golang/snappy/LZ77" compressionAlgorithmV2 = "klauspost/compress/s2" // When an upload exceeds encryptBufferThreshold ... encryptBufferThreshold = 1 << 20 // add an input buffer of this size. encryptBufferSize = 1 << 20 // minCompressibleSize is the minimum size at which we enable compression. minCompressibleSize = 4096 )
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/sts-handlers_test.go
} } `, } exportContent := map[string][]byte{} for k, v := range exportContentStrings { exportContent[k] = []byte(v) } var importContent []byte { var b bytes.Buffer zipWriter := zip.NewWriter(&b) rawDataFn := func(r io.Reader, filename string, sz int) error { header, zerr := zip.FileInfoHeader(dummyFileInfo{ name: filename, size: int64(sz),
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 100.2K bytes - Viewed (1)