Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 94 for NewWriter (0.25 sec)

  1. cmd/site-replication-utils_gen_test.go

    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeSiteResyncStatus(b *testing.B) {
    	v := SiteResyncStatus{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeSiteResyncStatus(b *testing.B) {
    	v := SiteResyncStatus{}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Nov 14 15:16:40 GMT 2022
    - 2.4K bytes
    - Viewed (0)
  2. lib/time/mkzip.go

    	log.SetPrefix("mkzip: ")
    	log.SetFlags(0)
    	flag.Usage = usage
    	flag.Parse()
    	args := flag.Args()
    	if len(args) != 1 || !strings.HasSuffix(args[0], ".zip") {
    		usage()
    	}
    
    	var zb bytes.Buffer
    	zw := zip.NewWriter(&zb)
    	seen := make(map[string]bool)
    	err := filepath.WalkDir(".", func(path string, d fs.DirEntry, err error) error {
    		if d.IsDir() {
    			return nil
    		}
    		data, err := os.ReadFile(path)
    		if err != nil {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Mar 04 17:32:07 GMT 2024
    - 2.1K bytes
    - Viewed (0)
  3. src/bufio/bufio.go

    		size = defaultBufSize
    	}
    	return &Writer{
    		buf: make([]byte, size),
    		wr:  w,
    	}
    }
    
    // NewWriter returns a new [Writer] whose buffer has the default size.
    // If the argument io.Writer is already a [Writer] with large enough buffer size,
    // it returns the underlying [Writer].
    func NewWriter(w io.Writer) *Writer {
    	return NewWriterSize(w, defaultBufSize)
    }
    
    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)
  4. src/cmd/addr2line/main.go

    		log.Fatal(err)
    	}
    	defer f.Close()
    
    	tab, err := f.PCLineTable()
    	if err != nil {
    		log.Fatalf("reading %s: %v", flag.Arg(0), err)
    	}
    
    	stdin := bufio.NewScanner(os.Stdin)
    	stdout := bufio.NewWriter(os.Stdout)
    
    	for stdin.Scan() {
    		p := stdin.Text()
    		if strings.Contains(p, ":") {
    			// Reverse translate file:line to pc.
    			// This was an extension in the old C version of 'go tool addr2line'
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Apr 11 16:34:30 GMT 2022
    - 2.3K bytes
    - Viewed (0)
  5. src/cmd/asm/main.go

    	case "index":
    		// known to compiler; ignore here so people can use
    		// the same list with -gcflags=-spectre=LIST and -asmflags=-spectrre=LIST
    	case "all", "ret":
    		ctxt.Retpoline = true
    	}
    
    	ctxt.Bso = bufio.NewWriter(os.Stdout)
    	defer ctxt.Bso.Flush()
    
    	architecture.Init(ctxt)
    
    	// Create object file, write header.
    	buf, err := bio.Create(*flags.OutputFile)
    	if err != nil {
    		log.Fatal(err)
    	}
    	defer buf.Close()
    
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Aug 29 07:48:38 GMT 2023
    - 2.7K bytes
    - Viewed (0)
  6. docs/debugging/xattr/main.go

    		log.Fatalln("setting an attribute requires a non-zero value")
    	}
    
    	if !set && value > 0 {
    		log.Fatalln("to set a value please specify --set along with --value")
    	}
    
    	table := tablewriter.NewWriter(os.Stdout)
    	table.SetHeader([]string{"Name", "Value"})
    	table.SetAutoWrapText(false)
    	table.SetAutoFormatHeaders(true)
    	table.SetHeaderAlignment(tablewriter.ALIGN_LEFT)
    	table.SetAlignment(tablewriter.ALIGN_LEFT)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Dec 29 23:52:41 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  7. internal/config/subnet/subnet.go

    	if !c.Registered() {
    		return "", errors.New("Deployment is not registered with SUBNET. Please register the deployment via 'mc license register ALIAS'")
    	}
    
    	var body bytes.Buffer
    	writer := multipart.NewWriter(&body)
    	part, e := writer.CreateFormFile("file", filename)
    	if e != nil {
    		return "", e
    	}
    
    	if _, e = part.Write(payload); e != nil {
    		return "", e
    	}
    	writer.Close()
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 27 16:35:36 GMT 2023
    - 2.9K bytes
    - Viewed (0)
  8. src/archive/zip/writer.go

    	testHookCloseSizeOffset func(size, offset uint64)
    }
    
    type header struct {
    	*FileHeader
    	offset uint64
    	raw    bool
    }
    
    // NewWriter returns a new [Writer] writing a zip file to w.
    func NewWriter(w io.Writer) *Writer {
    	return &Writer{cw: &countWriter{w: bufio.NewWriter(w)}}
    }
    
    // SetOffset sets the offset of the beginning of the zip data within the
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Apr 04 14:28:57 GMT 2024
    - 19.3K bytes
    - Viewed (0)
  9. cmd/callhome.go

    	return err
    }
    
    func createHealthJSONGzip(ctx context.Context, healthInfo madmin.HealthInfo) []byte {
    	var b bytes.Buffer
    	gzWriter := gzip.NewWriter(&b)
    
    	header := struct {
    		Version string `json:"version"`
    	}{Version: healthInfo.Version}
    
    	enc := json.NewEncoder(gzWriter)
    	if e := enc.Encode(header); e != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.1K bytes
    - Viewed (1)
  10. cmd/bucket-metadata_gen_test.go

    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeBucketMetadata(b *testing.B) {
    	v := BucketMetadata{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeBucketMetadata(b *testing.B) {
    	v := BucketMetadata{}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 2.3K bytes
    - Viewed (0)
Back to top