hostagent: fix logging QEMU

AkihiroSuda · AkihiroSuda · commit cb03fda332af · 2021-06-25T19:47:06.000+09:00
Signed-off-by: Akihiro Suda &lt;akihiro.suda.cz@hco.ntt.co.jp&gt;
diff --git a/pkg/hostagent/hostagent.go b/pkg/hostagent/hostagent.go
@@ -133,12 +133,12 @@ func (a *HostAgent) Run(ctx context.Context) error {
 	if err != nil {
 		return err
 	}
-	defer logPipeRoutine(a.l, qStdout, "qemu[stdout]")
+	go logPipeRoutine(a.l, qStdout, "qemu[stdout]")
 	qStderr, err := qCmd.StderrPipe()
 	if err != nil {
 		return err
 	}
-	defer logPipeRoutine(a.l, qStderr, "qemu[stderr]")
+	go logPipeRoutine(a.l, qStderr, "qemu[stderr]")
 
 	a.l.Infof("Starting QEMU (hint: to watch the boot progress, see %q)", filepath.Join(a.instDir, filenames.SerialLog))
 	a.l.Debugf("qCmd.Args: %v", qCmd.Args)

Original file line number	Diff line number	Diff line change
`@@ -133,12 +133,12 @@ func (a *HostAgent) Run(ctx context.Context) error {`
`133`	`133`	`if err != nil {`
`134`	`134`	`return err`
`135`	`135`	`}`
`136`		`- defer logPipeRoutine(a.l, qStdout, "qemu[stdout]")`
	`136`	`+ go logPipeRoutine(a.l, qStdout, "qemu[stdout]")`
`137`	`137`	`qStderr, err := qCmd.StderrPipe()`
`138`	`138`	`if err != nil {`
`139`	`139`	`return err`
`140`	`140`	`}`
`141`		`- defer logPipeRoutine(a.l, qStderr, "qemu[stderr]")`
	`141`	`+ go logPipeRoutine(a.l, qStderr, "qemu[stderr]")`
`142`	`142`
`143`	`143`	`a.l.Infof("Starting QEMU (hint: to watch the boot progress, see %q)", filepath.Join(a.instDir, filenames.SerialLog))`
`144`	`144`	`a.l.Debugf("qCmd.Args: %v", qCmd.Args)`