hpz937/zurg
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Disable pprof

Browse Source
This commit is contained in:
Ben Sarmiento
2023-12-03 12:56:12 +01:00
parent 2a4276aa3e
commit e6ec369767
2 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
internal/app.go
View File

@@ -5,7 +5,7 @@ import (
netHttp "net/http" netHttp "net/http"
"os" "os"
_ "net/http/pprof" // Register pprof // _ "net/http/pprof" // Register pprof
"github.com/debridmediamanager/zurg/internal/config" "github.com/debridmediamanager/zurg/internal/config"
"github.com/debridmediamanager/zurg/internal/router" "github.com/debridmediamanager/zurg/internal/router"
@@ -65,12 +65,12 @@ func MainApp(configPath string) {
handler.RedirectFixedPath = true handler.RedirectFixedPath = true
router.ApplyRouteTable(handler, getfile, torrentMgr, config, rd, log.Named("router")) router.ApplyRouteTable(handler, getfile, torrentMgr, config, rd, log.Named("router"))
go func() { // go func() {
if err := netHttp.ListenAndServe(":6060", nil); err != nil && err != netHttp.ErrServerClosed { // if err := netHttp.ListenAndServe(":6060", nil); err != nil && err != netHttp.ErrServerClosed {
zurglog.Errorf("Failed to start pprof: %v", err) // zurglog.Errorf("Failed to start pprof: %v", err)
os.Exit(1) // os.Exit(1)
} // }
}() // }()
addr := fmt.Sprintf("%s:%s", config.GetHost(), config.GetPort()) addr := fmt.Sprintf("%s:%s", config.GetHost(), config.GetPort())
zurglog.Infof("Starting server on %s", addr) zurglog.Infof("Starting server on %s", addr)

4
internal/torrent/manager.go
View File

@@ -571,7 +571,7 @@ func (t *TorrentManager) Delete(accessKey string, deleteInRD bool, updateDirecto
func (t *TorrentManager) repair(torrent *Torrent) { func (t *TorrentManager) repair(torrent *Torrent) {
if torrent.AllInProgress() { if torrent.AllInProgress() {
t.log.Infof("Torrent %s is in progress, cannot repair", torrent.AccessKey) t.log.Infof("Torrent %s is in progress, skipping repair until download is done", torrent.AccessKey)
return return
} }
@@ -743,7 +743,7 @@ func (t *TorrentManager) RepairAll() {
func (t *TorrentManager) Repair(torrent *Torrent) { func (t *TorrentManager) Repair(torrent *Torrent) {
_ = t.repairWorker.Submit(func() { _ = t.repairWorker.Submit(func() {
t.log.Info("repairing torrent %s", torrent.AccessKey) t.log.Info("Repairing torrent %s", torrent.AccessKey)
t.repair(torrent) t.repair(torrent)
t.log.Info("Finished repairing torrent %s", torrent.AccessKey) t.log.Info("Finished repairing torrent %s", torrent.AccessKey)
}) })