Method DropSourceIP

internal/firewalls/firewall_firewalld.go:168–200

(ip string, timeoutSeconds int, async bool)

}

func (this *Firewalld) DropSourceIP(ip string, timeoutSeconds int, async bool) error {
	if !this.isReady {
		return nil
	}

	// 避免短时间内重复添加
	if async && this.checkLatestIP(ip) {
		return nil
	}

	var family = "ipv4"
	if strings.Contains(ip, ":") {
		family = "ipv6"
	}
	var args = []string{"--add-rich-rule=rule family='" + family + "' source address='" + ip + "' drop"}
	if timeoutSeconds > 0 {
		args = append(args, "--timeout="+types.String(timeoutSeconds)+"s")
	}
	var cmd = executils.NewTimeoutCmd(10*time.Second, this.exe, args...)
	if async {
		this.pushCmd(cmd, ip)
		return nil
	}

	// 关闭连接
	defer conns.SharedMap.CloseIPConns(ip)

	err := cmd.Run()
	if err != nil {
		return fmt.Errorf("run command failed '%s': %w", cmd.String(), err)
	}
	return nil
}

func (this *Firewalld) RemoveSourceIP(ip string) error {
	if !this.isReady {