Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for MultiWriter (0.06 sec)

  1. internal/ringbuffer/ring_buffer_test.go

    	var wroteBuf bytes.Buffer
    	readHash := crc32.NewIEEE()
    	wroteHash := crc32.NewIEEE()
    	read := io.Writer(readHash)
    	wrote := io.Writer(wroteHash)
    	if debug {
    		read = io.MultiWriter(read, &readBuf)
    		wrote = io.MultiWriter(wrote, &wroteBuf)
    	}
    	debugln := func(args ...any) {
    		if debug {
    			fmt.Println(args...)
    		}
    	}
    	// Inject random reader/writer sleeps.
    	const maxSleep = int(1 * time.Millisecond)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  2. cmd/bucket-handlers.go

    			buf.Reset()
    			bytebufferpool.Put(buf)
    		}()
    
    		md5w := md5.New()
    
    		// Maximum allowed fan-out object size.
    		const maxFanOutSize = 16 << 20
    
    		n, err := io.Copy(io.MultiWriter(buf, md5w), ioutil.HardLimitReader(pReader, maxFanOutSize))
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    
    		// Set the correct hex md5sum for the fan-out stream.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  3. lib/fips140/v1.0.0-c2097c7c.zip

    hmac.New(sha256.New, make([]byte, 32)) w := io.Writer(h) /* // Uncomment for debugging. // Commented (as opposed to a const bool flag) // to avoid import "os" in default builds. f, err := os.Create("fipscheck.o") if err != nil { panic(err) } w = io.MultiWriter(h, f) */ w.Write([]byte("go fips object v1\n")) var nbuf [8]byte for _, sect := range Linkinfo.Sects { n := uintptr(sect.End) - uintptr(sect.Start) byteorder.BEPutUint64(nbuf[:], uint64(n)) w.Write(nbuf[:]) w.Write(unsafe.Slice((*byte)(sect.Start),...
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Thu Sep 25 19:53:19 UTC 2025
    - 642.7K bytes
    - Viewed (0)
  4. lib/fips140/v1.1.0-rc1.zip

    hmac.New(sha256.New, make([]byte, 32)) w := io.Writer(h) /* // Uncomment for debugging. // Commented (as opposed to a const bool flag) // to avoid import "os" in default builds. f, err := os.Create("fipscheck.o") if err != nil { panic(err) } w = io.MultiWriter(h, f) */ w.Write([]byte("go fips object v1\n")) var nbuf [8]byte for _, sect := range Linkinfo.Sects { n := uintptr(sect.End) - uintptr(sect.Start) byteorder.BEPutUint64(nbuf[:], uint64(n)) w.Write(nbuf[:]) w.Write(unsafe.Slice((*byte)(sect.Start),...
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Thu Dec 11 16:27:41 UTC 2025
    - 663K bytes
    - Viewed (0)
Back to top