Package edu.duke.cs.osprey.coffee

Class NodeProcessor

java.lang.Object

edu.duke.cs.osprey.coffee.NodeProcessor

All Implemented Interfaces:

AutoCloseable

public class NodeProcessor
extends Object
implements AutoCloseable

Field Summary

Fields

Modifier and Type	Field	Description
final ConfEnergyCalculator[]	cpuEcalcs
final TaskExecutor	cpuTasks
final CudaConfEnergyCalculator[]	gpuEcalcs
final boolean	includeStaticStatic
final NodeDB	nodedb
final NodeStats	nodeStats
final Parallelism	parallelism
final SeqDB	seqdb
final StateInfo[]	stateInfos
final Duration	statsReporterInterval

Constructor Summary

Constructors

Constructor	Description
NodeProcessor(TaskExecutor cpuTasks, SeqDB seqdb, NodeDB nodedb, StateInfo[] stateInfos, boolean includeStaticStatic, Parallelism parallelism, Structs.Precision precision, Duration statsReporterInterval)

Method Summary

Modifier and Type	Method	Description
void	close()
void	expand(NodeIndex.Node node, NodeTree tree, List<NodeIndex.Node> nodeBatch)
void	handleDrops(Stream<NodeIndex.Node> nodes)
void	initRootNode(int statei, NodeTree tree)
List<ConfEnergyCalculator.EnergiedCoords>	minimizeCoords(int statei, List<int[]> confs)
void	start(int numThreads, Directions directions)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

cpuTasks

public final TaskExecutor cpuTasks

seqdb

public final SeqDB seqdb

nodedb

public final NodeDB nodedb

stateInfos

public final StateInfo[] stateInfos

includeStaticStatic

public final boolean includeStaticStatic

parallelism

public final Parallelism parallelism

statsReporterInterval

public final Duration statsReporterInterval

cpuEcalcs

public final ConfEnergyCalculator[] cpuEcalcs

gpuEcalcs

public final CudaConfEnergyCalculator[] gpuEcalcs

nodeStats

public final NodeStats nodeStats

Constructor Details

NodeProcessor

public NodeProcessor(TaskExecutor cpuTasks,
 SeqDB seqdb,
 NodeDB nodedb,
 StateInfo[] stateInfos,
 boolean includeStaticStatic,
 Parallelism parallelism,
 Structs.Precision precision,
 Duration statsReporterInterval)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

start

public void start(int numThreads,
 Directions directions)

initRootNode

public void initRootNode(int statei,
 NodeTree tree)

minimizeCoords

public List<ConfEnergyCalculator.EnergiedCoords> minimizeCoords(int statei,
 List<int[]> confs)

expand

public void expand(NodeIndex.Node node,
 NodeTree tree,
 List<NodeIndex.Node> nodeBatch)

handleDrops

public void handleDrops(Stream<NodeIndex.Node> nodes)