nxshock/gron
1
0
Fork 0
mirror of https://github.com/nxshock/gron.git synced 2024-11-27 03:41:00 +05:00
Code Issues Projects Releases Wiki Activity

Log host which sends job requests

Browse Source
This commit is contained in:
nxshock 2022-03-27 13:12:36 +05:00
parent dac381b93a
commit 6708aeb531
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
httpserver.go
View File

@ -3,6 +3,7 @@ package main
import ( import (
"bytes" "bytes"
"fmt" "fmt"
"net"
"net/http" "net/http"
"os" "os"
"time" "time"
@ -53,7 +54,11 @@ func handleForceStart(w http.ResponseWriter, r *http.Request) {
for _, jobEntry := range jobEntries { for _, jobEntry := range jobEntries {
job := jobEntry.Job.(*Job) job := jobEntry.Job.(*Job)
if job.FileName == jobName { if job.FileName == jobName {
log.WithField("job", "http_server").Printf("forced start %s", job.FileName) host, _, err := net.SplitHostPort(r.RemoteAddr)
if err != nil {
host = r.RemoteAddr
}
log.WithField("job", "http_server").Printf("forced start %s from %s", job.FileName, host)
go job.Run() go job.Run()
time.Sleep(time.Second / 4) // wait some time for job start time.Sleep(time.Second / 4) // wait some time for job start
http.Redirect(w, r, "/", http.StatusTemporaryRedirect) http.Redirect(w, r, "/", http.StatusTemporaryRedirect)