writer.go
func (z *Writer) writeHeader() error {
	// Default to 4Mb if BlockMaxSize is not set.
	if z.Header.BlockMaxSize == 0 {
		z.Header.BlockMaxSize = bsMapID[7]
	}
	// The only option that needs to be validated.
	bSize := z.Header.BlockMaxSize
	bSizeID, ok := bsMapValue[bSize]
	if !ok {
		return fmt.Errorf("lz4: invalid block max size: %d", bSize)
	}
	// Allocate the compressed/uncompressed buffers.
	// The compressed buffer cannot exceed the uncompressed one.
	if n := 2 * bSize; cap(z.zdata) < n {
		z.zdata = make([]byte, n, n)
	}
	z.data = z.zdata[:bSize]
	z.zdata = z.zdata[:cap(z.zdata)][bSize:]
	z.idx = 0

	// Size is optional.
	buf := z.buf[:]

	// Set the fixed size data: magic number, block max size and flags.
	binary.LittleEndian.PutUint32(buf[0:], frameMagic)
	flg := byte(Version << 6)
	flg |= 1 << 5 // No block dependency.
	if z.Header.BlockChecksum {
		flg |= 1 << 4
	}
	if z.Header.Size > 0 {
		flg |= 1 << 3
	}
	if !z.Header.NoChecksum {
		flg |= 1 << 2
	}
	buf[4] = flg
	buf[5] = bSizeID << 4

	// Current buffer size: magic(4) + flags(1) + block max size (1).
	n := 6
	// Optional items.
	if z.Header.Size > 0 {
		binary.LittleEndian.PutUint64(buf[n:], z.Header.Size)
		n += 8
	}

	// The header checksum includes the flags, block max size and optional Size.
	buf[n] = byte(xxh32.ChecksumZero(buf[4:n]) >> 8 & 0xFF)
	z.checksum.Reset()

	// Header ready, write it out.
	if _, err := z.dst.Write(buf[0 : n+1]); err != nil {
		return err
	}
	z.Header.done = true
	if debugFlag {
		debug("wrote header %v", z.Header)
	}

	return nil
}
func (z *Writer) writeHeader() error {
	// Default to 4Mb if BlockMaxSize is not set.
	if z.Header.BlockMaxSize == 0 {
		z.Header.BlockMaxSize = bsMapID[7]
	}
	// The only option that needs to be validated.
	bSize := z.Header.BlockMaxSize
	bSizeID, ok := bsMapValue[bSize]
	if !ok {
		return fmt.Errorf("lz4: invalid block max size: %d", bSize)
	}
	// Allocate the compressed/uncompressed buffers.
	// The compressed buffer cannot exceed the uncompressed one.
	if n := 2 * bSize; cap(z.zdata) < n {
		z.zdata = make([]byte, n, n)
	}
	z.data = z.zdata[:bSize]
	z.zdata = z.zdata[:cap(z.zdata)][bSize:]
	z.idx = 0

	// Size is optional.
	buf := z.buf[:]

	// Set the fixed size data: magic number, block max size and flags.
	binary.LittleEndian.PutUint32(buf[0:], frameMagic)
	flg := byte(Version << 6)
	flg |= 1 << 5 // No block dependency.
	if z.Header.BlockChecksum {
		flg |= 1 << 4
	}
	if z.Header.Size > 0 {
		flg |= 1 << 3
	}
	if !z.Header.NoChecksum {
		flg |= 1 << 2
	}
	buf[4] = flg
	buf[5] = bSizeID << 4

	// Current buffer size: magic(4) + flags(1) + block max size (1).
	n := 6
	// Optional items.
	if z.Header.Size > 0 {
		binary.LittleEndian.PutUint64(buf[n:], z.Header.Size)
		n += 8
	}

	// The header checksum includes the flags, block max size and optional Size.
	buf[n] = byte(xxh32.ChecksumZero(buf[4:n]) >> 8 & 0xFF)
	z.checksum.Reset()

	// Header ready, write it out.
	if _, err := z.dst.Write(buf[0 : n+1]); err != nil {
		return err
	}
	z.Header.done = true
	if debugFlag {
		debug("wrote header %v", z.Header)
	}

	return nil
}
func ( z * Writer ) writeHeader ( ) error { // Default to 4Mb if BlockMaxSize is not set. if z . Header . BlockMaxSize == 0 { z . Header . BlockMaxSize = bsMapID [ 7 ] } // The only option that needs to be validated. bSize := z . Header . BlockMaxSize bSizeID , ok := bsMapValue [ bSize ] if ! ok { return fmt . Errorf ( " " , bSize ) } // Allocate the compressed/uncompressed buffers. // The compressed buffer cannot exceed the uncompressed one. if n := 2 * bSize ; cap ( z . zdata ) < n { z . zdata = make ( [ ] byte , n , n ) } z . data = z . zdata [ : bSize ] z . zdata = z . zdata [ : cap ( z . zdata ) ] [ bSize : ] z . idx = 0 // Size is optional. buf := z . buf [ : ] // Set the fixed size data: magic number, block max size and flags. binary . LittleEndian . PutUint32 ( buf [ 0 : ] , frameMagic ) flg := byte ( Version << 6 ) flg |= 1 << 5 // No block dependency. if z . Header . BlockChecksum { flg |= 1 << 4 } if z . Header . Size > 0 { flg |= 1 << 3 } if ! z . Header . NoChecksum { flg |= 1 << 2 } buf [ 4 ] = flg buf [ 5 ] = bSizeID << 4 // Current buffer size: magic(4) + flags(1) + block max size (1). n := 6 // Optional items. if z . Header . Size > 0 { binary . LittleEndian . PutUint64 ( buf [ n : ] , z . Header . Size ) n += 8 } // The header checksum includes the flags, block max size and optional Size. buf [ n ] = byte ( xxh32 . ChecksumZero ( buf [ 4 : n ] ) >> 8 & 0xFF ) z . checksum . Reset ( ) // Header ready, write it out. if _ , err := z . dst . Write ( buf [ 0 : n + 1 ] ) ; err != nil { return err } z . Header . done = true if debugFlag { debug ( " " , z . Header ) } return nil }
// writeHeader builds and writes the header (magic+header) to the underlying io.Writer.
writeHeader builds and writes the header ( magic + header ) to the underlying io . Writer .