1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
/*
* Copyright (c) 2017-2018 Samsung Electronics Co., Ltd All Rights Reserved
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License
*/
// File requests/queue_test.go contains additional tests for queue.go. Please
// take a look at requests_test.go for initTest() and requestsTests definition.
package requests
import (
"testing"
"git.tizen.org/tools/boruta"
"github.com/stretchr/testify/assert"
)
func TestRemovePanic(t *testing.T) {
assert := assert.New(t)
queue := newPrioQueue()
assert.Panics(func() { queue._remove(boruta.ReqID(1), boruta.LoPrio) })
}
func TestQueue(t *testing.T) {
assert := assert.New(t)
queue := newPrioQueue()
var reqs = []struct {
id boruta.ReqID
pr boruta.Priority
}{
{boruta.ReqID(1), boruta.Priority(7)},
{boruta.ReqID(2), boruta.Priority(1)},
{boruta.ReqID(3), boruta.Priority(2)},
{boruta.ReqID(4), boruta.Priority(12)},
{boruta.ReqID(5), boruta.Priority(3)},
{boruta.ReqID(6), boruta.Priority(3)},
}
sorted := []boruta.ReqID{boruta.ReqID(2), boruta.ReqID(3), boruta.ReqID(5), boruta.ReqID(6),
boruta.ReqID(1), boruta.ReqID(4)}
// Test for empty queue.
reqid, ok := queue.next()
assert.False(ok)
assert.Equal(boruta.ReqID(0), reqid)
// Test if iterator was initialized and queue is empty.
queue.initIterator()
reqid, ok = queue.next()
assert.False(ok)
assert.Equal(boruta.ReqID(0), reqid)
queue.releaseIterator()
req := requestsTests[0].req
// Push requests to the queue.
for _, r := range reqs {
queue.pushRequest(&boruta.ReqInfo{
ID: r.id,
Priority: r.pr,
Owner: req.Owner,
Deadline: req.Deadline,
ValidAfter: req.ValidAfter,
State: boruta.WAIT,
Caps: req.Caps,
})
}
// Check if queue returns request IDs in proper order.
queue.initIterator()
for _, r := range sorted {
reqid, ok = queue.next()
assert.True(ok)
assert.Equal(r, reqid)
}
// Check if call to next() after iterating through whole queue returns false.
reqid, ok = queue.next()
assert.False(ok)
assert.Equal(boruta.ReqID(0), reqid)
queue.releaseIterator()
// Check if after another initialization next() returns first element.
queue.initIterator()
reqid, ok = queue.next()
assert.True(ok)
assert.Equal(sorted[0], reqid)
// Check call to releaseIterator() when iterator hasn't finished properly
// sets next().
queue.releaseIterator()
reqid, ok = queue.next()
assert.False(ok)
assert.Equal(boruta.ReqID(0), reqid)
}
|
