faas-rs/faas
1
0
Fork 0
mirror of https://github.com/openfaas/faas.git synced 2025-06-15 19:56:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

Log fork/duration

Browse Source 
Signed-off-by: Alex Ellis <alexellis2@gmail.com>
This commit is contained in:
Alex Ellis 2017-10-31 11:20:22 +00:00
parent 38a3843d62
commit 8314b3c0b5
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
watchdog/main.go
View File

@ -60,6 +60,8 @@ func pipeRequest(config *WatchdogConfig, w http.ResponseWriter, r *http.Request,
debugHeaders(&r.Header, "in") debugHeaders(&r.Header, "in")
} }
log.Println("Forking fprocess.")
targetCmd := exec.Command(parts[0], parts[1:]...) targetCmd := exec.Command(parts[0], parts[1:]...)
envs := getAdditionalEnvs(config, r, method) envs := getAdditionalEnvs(config, r, method)
@ -160,10 +162,11 @@ func pipeRequest(config *WatchdogConfig, w http.ResponseWriter, r *http.Request,
return return
} }
var bytesWritten string
if config.writeDebug == true { if config.writeDebug == true {
os.Stdout.Write(out) os.Stdout.Write(out)
} else { } else {
log.Printf("Wrote %d Bytes\n", len(out)) bytesWritten = fmt.Sprintf("Wrote %d Bytes", len(out))
} }
if len(config.contentType) > 0 { if len(config.contentType) > 0 {
@ -177,8 +180,8 @@ func pipeRequest(config *WatchdogConfig, w http.ResponseWriter, r *http.Request,
} }
} }
execTime := time.Since(startTime).Seconds()
if ri.headerWritten == false { if ri.headerWritten == false {
execTime := time.Since(startTime).Seconds()
w.Header().Set("X-Duration-Seconds", fmt.Sprintf("%f", execTime)) w.Header().Set("X-Duration-Seconds", fmt.Sprintf("%f", execTime))
ri.headerWritten = true ri.headerWritten = true
w.WriteHeader(200) w.WriteHeader(200)
@ -189,6 +192,11 @@ func pipeRequest(config *WatchdogConfig, w http.ResponseWriter, r *http.Request,
header := w.Header() header := w.Header()
debugHeaders(&header, "out") debugHeaders(&header, "out")
} }
if len(bytesWritten) > 0 {
log.Printf("%s - Duration: %f seconds", bytesWritten, execTime)
} else {
log.Printf("Duration: %f seconds", execTime)
}
} }
func getAdditionalEnvs(config *WatchdogConfig, r *http.Request, method string) []string { func getAdditionalEnvs(config *WatchdogConfig, r *http.Request, method string) []string {