diff options
Diffstat (limited to 'http_server.go')
| -rw-r--r-- | http_server.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/http_server.go b/http_server.go index 2a7f534..f2a35b4 100644 --- a/http_server.go +++ b/http_server.go @@ -853,11 +853,14 @@ func (httpd *httpServer) ExecuteTail(sseconn *libhttp.SSEConn) { evid int64 ) + execRes.mtxOutput.Lock() if len(execRes.EndAt) != 0 { // The execution has been completed. _ = sseconn.WriteEvent(`end`, execRes.EndAt, nil) + execRes.mtxOutput.Unlock() goto out } + execRes.mtxOutput.Unlock() // And wait for the rest... |