Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 64 for newWriter (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/archive/zip/writer_test.go

    	// write a zip file
    	archive := new(bytes.Buffer)
    	w := NewWriter(archive)
    
    	for i := range files {
    		f := &files[i]
    		f.crc32 = crc32.ChecksumIEEE(f.content)
    		size := uint64(len(f.content))
    		f.uncompressedSize = size
    		f.compressedSize = size
    
    		var compressedContent []byte
    		if f.method == Deflate {
    			var buf bytes.Buffer
    			w, err := flate.NewWriter(&buf, flate.BestSpeed)
    			if err != nil {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Jan 28 04:20:09 GMT 2025
    - 14.4K bytes
    - Click Count (0)
  2. src/archive/tar/writer_test.go

    		}
    	})
    
    	t.Run("NegativeSize", func(t *testing.T) {
    		tw := NewWriter(new(bytes.Buffer))
    		hdr := &Header{Name: "small.txt", Size: -1}
    		if err := tw.WriteHeader(hdr); err == nil {
    			t.Fatalf("WriteHeader() = nil, want non-nil error")
    		}
    	})
    
    	t.Run("BeforeHeader", func(t *testing.T) {
    		tw := NewWriter(new(bytes.Buffer))
    		if _, err := tw.Write([]byte("Kilts")); err != ErrWriteTooLong {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Dec 15 16:34:13 GMT 2025
    - 40.2K bytes
    - Click Count (0)
  3. src/archive/zip/zip_test.go

    	"strings"
    	"testing"
    	"time"
    )
    
    func TestOver65kFiles(t *testing.T) {
    	if testing.Short() && testenv.Builder() == "" {
    		t.Skip("skipping in short mode")
    	}
    	buf := new(strings.Builder)
    	w := NewWriter(buf)
    	const nFiles = (1 << 16) + 42
    	for i := 0; i < nFiles; i++ {
    		_, err := w.CreateHeader(&FileHeader{
    			Name:   fmt.Sprintf("%d.dat", i),
    			Method: Store, // Deflate is too slow when it is compiled with -race flag
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu May 23 01:00:11 GMT 2024
    - 19.6K bytes
    - Click Count (0)
  4. src/archive/zip/reader_test.go

    //		if err := os.WriteFile("/tmp/biggest.zip", biggestZip, 0666); err != nil {
    //			log.Fatal(err)
    //		}
    //	}
    //
    //	func makeZip(name string, r io.Reader) []byte {
    //		var buf bytes.Buffer
    //		w := zip.NewWriter(&buf)
    //		wf, err := w.Create(name)
    //		if err != nil {
    //			log.Fatal(err)
    //		}
    //		if _, err = io.Copy(wf, r); err != nil {
    //			log.Fatal(err)
    //		}
    //		if err := w.Close(); err != nil {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Jan 15 18:35:56 GMT 2026
    - 57.9K bytes
    - Click Count (0)
  5. cmd/metacache-stream.go

    	if blockSize < 8<<10 {
    		blockSize = 128 << 10
    	}
    	w := metacacheWriter{
    		mw:        nil,
    		blockSize: blockSize,
    	}
    	w.creator = func() error {
    		s2w := s2.NewWriter(out, s2.WriterBlockSize(blockSize), s2.WriterConcurrency(2))
    		w.mw = msgp.NewWriter(s2w)
    		w.creator = nil
    		if err := w.mw.WriteByte(metacacheStreamVersion); err != nil {
    			return err
    		}
    
    		w.closer = func() (err error) {
    			defer func() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 07 15:37:12 GMT 2025
    - 19.5K bytes
    - Click Count (0)
  6. 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
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Jan 28 04:20:09 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  7. src/archive/tar/reader_test.go

    func TestInsecurePaths(t *testing.T) {
    	t.Setenv("GODEBUG", "tarinsecurepath=0")
    	for _, path := range []string{
    		"../foo",
    		"/foo",
    		"a/b/../../../c",
    	} {
    		var buf bytes.Buffer
    		tw := NewWriter(&buf)
    		tw.WriteHeader(&Header{
    			Name: path,
    		})
    		const securePath = "secure"
    		tw.WriteHeader(&Header{
    			Name: securePath,
    		})
    		tw.Close()
    
    		tr := NewReader(&buf)
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Dec 30 15:28:53 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  8. cmd/object-api-utils_test.go

    				if index.TotalUncompressed != int64(len(tt.data)) {
    					t.Errorf("Expected size %d, got %d", len(tt.data), index.TotalUncompressed)
    				}
    			}
    			var stdBuf bytes.Buffer
    			w := s2.NewWriter(&stdBuf)
    			_, err = io.CopyBuffer(w, bytes.NewReader(tt.data), buf)
    			if err != nil {
    				t.Fatal(err)
    			}
    			err = w.Close()
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			var (
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 24.1K bytes
    - Click Count (0)
  9. cmd/data-usage-cache_gen_test.go

    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func BenchmarkEncodeallTierStats(b *testing.B) {
    	v := allTierStats{}
    	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 BenchmarkDecodeallTierStats(b *testing.B) {
    	v := allTierStats{}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19K bytes
    - Click Count (0)
  10. cmd/batch-replicate_gen_test.go

    	}
    }
    
    func BenchmarkEncodeBatchJobReplicateCredentials(b *testing.B) {
    	v := BatchJobReplicateCredentials{}
    	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 BenchmarkDecodeBatchJobReplicateCredentials(b *testing.B) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.2K bytes
    - Click Count (0)
Back to Top