cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

harmonytask review comments

Browse Source
This commit is contained in:
Andrew Jackson (Ajax) 2023-08-21 11:26:26 -05:00
parent d732a7b747
commit 2912cf6f9c
4 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
itests/harmonytask_test.go
View File

@ -10,12 +10,13 @@ import (
"testing" "testing"
"time" "time"
"github.com/stretchr/testify/require"
"github.com/filecoin-project/lotus/itests/kit" "github.com/filecoin-project/lotus/itests/kit"
"github.com/filecoin-project/lotus/lib/harmony/harmonydb" "github.com/filecoin-project/lotus/lib/harmony/harmonydb"
"github.com/filecoin-project/lotus/lib/harmony/harmonytask" "github.com/filecoin-project/lotus/lib/harmony/harmonytask"
"github.com/filecoin-project/lotus/lib/harmony/resources" "github.com/filecoin-project/lotus/lib/harmony/resources"
"github.com/filecoin-project/lotus/node/impl" "github.com/filecoin-project/lotus/node/impl"
"github.com/stretchr/testify/require"
) )
type task1 struct { type task1 struct {

3
lib/harmony/harmonytask/harmonytask.go
View File

@ -9,9 +9,10 @@ import (
"sync/atomic" "sync/atomic"
"time" "time"
"github.com/gorilla/mux"
"github.com/filecoin-project/lotus/lib/harmony/harmonydb" "github.com/filecoin-project/lotus/lib/harmony/harmonydb"
"github.com/filecoin-project/lotus/lib/harmony/resources" "github.com/filecoin-project/lotus/lib/harmony/resources"
"github.com/gorilla/mux"
) )
// Consts (except for unit test) // Consts (except for unit test)

3
lib/harmony/harmonytask/taskTypeHandler.go
View File

@ -9,8 +9,9 @@ import (
"sync/atomic" "sync/atomic"
"time" "time"
"github.com/filecoin-project/lotus/lib/harmony/harmonydb"
logging "github.com/ipfs/go-log/v2" logging "github.com/ipfs/go-log/v2"
"github.com/filecoin-project/lotus/lib/harmony/harmonydb"
) )
var log = logging.Logger("harmonytask") var log = logging.Logger("harmonytask")

6
lib/harmony/resources/resources.go
View File

@ -12,12 +12,14 @@ import (
"time" "time"
cl "github.com/Nv7-Github/go-cl" cl "github.com/Nv7-Github/go-cl"
ffi "github.com/filecoin-project/filecoin-ffi"
"github.com/filecoin-project/lotus/lib/harmony/harmonydb"
logging "github.com/ipfs/go-log/v2" logging "github.com/ipfs/go-log/v2"
"github.com/pbnjay/memory" "github.com/pbnjay/memory"
"github.com/samber/lo" "github.com/samber/lo"
"golang.org/x/sys/unix" "golang.org/x/sys/unix"
ffi "github.com/filecoin-project/filecoin-ffi"
"github.com/filecoin-project/lotus/lib/harmony/harmonydb"
) )
var LOOKS_DEAD_TIMEOUT = 10 * time.Minute // Time w/o minute heartbeats var LOOKS_DEAD_TIMEOUT = 10 * time.Minute // Time w/o minute heartbeats