Skip to content

Commit

Permalink
tidy
Browse files Browse the repository at this point in the history
Signed-off-by: Robert Smith <robertdavidsmith@yahoo.com>
  • Loading branch information
robertdavidsmith committed Sep 26, 2024
1 parent 163527b commit a6b70cb
Showing 1 changed file with 0 additions and 18 deletions.
18 changes: 0 additions & 18 deletions internal/scheduler/nodedb/nodedb.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,23 +28,6 @@ import (

var empty struct{}

func (nodeDb *NodeDb) create(node *schedulerobjects.Node) (*internaltypes.Node, error) {
index := atomic.AddUint64(&nodeDb.numNodes, 1)

dbNode, err := internaltypes.FromSchedulerObjectsNode(node,
index,
nodeDb.indexedTaints,
nodeDb.indexedNodeLabels,
nodeDb.resourceListFactory)
if err != nil {
return nil, err
}

nodeDb.AddNodeToDb(dbNode)

return dbNode, nil
}

func (nodeDb *NodeDb) AddNodeToDb(node *internaltypes.Node) {
nodeDb.mu.Lock()
defer nodeDb.mu.Unlock()
Expand All @@ -60,7 +43,6 @@ func (nodeDb *NodeDb) AddNodeToDb(node *internaltypes.Node) {
}

func (nodeDb *NodeDb) CreateAndInsertWithJobDbJobsWithTxn(txn *memdb.Txn, jobs []*jobdb.Job, node *schedulerobjects.Node) error {

index := atomic.AddUint64(&nodeDb.numNodes, 1)

entry, err := internaltypes.FromSchedulerObjectsNode(node,
Expand Down

0 comments on commit a6b70cb

Please sign in to comment.