X-Git-Url: https://git.giacomolli.uk/onechat/blobdiff_plain/522d7fd117285e4e4ce3ea5ec9b5a1722521b681..f5c601f1801aaa276f8c335fcb51c373edc0b50c:/build_queue.go diff --git a/build_queue.go b/build_queue.go index 7db24be..540e396 100644 --- a/build_queue.go +++ b/build_queue.go @@ -14,14 +14,6 @@ const ( buildLeafWindow = 8 ) -func newBuildQueue() *BuildQueue { - return &BuildQueue{ - queued: make(map[NodeKey]bool), - running: make(map[NodeKey]bool), - failed: make(map[NodeKey]bool), - } -} - // BuildQueue holds the nodes that wait for a model build. A leaf joins it when // its message is too long to be its own node. A merge joins it when both of its // children are built and their texts do not fit in one node. So the core never @@ -42,6 +34,17 @@ type BuildQueue struct { retry []NodeKey } +// BuildMergeHeap holds the merges that can start, by the end of their context. +type BuildMergeHeap []NodeKey + +func newBuildQueue() *BuildQueue { + return &BuildQueue{ + queued: make(map[NodeKey]bool), + running: make(map[NodeKey]bool), + failed: make(map[NodeKey]bool), + } +} + // AddLeaf adds the leaf of message id. The IDs must come in increasing order. func (q *BuildQueue) AddLeaf(id int) { q.leaves = append(q.leaves, id) @@ -135,9 +138,6 @@ func (q *BuildQueue) nextLeaf() (NodeKey, bool) { return NodeKey{}, false } -// BuildMergeHeap holds the merges that can start, by the end of their context. -type BuildMergeHeap []NodeKey - func (h BuildMergeHeap) Len() int { return len(h) }