send: use accessor function for buffer pool
This commit is contained in:
parent
32d2148835
commit
1c02557013
2
send.go
2
send.go
|
@ -54,7 +54,7 @@ type QueueOutboundElement struct {
|
||||||
func (device *Device) NewOutboundElement() *QueueOutboundElement {
|
func (device *Device) NewOutboundElement() *QueueOutboundElement {
|
||||||
return &QueueOutboundElement{
|
return &QueueOutboundElement{
|
||||||
dropped: AtomicFalse,
|
dropped: AtomicFalse,
|
||||||
buffer: device.pool.messageBuffers.Get().(*[MaxMessageSize]byte),
|
buffer: device.GetMessageBuffer(),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue