Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 187 for reader_r (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. internal/s3select/jstream/decoder.go

    	if len(context) > 0 {
    		err.context = context[0]
    	}
    	err.atChar = d.cur()
    	err.pos[0] = d.lineNo + 1
    	err.pos[1] = int(d.pos - d.lineStart)
    	err.readerErr = d.readerErr
    	return err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top