• Felföldi Zsolt's avatar
    les: move client pool to les/vflux/server (#22495) · 2d89fe08
    Felföldi Zsolt authored
    * les: move client pool to les/vflux/server
    
    * les/vflux/server: un-expose NodeBalance, remove unused fn, fix bugs
    
    * tests/fuzzers/vflux: add ClientPool fuzzer
    
    * les/vflux/server: fixed balance tests
    
    * les: rebase fix
    
    * les/vflux/server: fixed more bugs
    
    * les/vflux/server: unexported NodeStateMachine fields and flags
    
    * les/vflux/server: unexport all internal components and functions
    
    * les/vflux/server: fixed priorityPool test
    
    * les/vflux/server: polish balance
    
    * les/vflux/server: fixed mutex locking error
    
    * les/vflux/server: priorityPool bug fixed
    
    * common/prque: make Prque wrap-around priority handling optional
    
    * les/vflux/server: rename funcs, small optimizations
    
    * les/vflux/server: fixed timeUntil
    
    * les/vflux/server: separated balance.posValue and negValue
    
    * les/vflux/server: polish setup
    
    * les/vflux/server: enforce capacity curve monotonicity
    
    * les/vflux/server: simplified requestCapacity
    
    * les/vflux/server: requestCapacity with target range, no iterations in SetCapacity
    
    * les/vflux/server: minor changes
    
    * les/vflux/server: moved default factors to balanceTracker
    
    * les/vflux/server: set inactiveFlag in priorityPool
    
    * les/vflux/server: moved related metrics to vfs package
    
    * les/vflux/client: make priorityPool temp state logic cleaner
    
    * les/vflux/server: changed log.Crit to log.Error
    
    * add vflux fuzzer to oss-fuzz
    Co-authored-by: 's avatarrjl493456442 <garyrong0905@gmail.com>
    Unverified
    2d89fe08
sstack_test.go 2.63 KB
// CookieJar - A contestant's algorithm toolbox
// Copyright (c) 2013 Peter Szilagyi. All rights reserved.
//
// CookieJar is dual licensed: use of this source code is governed by a BSD
// license that can be found in the LICENSE file. Alternatively, the CookieJar
// toolbox may be used in accordance with the terms and conditions contained
// in a signed written agreement between you and the author(s).

package prque

import (
	"math/rand"
	"sort"
	"testing"
)

func TestSstack(t *testing.T) {
	// Create some initial data
	size := 16 * blockSize
	data := make([]*item, size)
	for i := 0; i < size; i++ {
		data[i] = &item{rand.Int(), rand.Int63()}
	}
	stack := newSstack(nil, false)
	for rep := 0; rep < 2; rep++ {
		// Push all the data into the stack, pop out every second
		secs := []*item{}
		for i := 0; i < size; i++ {
			stack.Push(data[i])
			if i%2 == 0 {
				secs = append(secs, stack.Pop().(*item))
			}
		}
		rest := []*item{}
		for stack.Len() > 0 {
			rest = append(rest, stack.Pop().(*item))
		}
		// Make sure the contents of the resulting slices are ok
		for i := 0; i < size; i++ {
			if i%2 == 0 && data[i] != secs[i/2] {
				t.Errorf("push/pop mismatch: have %v, want %v.", secs[i/2], data[i])
			}
			if i%2 == 1 && data[i] != rest[len(rest)-i/2-1] {
				t.Errorf("push/pop mismatch: have %v, want %v.", rest[len(rest)-i/2-1], data[i])
			}
		}
	}
}

func TestSstackSort(t *testing.T) {
	// Create some initial data
	size := 16 * blockSize
	data := make([]*item, size)
	for i := 0; i < size; i++ {
		data[i] = &item{rand.Int(), int64(i)}
	}
	// Push all the data into the stack
	stack := newSstack(nil, false)
	for _, val := range data {
		stack.Push(val)
	}
	// Sort and pop the stack contents (should reverse the order)
	sort.Sort(stack)
	for _, val := range data {
		out := stack.Pop()
		if out != val {
			t.Errorf("push/pop mismatch after sort: have %v, want %v.", out, val)
		}
	}
}

func TestSstackReset(t *testing.T) {
	// Create some initial data
	size := 16 * blockSize
	data := make([]*item, size)
	for i := 0; i < size; i++ {
		data[i] = &item{rand.Int(), rand.Int63()}
	}
	stack := newSstack(nil, false)
	for rep := 0; rep < 2; rep++ {
		// Push all the data into the stack, pop out every second
		secs := []*item{}
		for i := 0; i < size; i++ {
			stack.Push(data[i])
			if i%2 == 0 {
				secs = append(secs, stack.Pop().(*item))
			}
		}
		// Reset and verify both pulled and stack contents
		stack.Reset()
		if stack.Len() != 0 {
			t.Errorf("stack not empty after reset: %v", stack)
		}
		for i := 0; i < size; i++ {
			if i%2 == 0 && data[i] != secs[i/2] {
				t.Errorf("push/pop mismatch: have %v, want %v.", secs[i/2], data[i])
			}
		}
	}
}