Method initCompression

transport/sendobj.go:86–100

(extra *Extra)

}

func (s *Stream) initCompression(extra *Extra) {
	s.lz4s.s = s
	s.lz4s.blockMaxSize = int(extra.Config.Transport.LZ4BlockMaxSize)
	s.lz4s.frameChecksum = extra.Config.Transport.LZ4FrameChecksum
	mem := extra.MMSA
	if mem == nil {
		mem = memsys.PageMM()
	}
	if s.lz4s.blockMaxSize >= memsys.MaxPageSlabSize {
		s.lz4s.sgl = mem.NewSGL(memsys.MaxPageSlabSize, memsys.MaxPageSlabSize)
	} else {
		s.lz4s.sgl = mem.NewSGL(cos.KiB*64, cos.KiB*64)
	}
	s.lid = fmt.Sprintf("%s[%d[%s]]", s.trname, s.sessID, cos.B2S(int64(s.lz4s.blockMaxSize), 0))
}

func (s *Stream) compressed() bool { return s.lz4s.s == s }
func (s *Stream) usePDU() bool     { return s.pdu != nil }