diff options
Diffstat (limited to 'device/pools.go')
-rw-r--r-- | device/pools.go | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/device/pools.go b/device/pools.go index 6939eeb..55eb6ab 100644 --- a/device/pools.go +++ b/device/pools.go @@ -64,12 +64,12 @@ func (device *Device) GetInboundElement() *QueueInboundElement { } } -func (device *Device) PutInboundElement(msg *QueueInboundElement) { - msg.clearPointers() +func (device *Device) PutInboundElement(elem *QueueInboundElement) { + elem.clearPointers() if PreallocatedBuffersPerPool == 0 { - device.pool.inboundElementPool.Put(msg) + device.pool.inboundElementPool.Put(elem) } else { - device.pool.inboundElementReuseChan <- msg + device.pool.inboundElementReuseChan <- elem } } @@ -81,11 +81,11 @@ func (device *Device) GetOutboundElement() *QueueOutboundElement { } } -func (device *Device) PutOutboundElement(msg *QueueOutboundElement) { - msg.clearPointers() +func (device *Device) PutOutboundElement(elem *QueueOutboundElement) { + elem.clearPointers() if PreallocatedBuffersPerPool == 0 { - device.pool.outboundElementPool.Put(msg) + device.pool.outboundElementPool.Put(elem) } else { - device.pool.outboundElementReuseChan <- msg + device.pool.outboundElementReuseChan <- elem } } |