socket setsockopt show EINVAL error

[skylin008]

Thanks shared this impressive project. I had rebuild the micropython firmware with V1.22, when set the socket.setsockopt parameter ,show OSError: [22] EINVAL, how to solve this issue. As follow code:

from machine import SPI, Pin
import gc
import socket
import uasyncio as asyncio
import logging
import network
from primitives.ringbuf_queue import RingbufQueue
from micropython import alloc_emergency_exception_buf
from time import sleep_ms

gc.collect()

from InitConfig import config

log = logging.MiniLog("Ethernet", level = logging.DEBUG)

alloc_emergency_exception_buf(100)

DEBUG = config.get('DEBUG', False)

version = "1.0"
author = "skylin"

class Ethernet():
ip = config.get('IP') # IP address
subnet = config.get('SUBNET') # subnet_mask
gateway = config.get('GATEWAY') # gateway
dns = config.get('DNS') # dns

def __init__(self,  maxtry = 100):
    _spi = SPI(1, baudrate = 10_000_000)    # SPI1 highest speed for 42M
    _cs  = Pin('E_SS', Pin.OUT)
    _rst = Pin('E_RST', Pin.OUT)
    _rst(0)
    sleep_ms(50)
    _rst(1)
    self._maxtry = maxtry
    self._isRuning = False
    self.nic = network.WIZNET5K(_spi, _cs, _rst)
    self.nic.active(False)
    self.nic.active(True)
    self.nic.ifconfig((self.ip, self.subnet, self.gateway, self.dns))
    cnt = 0
    while not self.nic.isconnected():
        cnt = cnt + 1
        sleep_ms(200)
        if maxtry is not None and cnt >= maxtry:
            cnt = 0
            break
    self._isRuning = True

def status(self):
    return self._isRuning
class Udp():

def __init__(self):

    host        = config.get('HOST')      # server IP
    port        = config.get('PORT')      # server port

    
    self.ringbuf = RingbufQueue([0 for _ in range(100)])
    
    self.isRuning = False
    self.eth = Ethernet()
    print(self.eth.status())
    if self.eth.status():
        s    = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # make a udp socket
        addr = socket.getaddrinfo(host, port)[0][-1]
        s.bind(('',port))                                        # bind porrt
        s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)  # if netlink free can be used for next time
    
        s.setblocking(False)
        self._sock = s
        self.addr  = addr
        self.isRuning = True
        #self.sreader = asyncio.StreamReader(self._sock)
        #self.swriter = asyncio.StreamWriter(self._sock, {})

def close(self):
    self._sock.close()

def status(self):
    return self.isRuning



def write(self):
    if self.isRuning: 
        if not self.ringbuf.empty():
            try:
                data = self.ringbuf.get_nowait()
                print(data) 
                                  
                self._sock.sendto(data, self.addr)

            except OSError as e:
                self.close()
            finally:
                pass

@micropython.native
def frame(self, data):
    if data is not None:
        self.ringbuf.put_nowait(data)
        #res = self.ringbuf.get_nowait()
        #print(res)


async def run(self):
    if self.status():
        if not self.ringbuf.empty():

            data = self.ringbuf.get_nowait()
            print(f"state:{self.state()}")
            print(f"sendData:{data}")
            
            try:
                await self.swriter.awrite(data)
                await self.swriter.drain()
            except:
                self.close()
                return 
class Frame(object):

NET_PACKET_HEADER    = config.get('NET_PACKET_HEADER')
NET_PACKET_TYPE      = config.get('NET_PACKET_TYPE')
NET_PACKET_COMPID    = config.get('NET_PACKET_COMPID')
NET_PACKET_TIMESTAMP = config.get('NET_PACKET_TIMESTAMP')
NET_PACKET_END       = config.get('NET_PACKET_END')

def __init__(self):
    pass

@micropython.native
def _parity_check(self, bytecode):
    """
    even return True
    odd  return False
    """
    parity = 0
    for b in bytecode:
        parity ^= b & 1
        for i in range(1, 8):
            parity ^= (b >> i) & 1
    return parity == 0

@micropython.native
def pack(self, distance, angle):               
   
    d = b''.join(map(lambda x:int.to_bytes(x,2,'little'),distance))

    a = b''.join(map(lambda x:int.to_bytes(x,1,'little'),angle))
    
    dataPacket = d + a

    dataLength = len(dataPacket)  

    packetLength = (42 + dataLength).to_bytes(8, 'little')   

    if (self._parity_check(dataPacket)):
        parity = b'\x01'
    else:
        parity = b'\x00'
        
    msg = self.NET_PACKET_HEADER + packetLength + self.NET_PACKET_TYPE + self.NET_PACKET_COMPID + self.NET_PACKET_TIMESTAMP + dataPacket + parity + self.NET_PACKET_END 
    
    print(f"package:{msg}")
    return msg

(Edited by @jimmo to add formatting)

[jimmo]

@skylin008 Please see Welcome (Please read before posting) for how to format code in forum posts and also please try to share only minimal examples to highlight the issue.

In this case though, setsockopt is not supported on the wiznet driver when using it in stack mode (i.e. where the wiznet chip manages the tcp stack). It is possible to build in LWIP mode, in which case setsockopt will work.