mirror of
https://github.com/onyx-and-iris/vbantxt.git
synced 2025-04-19 20:53:45 +01:00
Compare commits
3 Commits
d72c6a2d17
...
e36af2c059
Author | SHA1 | Date | |
---|---|---|---|
e36af2c059 | |||
5a5a6fa893 | |||
be11239d39 |
@ -11,6 +11,12 @@ Before any major/minor/patch bump all unit tests will be run to verify they pass
|
|||||||
|
|
||||||
- [x]
|
- [x]
|
||||||
|
|
||||||
|
# [0.2.1] - 2024-11-07
|
||||||
|
|
||||||
|
### Fixed
|
||||||
|
|
||||||
|
- {packet}.header() now uses a reusable buffer.
|
||||||
|
|
||||||
# [0.2.0] - 2024-10-27
|
# [0.2.0] - 2024-10-27
|
||||||
|
|
||||||
### Added
|
### Added
|
||||||
|
35
packet.go
35
packet.go
@ -1,6 +1,7 @@
|
|||||||
package vbantxt
|
package vbantxt
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"bytes"
|
||||||
"encoding/binary"
|
"encoding/binary"
|
||||||
|
|
||||||
log "github.com/sirupsen/logrus"
|
log "github.com/sirupsen/logrus"
|
||||||
@ -17,19 +18,24 @@ var BpsOpts = []int{0, 110, 150, 300, 600, 1200, 2400, 4800, 9600, 14400, 19200,
|
|||||||
1000000, 1500000, 2000000, 3000000}
|
1000000, 1500000, 2000000, 3000000}
|
||||||
|
|
||||||
type packet struct {
|
type packet struct {
|
||||||
name string
|
streamname []byte
|
||||||
bpsIndex int
|
bpsIndex int
|
||||||
channel int
|
channel int
|
||||||
framecounter []byte
|
framecounter []byte
|
||||||
|
hbuf *bytes.Buffer
|
||||||
}
|
}
|
||||||
|
|
||||||
// newPacket returns a packet struct with default values, framecounter at 0.
|
// newPacket returns a packet struct with default values, framecounter at 0.
|
||||||
func newPacket(streamname string) packet {
|
func newPacket(streamname string) packet {
|
||||||
|
streamnameBuf := make([]byte, streamNameSz)
|
||||||
|
copy(streamnameBuf, streamname)
|
||||||
|
|
||||||
return packet{
|
return packet{
|
||||||
name: streamname,
|
streamname: streamnameBuf,
|
||||||
bpsIndex: 0,
|
bpsIndex: 0,
|
||||||
channel: 0,
|
channel: 0,
|
||||||
framecounter: make([]byte, 4),
|
framecounter: make([]byte, 4),
|
||||||
|
hbuf: bytes.NewBuffer(make([]byte, headerSz)),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -43,24 +49,17 @@ func (p *packet) nbc() byte {
|
|||||||
return byte(p.channel)
|
return byte(p.channel)
|
||||||
}
|
}
|
||||||
|
|
||||||
// streamname defines the stream name of the text request
|
|
||||||
func (p *packet) streamname() []byte {
|
|
||||||
b := make([]byte, streamNameSz)
|
|
||||||
copy(b, p.name)
|
|
||||||
return b
|
|
||||||
}
|
|
||||||
|
|
||||||
// header returns a fully formed packet header
|
// header returns a fully formed packet header
|
||||||
func (p *packet) header() []byte {
|
func (p *packet) header() []byte {
|
||||||
h := make([]byte, 0, headerSz)
|
p.hbuf.Reset()
|
||||||
h = append(h, []byte("VBAN")...)
|
p.hbuf.WriteString("VBAN")
|
||||||
h = append(h, p.sr())
|
p.hbuf.WriteByte(p.sr())
|
||||||
h = append(h, byte(0))
|
p.hbuf.WriteByte(byte(0))
|
||||||
h = append(h, p.nbc())
|
p.hbuf.WriteByte(p.nbc())
|
||||||
h = append(h, byte(0x10))
|
p.hbuf.WriteByte(byte(0x10))
|
||||||
h = append(h, p.streamname()...)
|
p.hbuf.Write(p.streamname)
|
||||||
h = append(h, p.framecounter...)
|
p.hbuf.Write(p.framecounter)
|
||||||
return h
|
return p.hbuf.Bytes()
|
||||||
}
|
}
|
||||||
|
|
||||||
// bumpFrameCounter increments the frame counter by 1
|
// bumpFrameCounter increments the frame counter by 1
|
||||||
|
Loading…
x
Reference in New Issue
Block a user