Method Write

nhp/log/logger.go:60–70

async writer must be initiated first, implements atomic write

(buf []byte)

// async writer
// must be initiated first, implements atomic write
func (lw *AsyncLogWriter) Write(buf []byte) (n int, err error) {
	lw.Lock()
	defer lw.Unlock()

	len := len(buf)
	msg := make([]byte, len)
	copy(msg, buf)
	lw.msg <- msg

	return len, nil
}

func (lw *AsyncLogWriter) writeRoutine() {
	defer lw.wg.Done()