Function processReadFileParallel

processor/workers.go:647–820

For files under a certain size its faster to just read them into memory in one chunk and then process them which this method does NB there is little point in multi-processing at this level, it would be better done on the input channel if required

(filename string, content *[]byte)

// NB there is little point in multi-processing at this level, it would be
// better done on the input channel if required
func processReadFileParallel(filename string, content *[]byte) (Result, error) {
	startTime := makeTimestampNano()

	var wg sync.WaitGroup
	result := Result{}

	if hasHash(HashNames.MD4) {
		wg.Add(1)
		go func() {
			startTime = makeTimestampNano()
			d := md4.New()
			d.Write(*content)
			result.MD4 = hex.EncodeToString(d.Sum(nil))

			if Trace {
				printTrace(fmt.Sprintf("nanoseconds processing md4: %s: %d", filename, makeTimestampNano()-startTime))
			}
			wg.Done()
		}()
	}

	if hasHash(HashNames.MD5) {
		wg.Add(1)
		go func() {
			startTime = makeTimestampNano()
			d := md5.New()
			d.Write(*content)
			result.MD5 = hex.EncodeToString(d.Sum(nil))

			if Trace {
				printTrace(fmt.Sprintf("nanoseconds processing md5: %s: %d", filename, makeTimestampNano()-startTime))
			}
			wg.Done()
		}()
	}

	if hasHash(HashNames.SHA1) {
		wg.Add(1)
		go func() {
			startTime = makeTimestampNano()
			d := sha1.New()
			d.Write(*content)
			result.SHA1 = hex.EncodeToString(d.Sum(nil))

			if Trace {
				printTrace(fmt.Sprintf("nanoseconds processing sha1: %s: %d", filename, makeTimestampNano()-startTime))
			}
			wg.Done()
		}()
	}

	if hasHash(HashNames.SHA256) {
		wg.Add(1)
		go func() {
			startTime = makeTimestampNano()
			d := sha256.New()
			d.Write(*content)
			result.SHA256 = hex.EncodeToString(d.Sum(nil))