1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
package sctp
// control queue
type controlQueue struct {
queue []*packet
}
func newControlQueue() *controlQueue {
return &controlQueue{queue: []*packet{}}
}
func (q *controlQueue) push(c *packet) {
q.queue = append(q.queue, c)
}
func (q *controlQueue) pushAll(packets []*packet) {
q.queue = append(q.queue, packets...)
}
func (q *controlQueue) popAll() []*packet {
packets := q.queue
q.queue = []*packet{}
return packets
}
func (q *controlQueue) size() int {
return len(q.queue)
}
|
