lynxeyedの電音鍵盤

MBDとFPGAと車載で使うデバイスの備忘録

W5500でTCP/IP:send() , recv()をそれぞれ独立に行う

W5500でTCPソケット送受信をそれぞれ独立にしたい

ArduinoでもすっかりおなじみになったWiznetのSPI-PHYシリーズですが、思い出しては忘れを繰り返すので、自分への開発時短効果を期待してメモがわり。

W5100/5200/5500のioLibraryドライバ
GitHub - Wiznet/ioLibrary_Driver: Create a repository of WIZnet ioLibrary.

これを自分の使ってるマイコンに移植して、こんな感じで動かすと思います。

#include <____my_mcu_headers____.h>
#include "socket.h"
#include "loopback.h"	


/////////////////////////////////////////
// SOCKET NUMBER DEFINION for Examples //
/////////////////////////////////////////
#define SOCK_TCPS        0
// ....

///////////////////////////////////
// Default Network Configuration //
///////////////////////////////////
volatile wiz_NetInfo gWIZNETINFO = { .mac = {0x00, 0xAB, 0xCD, 0xEF, 0x01, 0x23},
                            .ip = {192,168,1,111},
                            .sn = {255,255,255,0},
                            .gw = {192, 168, 1, 1},
                            .dns = {0,0,0,0},
                            .dhcp = NETINFO_STATIC};

							
// 	(中略)
int main(void){

	int32_t ret = 0;
    uint8_t memsize[2][8] = {{2,2,2,2,2,2,2,2},{2,2,2,2,2,2,2,2}};


// 初期化処理もろもろ

    
	for(;;) {
	
        if( (ret = loopback_tcps(SOCK_TCPS, gDATABUF, 5000)) < 0) { // Port=5000 (= 192.168.1.111:5000)
			printf("SOCKET ERROR : %ld\r\n", ret);
		}

// ......
	}
}

こんな感じでloopback_tcpsをポーリングで動かしてるとおもいます。
loopbackサンプルプログラムを動かして喜んでそのまま積み基板化することが多いのですが、
loopbackのサンプルプログラムを元にsend(), recv()を独立に動かすの、前知識なしではしんどい。

前知識:TCPの状態遷移図
基礎から学ぶWindowsネットワーク:第16回 信頼性のある通信を実現するTCPプロトコル(3) (3/4) - @IT

でもほかにリソース割かなくてはならないし読んでられないよ...何のためにWiznet(ryなので、loopback.cのloopback_tcps()を下記に示すコードに置き換えるだけでrecv(),send()のみできるプログラムを急ごしらえで作成しました。
send/recvの同時発生でバッファの内容を破壊しないような配慮はしてないので各自で書き換えてほしい。

bufに文字列がある場合、文字列をsend()します。bufが空の場合(buf[0]='\0')受信データがあるか確認し、あったらrecv()します。ループバックはしません。なので関数名がおかしくなります。はい。ちゃんと直せよ(殴

#if LOOPBACK_MODE == LOOPBACK_MAIN_NOBLCOK
int32_t loopback_tcps(uint8_t sn, uint8_t* buf, uint16_t port)
{
   int32_t ret;
   uint16_t size = 0, sentsize=0;
#ifdef _LOOPBACK_DEBUG_
   uint8_t destip[4];
   uint16_t destport;
#endif

   switch(getSn_SR(sn))
   {
      case SOCK_ESTABLISHED :
         if(getSn_IR(sn) & Sn_IR_CON)
         {
#ifdef _LOOPBACK_DEBUG_
			getSn_DIPR(sn, destip);
			destport = getSn_DPORT(sn);

			printf("%d:Connected - IP:%d.%d.%d.%d : %d\r\n",sn, destip[0], destip[1], destip[2], destip[3], destport);
#endif
			setSn_IR(sn,Sn_IR_CON);
         }
		 if((size = getSn_RX_RSR(sn)) > 0) // Don't need to check SOCKERR_BUSY because it doesn't not occur.
         {
			if(size > DATA_BUF_SIZE) size = DATA_BUF_SIZE;
			ret = recv(sn, buf, size);
	        if(ret <= 0){
                return ret;      // check SOCKERR_BUSY & SOCKERR_XXX. For showing the occurrence of SOCKERR_BUSY.
            }
//            sentsize = 0;
//            while(size != sentsize)
//			{
//				ret = send(sn, buf+sentsize, size-sentsize);
//				if(ret < 0)
//				{
//					close(sn);
//					return ret;
//				}
//				sentsize += ret; // Don't care SOCKERR_BUSY, because it is zero.
//			}
         }else if((size = getSn_TX_FSR(sn)) > 0){
         
            size = strlen((const char*)buf);
            sentsize = 0;
			while(size != sentsize)
			{
				ret = send(sn, buf+sentsize, size-sentsize);
				if(ret < 0)
				{
					close(sn);
					return ret;
				}
				sentsize += ret; // Don't care SOCKERR_BUSY, because it is zero.
			}
        }
         break;
      case SOCK_CLOSE_WAIT :
#ifdef _LOOPBACK_DEBUG_
         //printf("%d:CloseWait\r\n",sn);
#endif
         if((ret = disconnect(sn)) != SOCK_OK) return ret;
#ifdef _LOOPBACK_DEBUG_
         printf("%d:Socket Closed\r\n", sn);
#endif
         break;
      case SOCK_INIT :
#ifdef _LOOPBACK_DEBUG_
    	 printf("%d:Listen, TCP server loopback, port [%d]\r\n", sn, port);
#endif
         if( (ret = listen(sn)) != SOCK_OK) return ret;
         break;
      case SOCK_CLOSED:
#ifdef _LOOPBACK_DEBUG_
         //printf("%d:TCP server loopback start\r\n",sn);
#endif
         if((ret = socket(sn, Sn_MR_TCP, port, 0x00)) != sn) return ret;
#ifdef _LOOPBACK_DEBUG_
         //printf("%d:Socket opened\r\n",sn);
#endif
         break;
      default:
         break;
   }

   return 1;
}


main関数などからループで呼び出してやればOK。
send()したい文字列があればbufにそのポインタを指定し、なければ空のバッファのポインタを指定しておく
呼び出し後にbufの中身を消しておくのを忘れずに。