Describe child agent directories and limits

[onechat] / build_queue_test.go

diff --git a/build_queue_test.go b/build_queue_test.go
index 078e06a64e0e3240ffd735b34b27b3e805094756..34a4571212e3baf5fd7d12fd2995c6221ae388af 100644 (file)
--- a/build_queue_test.go
+++ b/build_queue_test.go
@@ -14,6 +14,7 @@ func TestQueueStartsInMessageOrder(t *testing.T) {
        queue.AddMerge(NodeKey{1, 1})
 
        var order []NodeKey
        queue.AddMerge(NodeKey{1, 1})
 
        var order []NodeKey

+

        for {
                key, ready := queue.Next()
                if !ready {
        for {
                key, ready := queue.Next()
                if !ready {


@@ -34,16 +35,19 @@ func TestQueueRetriesAFailedMergeAtTheNextMessage(t *testing.T) {
        require.True(t, ready)
 
        queue.Fail(key)
        require.True(t, ready)
 
        queue.Fail(key)

+

        _, ready = queue.Next()
        require.False(t, ready)
 
        queue.Retry()
        _, ready = queue.Next()
        require.False(t, ready)
 
        queue.Retry()

+

        key, ready = queue.Next()
        require.True(t, ready)
        require.Equal(t, NodeKey{1, 0}, key)
 
        queue.Done(key)
        queue.AddMerge(NodeKey{1, 0})
        key, ready = queue.Next()
        require.True(t, ready)
        require.Equal(t, NodeKey{1, 0}, key)
 
        queue.Done(key)
        queue.AddMerge(NodeKey{1, 0})

+

        _, ready = queue.Next()
        require.True(t, ready)
 }
        _, ready = queue.Next()
        require.True(t, ready)
 }