(localPort string, reusedPort string)
| 237 | } |
| 238 | |
| 239 | func DeletePortReuseRules(localPort string, reusedPort string) error { |
| 240 | var cmds []string |
| 241 | |
| 242 | cmds = append(cmds, fmt.Sprintf("iptables -t nat -D PREROUTING -p tcp --dport %s --syn -m recent --rcheck --seconds 3600 --name %s --rsource -j %s", reusedPort, strings.ToLower(CHAIN_NAME), CHAIN_NAME)) |
| 243 | cmds = append(cmds, fmt.Sprintf("iptables -D INPUT -p tcp -m string --string %s --algo bm -m recent --name %s --remove -j ACCEPT", STOP_FORWARDING, strings.ToLower(CHAIN_NAME))) |
| 244 | cmds = append(cmds, fmt.Sprintf("iptables -D INPUT -p tcp -m string --string %s --algo bm -m recent --set --name %s --rsource -j ACCEPT", START_FORWARDING, strings.ToLower(CHAIN_NAME))) |
| 245 | cmds = append(cmds, fmt.Sprintf("iptables -t nat -F %s", CHAIN_NAME)) |
| 246 | cmds = append(cmds, fmt.Sprintf("iptables -t nat -X %s", CHAIN_NAME)) |
| 247 | |
| 248 | for _, each := range cmds { |
| 249 | cmd := strings.Split(each, " ") |
| 250 | exec.Command(cmd[0], cmd[1:]...).Run() |
| 251 | } |
| 252 | |
| 253 | return nil |
| 254 | } |
| 255 | |
| 256 | func SetPortReuseRules(localPort string, reusedPort string) error { |
| 257 | var cmds []string |
no test coverage detected