aboutsummaryrefslogtreecommitdiffstats
path: root/syz-verifier/exectask.go
diff options
context:
space:
mode:
authorTaras Madan <tarasmadan@google.com>2022-03-30 15:47:47 +0200
committerGitHub <noreply@github.com>2022-03-30 15:47:47 +0200
commit9d49f3a7c56a414597a16f28dd8b6b2be6352ad8 (patch)
treedcba4852fbcedca01e8de47e52ba0a3a9f20c353 /syz-verifier/exectask.go
parent42718dd659525414aa0bf2794688ac94a32f7764 (diff)
Revert "syz-verifier/exectask.go: add tests" (#3050)
This reverts commit 42718dd659525414aa0bf2794688ac94a32f7764. Original PR had a race.
Diffstat (limited to 'syz-verifier/exectask.go')
-rw-r--r--syz-verifier/exectask.go14
1 files changed, 1 insertions, 13 deletions
diff --git a/syz-verifier/exectask.go b/syz-verifier/exectask.go
index db947cbcd..052469ed7 100644
--- a/syz-verifier/exectask.go
+++ b/syz-verifier/exectask.go
@@ -66,12 +66,6 @@ func MakeExecTask(prog *prog.Prog) *ExecTask {
return task
}
-func ExecTasksQueued() int {
- ChanMapMutex.Lock()
- defer ChanMapMutex.Unlock()
- return len(TaskIDToExecResultChan)
-}
-
func DeleteExecTask(task *ExecTask) {
ChanMapMutex.Lock()
defer ChanMapMutex.Unlock()
@@ -94,28 +88,22 @@ func MakeExecTaskQueue() *ExecTaskQueue {
// ExecTaskQueue respects the pq.priority. Internally it is a thread-safe PQ.
type ExecTaskQueue struct {
pq ExecTaskPriorityQueue
- mu sync.Mutex
}
// PopTask return false if no tasks are available.
func (q *ExecTaskQueue) PopTask() (*ExecTask, bool) {
- q.mu.Lock()
- defer q.mu.Unlock()
if q.pq.Len() == 0 {
return nil, false
}
+
return heap.Pop(&q.pq).(*ExecTask), true
}
func (q *ExecTaskQueue) PushTask(task *ExecTask) {
- q.mu.Lock()
- defer q.mu.Unlock()
heap.Push(&q.pq, task)
}
func (q *ExecTaskQueue) Len() int {
- q.mu.Lock()
- defer q.mu.Unlock()
return q.pq.Len()
}