Function DumpEntriesWithTimeDiff

pkg/maps/nat/nat.go:179–214

DumpEntriesWithTimeDiff iterates through Map m and writes the values of the nat entries in m to a string. If clockSource is not nil, it uses it to compute the time difference of each entry from now and prints that too.

(m NatMap, clockSource *models.ClockSource)

// nat entries in m to a string. If clockSource is not nil, it uses it to
// compute the time difference of each entry from now and prints that too.
func DumpEntriesWithTimeDiff(m NatMap, clockSource *models.ClockSource) (string, error) {
	var toDeltaSecs func(uint64) string
	var sb strings.Builder

	if clockSource == nil {
		toDeltaSecs = func(t uint64) string {
			return fmt.Sprintf("? (raw %d)", t)
		}
	} else {
		now, err := timestamp.GetCTCurTime(clockSource)
		if err != nil {
			return "", err
		}
		tsConverter, err := timestamp.NewCTTimeToSecConverter(clockSource)
		if err != nil {
			return "", err
		}
		tsecNow := tsConverter(now)
		toDeltaSecs = func(t uint64) string {
			tsec := tsConverter(uint64(t))
			diff := int64(tsecNow) - int64(tsec)
			return fmt.Sprintf("%dsec ago", diff)
		}
	}

	cb := func(k bpf.MapKey, v bpf.MapValue) {
		key := k.(NatKey)
		if !key.ToHost().Dump(&sb, false) {
			return
		}
		val := v.(NatEntry)
		sb.WriteString(val.ToHost().Dump(key, toDeltaSecs))
	}
	err := m.DumpWithCallback(cb)
	return sb.String(), err
}

// DoDumpEntries iterates through Map m and writes the values of the
// nat entries in m to a string.