Method init

internal/firewalls/firewall_firewalld.go:51–69

()

}

func (this *Firewalld) init() {
	goman.New(func() {
		for c := range this.cmdQueue {
			var cmd = c.cmd
			err := cmd.Run()
			if err != nil {
				if strings.HasPrefix(err.Error(), "Warning:") {
					continue
				}
				remotelogs.Warn("FIREWALL", "run command failed '"+cmd.String()+"': "+err.Error())
			} else {
				// 关闭连接
				if len(c.denyIP) > 0 {
					conns.SharedMap.CloseIPConns(c.denyIP)
				}
			}
		}
	})
}

// Name 名称
func (this *Firewalld) Name() string {