Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ReaderErr (0.07 sec)

  1. internal/s3select/jstream/errors.go

    	msg       string // description of error
    	context   string // additional error context
    	pos       errPos
    	atChar    byte
    	readerErr error // underlying reader error, if any
    }
    
    // ReaderErr returns the underlying error.
    func (e DecoderError) ReaderErr() error { return e.readerErr }
    
    // Error returns a string representation of the error.
    func (e DecoderError) Error() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  2. internal/s3select/jstream/scanner.go

    	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 {
    	sr := &scanner{
    		end:       maxInt,
    		fillReq:   make(chan struct{}),
    		fillReady: make(chan int64),
    	}
    
    	go func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  5. internal/s3select/jstream/decoder_test.go

    	if err == nil {
    		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
    	}{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top