def write(self, buf, start=0, end=None):
end = end if end else len(buf)
port = self._spi.get_port(self.cs, self.freq, self.mode)
- port.write(buf[start:end])
+ chunks, rest = divmod(end - start, self._spi.PAYLOAD_MAX_LENGTH)
+ for i in range(chunks):
+ chunk_start = start + i * self._spi.PAYLOAD_MAX_LENGTH
+ chunk_end = chunk_start + self._spi.PAYLOAD_MAX_LENGTH
+ port.write(buf[chunk_start:chunk_end])
+ if rest:
+ port.write(buf[-1*rest:])
def readinto(self, buf, start=0, end=None, write_value=0):
end = end if end else len(buf)
in_end = in_end if in_end else len(buffer_in)
port = self._spi.get_port(self.cs, self.freq, self.mode)
result = port.exchange(buffer_out[out_start:out_end],
- in_end-in_start)
+ in_end-in_start, duplex=True)
for i, b in enumerate(result):
buffer_in[in_start+i] = b