* 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: rjl493456442 <garyrong0905@gmail.com>
		
			
				
	
	
		
			101 lines
		
	
	
		
			2.6 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			101 lines
		
	
	
		
			2.6 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| // 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])
 | |
| 			}
 | |
| 		}
 | |
| 	}
 | |
| }
 |