- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 187 for reader_r (0.12 sec)
-
internal/s3select/jstream/scanner_test.go
var i int r := bytes.NewReader(data) scanner := newScanner(r) for scanner.pos < atomic.LoadInt64(&scanner.end) { c := scanner.next() if scanner.readerErr != nil { t.Fatal(scanner.readerErr) } if c != data[i] { t.Fatalf("expected %s, got %s", string(data[i]), string(c)) } t.Logf("pos=%d remaining=%d (%s)", i, r.Len(), string(c)) i++ } }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 3.2K bytes - Viewed (0) -
cmd/bitrot.go
if algo == HighwayHash256S { return newStreamingBitrotReader(disk, data, bucket, filePath, tillOffset, algo, shardSize) } return newWholeBitrotReader(disk, bucket, filePath, algo, tillOffset, sum) } // Close all the readers. func closeBitrotReaders(rs []io.ReaderAt) { for _, r := range rs { if r != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 7.6K bytes - Viewed (0) -
internal/s3select/jstream/scanner.go
) type scanner struct { pos int64 // position in reader ipos int64 // internal buffer position ifill int64 // internal buffer fill end int64 buf [chunk + 1]byte // internal buffer (with a lookback size of 1) nbuf [chunk]byte // next internal buffer fillReq chan struct{} fillReady chan int64 readerErr error // underlying reader error, if any } func newScanner(r io.Reader) *scanner {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 2.5K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/RenderMarkdown.java
MutableDataSet options = new MutableDataSet(); options.set(Parser.EXTENSIONS, Collections.singletonList(TablesExtension.create())); Parser parser = Parser.builder(options).build(); HtmlRenderer renderer = HtmlRenderer.builder(options).build(); File markdownFile = getMarkdownFile().get().getAsFile(); Charset inputEncoding = Charset.forName(getInputEncoding().get());
Registered: Wed Oct 30 11:36:09 UTC 2024 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 3.2K bytes - Viewed (0) -
internal/s3select/jstream/decoder.go
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 13.5K bytes - Viewed (0) -
cmd/sftp-server-driver.go
} func (f *sftpDriver) AccessKey() string { return f.permissions.CriticalOptions["AccessKey"] } func (f *sftpDriver) Fileread(r *sftp.Request) (ra io.ReaderAt, err error) { // This is not timing the actual read operation, but the time it takes to prepare the reader. stopFn := globalSftpMetrics.log(r, f.AccessKey()) defer stopFn(0, err) flags := r.Pflags() if !flags.Read { // sanity check
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 11.1K bytes - Viewed (0) -
internal/s3select/jstream/decoder_test.go
t.Fatalf("missing expected decoder error") } derr, ok := err.(DecoderError) if !ok { t.Fatalf("expected error of type DecoderError, got %T", err) } if derr.ReaderErr() == nil { t.Fatalf("missing expected underlying reader error") } } func TestDecoderMaxDepth(t *testing.T) { tests := []struct { input string maxDepth int mustFail bool }{ // No limit
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 6.6K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild.binary-compatibility.gradle
</p> ${writeFilterPreset(project)} """.stripIndent() it.renderer.set(EnrichedReportRenderer.class) } as Action) BinaryCompatibilityHelper.setupJApiCmpRichReportRules( delegate, acceptedViolations, apiSourceFolders, baseVersion.get(),
Registered: Wed Oct 30 11:36:09 UTC 2024 - Last Modified: Fri Jul 26 08:15:16 UTC 2024 - 9.1K bytes - Viewed (0) -
src/archive/zip/writer.go
// flag bit is set. However, there are several problems: // // * Many ZIP readers still do not support UTF-8. // * If the UTF-8 flag is cleared, several readers simply interpret the // name and comment fields as whatever the local system encoding is. // // In order to avoid breaking readers without UTF-8 support, // we avoid setting the UTF-8 flag if the strings are CP-437 compatible.
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Mon Sep 23 14:32:33 UTC 2024 - 19.4K bytes - Viewed (0) -
src/archive/zip/reader_test.go
} } func messWith(fileName string, corrupter func(b []byte)) (r io.ReaderAt, size int64) { data, err := os.ReadFile(filepath.Join("testdata", fileName)) if err != nil { panic("Error reading " + fileName + ": " + err.Error()) } corrupter(data) return bytes.NewReader(data), int64(len(data)) } func returnCorruptCRC32Zip() (r io.ReaderAt, size int64) { return messWith("go-with-datadesc-sig.zip", func(b []byte) {
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Thu Jul 25 00:25:45 UTC 2024 - 55.6K bytes - Viewed (0)