opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-09-24 16:03:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: lbagent service code typo 20260604 (#24977)

Browse Source 
Co-authored-by: Qiu Jian <qiujian@yunionyun.com>
This commit is contained in:
Jian Qiu
2026-06-05 01:13:15 +08:00
committed by GitHub
co-authored by Qiu Jian
parent adbefb74bf
commit 354408b656
1 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/lbagent/haproxy.go
+11 -11
View File
@@ -666,21 +666,11 @@ func (h *HaproxyHelper) runServiceOnce(args []string) error {
args = args[1:]
cmd := exec.Command(name, args...)
stdout, err := cmd.StdoutPipe()
if err != nil {
log.Errorf("service %s stdout pipe error: %s", cmd.String(), err)
return errors.Wrapf(err, "service %s stdout pipe error", cmd.String())
}
stderr, err := cmd.StderrPipe()
if err != nil {
log.Errorf("service %s stderr pipe error: %s", cmd.String(), err)
return errors.Wrapf(err, "service %s stderr pipe error", cmd.String())
}
drain := func(out io.ReadCloser, isErr bool) {
defer out.Close()
buf := make([]byte, 1024)
for {
n, err := stdout.Read(buf)
n, err := out.Read(buf)
if err != nil {
log.Errorf("read pipe error: %s", err)
return
@@ -692,6 +682,16 @@ func (h *HaproxyHelper) runServiceOnce(args []string) error {
}
}
}
stdout, err := cmd.StdoutPipe()
if err != nil {
log.Errorf("service %s stdout pipe error: %s", cmd.String(), err)
return errors.Wrapf(err, "service %s stdout pipe error", cmd.String())
}
stderr, err := cmd.StderrPipe()
if err != nil {
log.Errorf("service %s stderr pipe error: %s", cmd.String(), err)
return errors.Wrapf(err, "service %s stderr pipe error", cmd.String())
}
err = cmd.Start()
if err != nil {
return errors.Wrapf(err, "start service %s", cmd.String())