mirror of
https://github.com/tinygo-org/drivers.git
synced 2026-07-26 10:38:41 +00:00
Nicholas Wiersma
4b831af52b
Thank you, @nrwiersma for working on this and @soypat for review. Now merging.
105 lines
2.1 KiB
Go
105 lines
2.1 KiB
Go
package w5500
|
|
|
|
import "time"
|
|
|
|
func (d *Device) irqPoll(sockn uint8, state uint8, deadline time.Time) uint8 {
|
|
waitTime := 500 * time.Microsecond
|
|
for {
|
|
if !deadline.IsZero() && time.Now().After(deadline) {
|
|
// If a deadline is set and it has passed, return 0.
|
|
return sockIntUnknown
|
|
}
|
|
|
|
irq := d.readByte(sockInt, sockAddr(sockn)) & 0b00011111
|
|
if got := irq & state; got != 0 {
|
|
// Acknowledge the interrupt.
|
|
d.writeByte(sockInt, sockAddr(sockn), got)
|
|
|
|
return got
|
|
}
|
|
|
|
d.mu.Unlock()
|
|
|
|
time.Sleep(waitTime)
|
|
|
|
// Exponential backoff for polling.
|
|
waitTime *= 2
|
|
if waitTime > 10*time.Millisecond {
|
|
waitTime = 10 * time.Millisecond
|
|
}
|
|
|
|
d.mu.Lock()
|
|
}
|
|
}
|
|
|
|
func (d *Device) read(addr uint16, bsb uint8, p []byte) {
|
|
d.cs(false)
|
|
if len(p) == 0 {
|
|
return
|
|
}
|
|
|
|
d.sendReadHeader(addr, bsb)
|
|
_ = d.bus.Tx(nil, p)
|
|
d.cs(true)
|
|
}
|
|
|
|
func (d *Device) readUint16(addr uint16, bsb uint8) uint16 {
|
|
d.cs(false)
|
|
d.sendReadHeader(addr, bsb)
|
|
buf := d.cmdBuf
|
|
_ = d.bus.Tx(nil, buf[:2])
|
|
d.cs(true)
|
|
return uint16(buf[1]) | uint16(buf[0])<<8
|
|
}
|
|
|
|
func (d *Device) readByte(addr uint16, bsb uint8) byte {
|
|
d.cs(false)
|
|
d.sendReadHeader(addr, bsb)
|
|
r, _ := d.bus.Transfer(byte(0))
|
|
d.cs(true)
|
|
return r
|
|
}
|
|
|
|
func (d *Device) write(addr uint16, bsb uint8, p []byte) {
|
|
d.cs(false)
|
|
if len(p) == 0 {
|
|
return
|
|
}
|
|
d.sendWriteHeader(addr, bsb)
|
|
_ = d.bus.Tx(p, nil)
|
|
d.cs(true)
|
|
}
|
|
|
|
func (d *Device) writeUint16(addr uint16, bsb uint8, v uint16) {
|
|
d.cs(false)
|
|
d.sendWriteHeader(addr, bsb)
|
|
buf := d.cmdBuf
|
|
buf[0] = byte(v >> 8)
|
|
buf[1] = byte(v & 0xff)
|
|
_ = d.bus.Tx(buf[:2], nil)
|
|
d.cs(true)
|
|
}
|
|
|
|
func (d *Device) writeByte(addr uint16, bsb uint8, b byte) {
|
|
d.cs(false)
|
|
d.sendWriteHeader(addr, bsb)
|
|
_, _ = d.bus.Transfer(b)
|
|
d.cs(true)
|
|
}
|
|
|
|
func (d *Device) sendReadHeader(addr uint16, bsb uint8) {
|
|
buf := d.cmdBuf
|
|
buf[0] = byte(addr >> 8)
|
|
buf[1] = byte(addr & 0xff)
|
|
buf[2] = bsb << 3
|
|
_ = d.bus.Tx(buf[:], nil)
|
|
}
|
|
|
|
func (d *Device) sendWriteHeader(addr uint16, bsb uint8) {
|
|
buf := d.cmdBuf
|
|
buf[0] = byte(addr >> 8)
|
|
buf[1] = byte(addr & 0xff)
|
|
buf[2] = bsb<<3 | 0b100
|
|
_ = d.bus.Tx(buf[:], nil)
|
|
}
|