|
|
|
@ -36,6 +36,7 @@ const CAN_ID_06C = 0x06C |
|
|
|
|
const CAN_ID_061 = 0x061 |
|
|
|
|
const CAN_ID_062 = 0x062 |
|
|
|
|
const CAN_ID_065 = 0x065 |
|
|
|
|
const bufferSize = 100 |
|
|
|
|
|
|
|
|
|
type CanFrame struct { |
|
|
|
|
CanId uint32 |
|
|
|
@ -159,7 +160,7 @@ func StartCan(canbus string) (<-chan *CanFrame, error) { |
|
|
|
|
|
|
|
|
|
if cerr := socket.Bind(canbus, filter); cerr == nil { |
|
|
|
|
|
|
|
|
|
canevents := make(chan *CanFrame) |
|
|
|
|
canevents := make(chan *CanFrame, bufferSize) |
|
|
|
|
|
|
|
|
|
go func() { |
|
|
|
|
defer close(canevents) |
|
|
|
|