cfc65a13f6
This commit includes updates that affects the build, testing, and
deployment of Tile38.
- The root level build.sh has been broken up into multiple scripts
and placed in the "scripts" directory.
- The vendor directory has been updated to follow the Go modules
rules, thus `make` should work on isolated environments. Also
some vendored packages may have been updated to a later
version, if needed.
- The Makefile has been updated to allow for making single
binaries such as `make tile38-server`. There is some scaffolding
during the build process, so from now on all binaries should be
made using make. For example, to run a development version of
the tile38-cli binary, do this:
make tile38-cli && ./tile38-cli
not this:
go run cmd/tile38-cli/main.go
- Travis.CI docker push script has been updated to address a
change to Docker's JSON repo meta output, which in turn fixes
a bug where new Tile38 versions were not being properly pushed
to Docker
107 lines
2.1 KiB
Go
107 lines
2.1 KiB
Go
package amqp
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"math/big"
|
|
)
|
|
|
|
const (
|
|
free = 0
|
|
allocated = 1
|
|
)
|
|
|
|
// allocator maintains a bitset of allocated numbers.
|
|
type allocator struct {
|
|
pool *big.Int
|
|
last int
|
|
low int
|
|
high int
|
|
}
|
|
|
|
// NewAllocator reserves and frees integers out of a range between low and
|
|
// high.
|
|
//
|
|
// O(N) worst case space used, where N is maximum allocated, divided by
|
|
// sizeof(big.Word)
|
|
func newAllocator(low, high int) *allocator {
|
|
return &allocator{
|
|
pool: big.NewInt(0),
|
|
last: low,
|
|
low: low,
|
|
high: high,
|
|
}
|
|
}
|
|
|
|
// String returns a string describing the contents of the allocator like
|
|
// "allocator[low..high] reserved..until"
|
|
//
|
|
// O(N) where N is high-low
|
|
func (a allocator) String() string {
|
|
b := &bytes.Buffer{}
|
|
fmt.Fprintf(b, "allocator[%d..%d]", a.low, a.high)
|
|
|
|
for low := a.low; low <= a.high; low++ {
|
|
high := low
|
|
for a.reserved(high) && high <= a.high {
|
|
high++
|
|
}
|
|
|
|
if high > low+1 {
|
|
fmt.Fprintf(b, " %d..%d", low, high-1)
|
|
} else if high > low {
|
|
fmt.Fprintf(b, " %d", high-1)
|
|
}
|
|
|
|
low = high
|
|
}
|
|
return b.String()
|
|
}
|
|
|
|
// Next reserves and returns the next available number out of the range between
|
|
// low and high. If no number is available, false is returned.
|
|
//
|
|
// O(N) worst case runtime where N is allocated, but usually O(1) due to a
|
|
// rolling index into the oldest allocation.
|
|
func (a *allocator) next() (int, bool) {
|
|
wrapped := a.last
|
|
|
|
// Find trailing bit
|
|
for ; a.last <= a.high; a.last++ {
|
|
if a.reserve(a.last) {
|
|
return a.last, true
|
|
}
|
|
}
|
|
|
|
// Find preceding free'd pool
|
|
a.last = a.low
|
|
|
|
for ; a.last < wrapped; a.last++ {
|
|
if a.reserve(a.last) {
|
|
return a.last, true
|
|
}
|
|
}
|
|
|
|
return 0, false
|
|
}
|
|
|
|
// reserve claims the bit if it is not already claimed, returning true if
|
|
// successfully claimed.
|
|
func (a *allocator) reserve(n int) bool {
|
|
if a.reserved(n) {
|
|
return false
|
|
}
|
|
a.pool.SetBit(a.pool, n-a.low, allocated)
|
|
return true
|
|
}
|
|
|
|
// reserved returns true if the integer has been allocated
|
|
func (a *allocator) reserved(n int) bool {
|
|
return a.pool.Bit(n-a.low) == allocated
|
|
}
|
|
|
|
// release frees the use of the number for another allocation
|
|
func (a *allocator) release(n int) {
|
|
a.pool.SetBit(a.pool, n-a.low, free)
|
|
}
|