Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 82 for reader_r (0.56 sec)

  1. doc/asm.html

    </p>
    
    <pre>
    type reader struct {
    	buf [bufSize]byte
    	r   int
    }
    </pre>
    
    <p>
    Assembly can refer to the size of this struct
    as <code>reader__size</code> and the offsets of the two fields
    as <code>reader_buf</code> and <code>reader_r</code>.
    Hence, if register <code>R1</code> contains a pointer to
    a <code>reader</code>, assembly can reference the <code>r</code> field
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Nov 28 19:15:27 UTC 2023
    - 36.3K bytes
    - Viewed (1)
  2. internal/event/config_test.go

    		panic(err)
    	}
    
    	testCases := []struct {
    		reader     *strings.Reader
    		region     string
    		targetList *TargetList
    		expectErr  bool
    	}{
    		{reader1, "eu-west-1", nil, true},
    		{reader2, "us-east-1", targetList1, true},
    		{reader4, "us-east-1", targetList1, true},
    		{reader3, "", targetList2, false},
    		{reader2, "us-east-1", targetList2, false},
    	}
    
    	for i, testCase := range testCases {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 29K bytes
    - Viewed (0)
  3. src/archive/zip/reader.go

    // the [ErrInsecurePath] error and use the returned reader.
    func NewReader(r io.ReaderAt, size int64) (*Reader, error) {
    	if size < 0 {
    		return nil, errors.New("zip: size cannot be negative")
    	}
    	zr := new(Reader)
    	var err error
    	if err = zr.init(r, size); err != nil && err != ErrInsecurePath {
    		return nil, err
    	}
    	return zr, err
    }
    
    func (r *Reader) init(rdr io.ReaderAt, size int64) error {
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Sat Aug 03 01:05:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  4. src/archive/tar/reader.go

    	"strconv"
    	"strings"
    	"time"
    )
    
    // Reader provides sequential access to the contents of a tar archive.
    // Reader.Next advances to the next file in the archive (including the first),
    // and then Reader can be treated as an io.Reader to access the file's data.
    type Reader struct {
    	r    io.Reader
    	pad  int64      // Amount of padding (ignored) after current file entry
    	curr fileReader // Reader for current file entry
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  5. cmd/metacache-stream_test.go

    	if err != io.EOF {
    		t.Fatal(err)
    	}
    }
    
    func Test_metacacheReader_readAll(t *testing.T) {
    	r := loadMetacacheSample(t)
    	defer r.Close()
    	var readErr error
    	objs := make(chan metaCacheEntry, 1)
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    		readErr = r.readAll(context.Background(), objs)
    		wg.Done()
    	}()
    	want := loadMetacacheSampleNames
    	i := 0
    	for entry := range objs {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 15K bytes
    - Viewed (0)
  6. build-logic/documentation/src/test/groovy/gradlebuild/docs/dsl/docbook/ClassDocRendererTest.groovy

            </section>
        </section>''')
        }
    
        def linkRenderer() {
            LinkRenderer renderer = Mock()
            _ * renderer.link(!null, !null) >> {
                args -> parse("<classname>${args[0].signature}</classname>", document)
            }
            return renderer
        }
    
        def classDoc(Map<String, ?> args = [:], String name) {
            ClassDoc classDoc = Mock()
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 40.8K bytes
    - Viewed (0)
  7. cmd/erasure-healing.go

    	var found int
    	var notFound int
    	var foundNotEmpty int
    	var otherFound int
    	for _, readErr := range errs {
    		switch {
    		case readErr == nil:
    			found++
    		case readErr == errFileNotFound || readErr == errVolumeNotFound:
    			notFound++
    		case readErr == errVolumeNotEmpty:
    			foundNotEmpty++
    		default:
    			otherFound++
    		}
    	}
    	found = found + foundNotEmpty + otherFound
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  8. src/bufio/bufio.go

    // NewReaderSize returns a new [Reader] whose buffer has at least the specified
    // size. If the argument io.Reader is already a [Reader] with large enough
    // size, it returns the underlying [Reader].
    func NewReaderSize(rd io.Reader, size int) *Reader {
    	// Is it already a Reader?
    	b, ok := rd.(*Reader)
    	if ok && len(b.buf) >= size {
    		return b
    	}
    	r := new(Reader)
    	r.reset(make([]byte, max(size, minReadBufferSize)), rd)
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  9. internal/ringbuffer/ring_buffer.go

    	if len(p) == 0 {
    		return 0, r.readErr(false)
    	}
    
    	r.mu.Lock()
    	defer r.mu.Unlock()
    	if err := r.readErr(true); err != nil {
    		return 0, err
    	}
    
    	r.wg.Add(1)
    	defer r.wg.Done()
    	n, err = r.read(p)
    	for err == ErrIsEmpty && r.block {
    		r.writeCond.Wait()
    		if err = r.readErr(true); err != nil {
    			break
    		}
    		n, err = r.read(p)
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. internal/ringbuffer/ring_buffer_test.go

    			fmt.Println(args...)
    		}
    	}
    	// Inject random reader/writer sleeps.
    	const maxSleep = int(1 * time.Millisecond)
    	doSleep := !testing.Short()
    	rb := New(4 << 10).SetBlocking(true)
    
    	// Reader
    	var readErr error
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    		readRng := rand.New(rand.NewSource(1))
    		defer wg.Done()
    		defer rb.CloseWithError(readErr)
    		buf := make([]byte, 1024)
    		for {
    			// Read
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
Back to top