kyfx
/
api-testing
mirror of https://github.com/LinuxSuRen/api-testing.git
5
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

support given http port

This commit is contained in:
rick 2025-03-14 10:04:46 +00:00
parent e3e7357d66
commit 76953f09d3
1 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
pkg/server/store_ext_manager.go
View File

@ -130,16 +130,22 @@ func (s *storeExtManager) Start(name, socket string) (err error) {
}
func (s *storeExtManager) startPlugin(socketURL, plugin, pluginName string) (err error) {
socketFile := strings.TrimPrefix(socketURL, s.socketPrefix)
_ = os.RemoveAll(socketFile) // always deleting the socket file to avoid start failing
if strings.HasPrefix(socketURL, s.socketPrefix) {
socketFile := strings.TrimPrefix(socketURL, s.socketPrefix)
_ = os.RemoveAll(socketFile) // always deleting the socket file to avoid start failing
s.lock.Lock()
s.filesNeedToBeRemoved = append(s.filesNeedToBeRemoved, socketFile)
s.extStatusMap[pluginName] = true
s.lock.Unlock()
s.lock.Lock()
s.filesNeedToBeRemoved = append(s.filesNeedToBeRemoved, socketFile)
s.extStatusMap[pluginName] = true
s.lock.Unlock()
if err = s.execer.RunCommandWithIO(plugin, "", os.Stdout, os.Stderr, s.processChan, "--socket", socketFile); err != nil {
serverLogger.Info("failed to start ext manager", "socket", socketURL, "error: ", err.Error())
if err = s.execer.RunCommandWithIO(plugin, "", os.Stdout, os.Stderr, s.processChan, "--socket", socketFile); err != nil {
serverLogger.Info("failed to start ext manager", "socket", socketURL, "error: ", err.Error())
}
} else if len(strings.Split(socketURL, ":")) == 2 {
if err = s.execer.RunCommandWithIO(plugin, "", os.Stdout, os.Stderr, s.processChan, "--port", strings.Split(socketURL, ":")[1]); err != nil {
serverLogger.Info("failed to start ext manager", "socket", socketURL, "error: ", err.Error())
}
}
return
}