Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for WriteTo (3.76 sec)

  1. src/bytes/reader_test.go

    	{"ReadByte", func(r *Reader) { r.ReadByte() }},
    	{"UnreadRune", func(r *Reader) { r.UnreadRune() }},
    	{"Seek", func(r *Reader) { r.Seek(0, io.SeekCurrent) }},
    	{"WriteTo", func(r *Reader) { r.WriteTo(&Buffer{}) }},
    }
    
    func TestUnreadRuneError(t *testing.T) {
    	for _, tt := range UnreadRuneErrorTests {
    		reader := NewReader([]byte("0123456789"))
    		if _, _, err := reader.ReadRune(); err != nil {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Dec 13 18:45:54 GMT 2021
    - 8K bytes
    - Viewed (0)
  2. src/bytes/reader.go

    	}
    	r.i = abs
    	return abs, nil
    }
    
    // WriteTo implements the [io.WriterTo] interface.
    func (r *Reader) WriteTo(w io.Writer) (n int64, err error) {
    	r.prevRune = -1
    	if r.i >= int64(len(r.s)) {
    		return 0, nil
    	}
    	b := r.s[r.i:]
    	m, err := w.Write(b)
    	if m > len(b) {
    		panic("bytes.Reader.WriteTo: invalid Write count")
    	}
    	r.i += int64(m)
    	n = int64(m)
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 17:10:31 GMT 2023
    - 3.9K bytes
    - Viewed (0)
  3. cmd/admin-handlers-config-kv.go

    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	var s strings.Builder
    	for _, subSysConfig := range subSysConfigs {
    		subSysConfig.WriteTo(&s, false)
    	}
    
    	password := cred.SecretKey
    	econfigData, err := madmin.EncryptData(password, []byte(s.String()))
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.7K bytes
    - Viewed (0)
  4. src/archive/tar/reader.go

    	if err != nil && err != io.EOF {
    		tr.err = err
    	}
    	return n, err
    }
    
    // writeTo writes the content of the current file to w.
    // The bytes written matches the number of remaining bytes in the current file.
    //
    // If the current file is sparse and w is an io.WriteSeeker,
    // then writeTo uses Seek to skip past holes defined in Header.SparseHoles,
    // assuming that skipped regions are filled with NULs.
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Mar 08 01:59:14 GMT 2024
    - 26.8K bytes
    - Viewed (0)
  5. src/bufio/bufio.go

    		buf.Write(fb)
    	}
    	buf.Write(frag)
    	return buf.String(), err
    }
    
    // WriteTo implements io.WriterTo.
    // This may make multiple calls to the [Reader.Read] method of the underlying [Reader].
    // If the underlying reader supports the [Reader.WriteTo] method,
    // this calls the underlying [Reader.WriteTo] without buffering.
    func (b *Reader) WriteTo(w io.Writer) (n int64, err error) {
    	b.lastByte = -1
    	b.lastRuneSize = -1
    
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Oct 12 14:39:08 GMT 2023
    - 21.8K bytes
    - Viewed (0)
  6. internal/http/server.go

    				return nil
    			}
    
    			// Write all running goroutines.
    			tmp, err := os.CreateTemp("", "minio-goroutines-*.txt")
    			if err == nil {
    				_ = pprof.Lookup("goroutine").WriteTo(tmp, 1)
    				tmp.Close()
    				return errors.New("timed out. some connections are still active. goroutines written to " + tmp.Name())
    			}
    			return errors.New("timed out. some connections are still active")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  7. internal/grid/connection.go

    			PutByteBuffer(toSend)
    			err = conn.SetWriteDeadline(time.Now().Add(connWriteTimeout))
    			if err != nil {
    				gridLogIf(ctx, fmt.Errorf("conn.SetWriteDeadline: %w", err))
    				return
    			}
    			_, err = buf.WriteTo(conn)
    			if err != nil {
    				gridLogIf(ctx, fmt.Errorf("ws write: %w", err))
    				return
    			}
    			continue
    		}
    
    		// Merge entries and send
    		queue = append(queue, toSend)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  8. src/bytes/example_test.go

    	"fmt"
    	"io"
    	"os"
    	"sort"
    	"strconv"
    	"unicode"
    )
    
    func ExampleBuffer() {
    	var b bytes.Buffer // A Buffer needs no initialization.
    	b.Write([]byte("Hello "))
    	fmt.Fprintf(&b, "world!")
    	b.WriteTo(os.Stdout)
    	// Output: Hello world!
    }
    
    func ExampleBuffer_reader() {
    	// A Buffer can turn a string or a []byte into an io.Reader.
    	buf := bytes.NewBufferString("R29waGVycyBydWxlIQ==")
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Mar 04 15:54:40 GMT 2024
    - 15K bytes
    - Viewed (1)
  9. src/bytes/buffer.go

    	copy(b2, b)
    	return b2[:len(b)]
    }
    
    // WriteTo writes data to w until the buffer is drained or an error occurs.
    // The return value n is the number of bytes written; it always fits into an
    // int, but it is int64 to match the io.WriterTo interface. Any error
    // encountered during the write is also returned.
    func (b *Buffer) WriteTo(w io.Writer) (n int64, err error) {
    	b.lastRead = opInvalid
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 17:10:31 GMT 2023
    - 15.7K bytes
    - Viewed (0)
  10. cmd/utils.go

    			runtime.GC()
    			var buf bytes.Buffer
    			err := pprof.Lookup("heap").WriteTo(&buf, 0)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerBlock:
    		runtime.SetBlockProfileRate(100)
    		prof.stopFn = func() ([]byte, error) {
    			var buf bytes.Buffer
    			err := pprof.Lookup("block").WriteTo(&buf, 0)
    			runtime.SetBlockProfileRate(0)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerMutex:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 31.4K bytes
    - Viewed (0)
Back to top