mirrors2/orca
1
0
Fork 0
mirror of https://github.com/zhengkai/orca.git synced 2026-02-04 17:02:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

tidy

Browse Source
This commit is contained in:
Zheng Kai
2023-06-28 16:28:16 +08:00
parent 770510ccdc
commit e76c3dc03c
2 changed files with 3 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
server/src/core/fetch.go
View File

@@ -46,6 +46,7 @@ func (pr *row) fetchRemote() (ab []byte, err error) {
pr.httpCode = rsp.StatusCode pr.httpCode = rsp.StatusCode
err = fmt.Errorf(`status code fail: %d`, rsp.StatusCode) err = fmt.Errorf(`status code fail: %d`, rsp.StatusCode)
b.WriteString(err.Error()) b.WriteString(err.Error())
b.WriteString("\n\n")
} }
b.WriteString("rsp header:\n\n") b.WriteString("rsp header:\n\n")

17
server/src/core/row.go
View File

@@ -6,7 +6,6 @@ import (
"net/http" "net/http"
"project/pb" "project/pb"
"project/util" "project/util"
"project/zj"
"sync" "sync"
"time" "time"
) )
@@ -37,26 +36,14 @@ func (pr *row) run() {
pr.startLog() pr.startLog()
if pr.req.Method != http.MethodGet {
// pr.mux.Unlock()
// return
}
pr.rsp, pr.err = pr.fetchRemote() pr.rsp, pr.err = pr.fetchRemote()
pr.done = true pr.done = true
pr.mux.Unlock() pr.mux.Unlock()
if pr.err != nil {
zj.W(pr.err)
}
// go pr.metrics()
go writeFailLog(pr.hash, pr.log.Bytes())
if pr.err == nil { if pr.err == nil {
// pr.failLog.Reset()
// go writeFailLog(pr.hash, pr.log.Bytes())
pr.saveFile() pr.saveFile()
} else {
go writeFailLog(pr.hash, pr.log.Bytes())
} }
pr.suicide() pr.suicide()
} }