diff --git a/core/adapter.go b/core/adapter.go index 853a86a..8bb55b9 100644 --- a/core/adapter.go +++ b/core/adapter.go @@ -340,11 +340,11 @@ func (f *Factory) Push(msg map[string]string) map[string]string { func (f *Factory) SetReplyHandler(function func(map[string]interface{}) string) { f.reply = func(m map[string]interface{}) string { - if f.uuid != "" { - mutex := GetMutex(f.uuid) - mutex.Lock() - defer mutex.Unlock() - } + // if f.uuid != "" { + // mutex := GetMutex(f.uuid) + // mutex.Lock() + // defer mutex.Unlock() + // } defer func() { err := recover() if err != nil { @@ -357,11 +357,11 @@ func (f *Factory) SetReplyHandler(function func(map[string]interface{}) string) func (f *Factory) SetActionHandler(function func(map[string]interface{}) string) { f.action = func(m map[string]interface{}) string { - if f.uuid != "" { - mutex := GetMutex(f.uuid) - mutex.Lock() - defer mutex.Unlock() - } + // if f.uuid != "" { + // mutex := GetMutex(f.uuid) + // mutex.Lock() + // defer mutex.Unlock() + // } defer func() { err := recover() if err != nil { diff --git a/core/grpc_plugins.go b/core/grpc_plugins.go index 220304f..6909806 100644 --- a/core/grpc_plugins.go +++ b/core/grpc_plugins.go @@ -31,7 +31,7 @@ func initNodePlugins() { root := strings.ReplaceAll(utils.ExecPath+"/plugins", "\\", "/") plugins := []string{root} os.Mkdir(root, 0755) - fmt.Println("root", root) + // fmt.Println("root", root) files, _ := ioutil.ReadDir(root) for _, file := range files { diff --git a/core/plugin_core.go b/core/plugin_core.go index 99b0c64..6a5a240 100644 --- a/core/plugin_core.go +++ b/core/plugin_core.go @@ -179,7 +179,7 @@ func initPlugins() { } } return &storage.Final{ - Error: errors.New("非法操作!"), + Error: errors.New("安装失败!!!"), } }