Method execTask

internal/nodes/node_tasks.go:68–117

执行任务

(rpcClient *rpc.RPCClient, task *pb.NodeTask)

// 执行任务
func (this *Node) execTask(rpcClient *rpc.RPCClient, task *pb.NodeTask) error {
	var err error
	switch task.Type {
	case "ipItemChanged":
		err = this.execIPItemChangedTask()
	case "configChanged":
		err = this.execConfigChangedTask(task)
	case "nodeVersionChanged":
		err = this.execNodeVersionChangedTask()
	case "scriptsChanged":
		err = this.execScriptsChangedTask()
	case "nodeLevelChanged":
		err = this.execNodeLevelChangedTask(rpcClient)
	case "ddosProtectionChanged":
		err = this.execDDoSProtectionChangedTask(rpcClient)
	case "globalServerConfigChanged":
		err = this.execGlobalServerConfigChangedTask(rpcClient)
	case "userServersStateChanged":
		err = this.execUserServersStateChangedTask(rpcClient, task)
	case "uamPolicyChanged":
		err = this.execUAMPolicyChangedTask(rpcClient)
	case "httpCCPolicyChanged":
		err = this.execHTTPCCPolicyChangedTask(rpcClient)
	case "http3PolicyChanged":
		err = this.execHTTP3PolicyChangedTask(rpcClient)
	case "httpPagesPolicyChanged":
		err = this.execHTTPPagesPolicyChangedTask(rpcClient)
	case "updatingServers":
		err = this.execUpdatingServersTask(rpcClient)
	case "plusChanged":
		err = this.notifyPlusChange()
	case "toaChanged":
		err = this.execTOAChangedTask()
	case "networkSecurityPolicyChanged":
		err = this.execNetworkSecurityPolicyChangedTask(rpcClient)
	case "webPPolicyChanged":
		err = this.execWebPPolicyChangedTask(rpcClient)
	case "planChanged":
		err = this.execPlanChangedTask(rpcClient)
	default:
		// 特殊任务
		if strings.HasPrefix(task.Type, "ipListDeleted") { // 删除IP名单
			err = this.execDeleteIPList(task.Type)
		} else { // 未处理的任务
			remotelogs.Error("NODE", "task '"+types.String(task.Id)+"', type '"+task.Type+"' has not been handled")
		}
	}

	return err
}

// 更新IP条目变更
func (this *Node) execIPItemChangedTask() error {