mirror of
https://github.com/cwinfo/matterbridge.git
synced 2024-11-23 05:51:35 +00:00
145 lines
2.9 KiB
Go
145 lines
2.9 KiB
Go
/*
|
|
Package ring provides a simple implementation of a ring buffer.
|
|
*/
|
|
package ring
|
|
|
|
/*
|
|
The DefaultCapacity of an uninitialized Ring buffer.
|
|
|
|
Changing this value only affects ring buffers created after it is changed.
|
|
*/
|
|
var DefaultCapacity int = 10
|
|
|
|
/*
|
|
Type Ring implements a Circular Buffer.
|
|
The default value of the Ring struct is a valid (empty) Ring buffer with capacity DefaultCapacify.
|
|
*/
|
|
type Ring struct {
|
|
head int // the most recent value written
|
|
tail int // the least recent value written
|
|
buff []interface{}
|
|
}
|
|
|
|
/*
|
|
Set the maximum size of the ring buffer.
|
|
*/
|
|
func (r *Ring) SetCapacity(size int) {
|
|
r.checkInit()
|
|
r.extend(size)
|
|
}
|
|
|
|
/*
|
|
Capacity returns the current capacity of the ring buffer.
|
|
*/
|
|
func (r Ring) Capacity() int {
|
|
return len(r.buff)
|
|
}
|
|
|
|
/*
|
|
Enqueue a value into the Ring buffer.
|
|
*/
|
|
func (r *Ring) Enqueue(i interface{}) {
|
|
r.checkInit()
|
|
r.set(r.head+1, i)
|
|
old := r.head
|
|
r.head = r.mod(r.head + 1)
|
|
if old != -1 && r.head == r.tail {
|
|
r.tail = r.mod(r.tail + 1)
|
|
}
|
|
}
|
|
|
|
/*
|
|
Dequeue a value from the Ring buffer.
|
|
|
|
Returns nil if the ring buffer is empty.
|
|
*/
|
|
func (r *Ring) Dequeue() interface{} {
|
|
r.checkInit()
|
|
if r.head == -1 {
|
|
return nil
|
|
}
|
|
v := r.get(r.tail)
|
|
if r.tail == r.head {
|
|
r.head = -1
|
|
r.tail = 0
|
|
} else {
|
|
r.tail = r.mod(r.tail + 1)
|
|
}
|
|
return v
|
|
}
|
|
|
|
/*
|
|
Read the value that Dequeue would have dequeued without actually dequeuing it.
|
|
|
|
Returns nil if the ring buffer is empty.
|
|
*/
|
|
func (r *Ring) Peek() interface{} {
|
|
r.checkInit()
|
|
if r.head == -1 {
|
|
return nil
|
|
}
|
|
return r.get(r.tail)
|
|
}
|
|
|
|
/*
|
|
Values returns a slice of all the values in the circular buffer without modifying them at all.
|
|
The returned slice can be modified independently of the circular buffer. However, the values inside the slice
|
|
are shared between the slice and circular buffer.
|
|
*/
|
|
func (r *Ring) Values() []interface{} {
|
|
if r.head == -1 {
|
|
return []interface{}{}
|
|
}
|
|
arr := make([]interface{}, 0, r.Capacity())
|
|
for i := 0; i < r.Capacity(); i++ {
|
|
idx := r.mod(i + r.tail)
|
|
arr = append(arr, r.get(idx))
|
|
if idx == r.head {
|
|
break
|
|
}
|
|
}
|
|
return arr
|
|
}
|
|
|
|
/**
|
|
*** Unexported methods beyond this point.
|
|
**/
|
|
|
|
// sets a value at the given unmodified index and returns the modified index of the value
|
|
func (r *Ring) set(p int, v interface{}) {
|
|
r.buff[r.mod(p)] = v
|
|
}
|
|
|
|
// gets a value based at a given unmodified index
|
|
func (r *Ring) get(p int) interface{} {
|
|
return r.buff[r.mod(p)]
|
|
}
|
|
|
|
// returns the modified index of an unmodified index
|
|
func (r *Ring) mod(p int) int {
|
|
return p % len(r.buff)
|
|
}
|
|
|
|
func (r *Ring) checkInit() {
|
|
if r.buff == nil {
|
|
r.buff = make([]interface{}, DefaultCapacity)
|
|
for i := range r.buff {
|
|
r.buff[i] = nil
|
|
}
|
|
r.head, r.tail = -1, 0
|
|
}
|
|
}
|
|
|
|
func (r *Ring) extend(size int) {
|
|
if size == len(r.buff) {
|
|
return
|
|
} else if size < len(r.buff) {
|
|
r.buff = r.buff[0:size]
|
|
}
|
|
newb := make([]interface{}, size-len(r.buff))
|
|
for i := range newb {
|
|
newb[i] = nil
|
|
}
|
|
r.buff = append(r.buff, newb...)
|
|
}
|