Users » nyatla » Code » libMiMic

Ryo Iizuka / libMiMic

This is Webservice SDK for mbed. LPCXpresso1769/LPC1768/FRDM-K64F/LPC4088

Dependents: MbedFileServer_1768MiniDK2 RedWireBridge IssueDebug_gcc MiMicRemoteMCU-for-Mbed ... more

libMiMic(MiMic library for mbed)は、WebService機能を提供するSDKです。 mbedでWebAPIに対応したネットワークデバイスを簡単に作ることが出来ます。

libMiMicはMiMic projectで開発しています。MiMic projectについてはこちらをご覧ください。 http://nyatla.jp/mimic/wp/

構成

libMiMicはmbedRTOS上で動作し、ユーザアプリケーションにAPIを提供します。コアAPIはC言語で記述されていますが、使用頻度の高いものについてはmbed向けのC++APIが準備されています。

/media/uploads/nyatla/libmimic-sdk.png

※libMiMicはmbedの標準イーサネットドライバをしようしていません。

標準イーサネットドライバと同時に使用することはできません。

MiMicIP - IPv4スタックです。レテンシとメモリ消費量を抑えたuipベースのライブラリです。
ARP/ICMP/UDP/TCP - 基礎的なソケットAPIを提供します。APIは独自です。
HTTP/1.1 Server - HTTP/1.1に対応したサーバです。マルチセッション・Chunked・持続性接続に対応しています。
HTTP Modules - HTTP/1.1の機能モジュールです。以下のモジュールがあります。
- ROM file provider - ROMに格納したファイルイメージを公開します。
- File system provider - mbedファイルシステムを公開します。
- Onchip configuration - プログラムフラッシュを利用して設定を保存します。
- MiMicVM processor - RPCリクエスト(MiMicVM)を処理します。
- FileUpload - ファイルアップロードを受け取ります。
- URL decoder - HTTPリクエストを解析します。
- UPnP handler -UPnPメッセージを処理します。
- WebSocket - Websocketサーバです。
mDNS - マルチキャストDNSサービスです。
UPnP - UPnP/1.0の機能を提供します。UPnP handlerと協調して動作します。(現在はデバイス探索(SSDP)・デスクリプション(Description)のみ実装してあります。)
DHCP/APIPA - ゼロコンフィギュレーション用のモジュールです。
HTTP/1.1 Client
mbed C++ class library - mbed向けのC++CPIです。C言語のものより簡単です。

対応機種

mbed(mbed LPC1768)
LPCXpresso1769

プログラム

Import program MiMicRemoteMCU-for-Mbed

MiMic RemoteMCU for mbed. This program provides MCU control API over REST API. It can control MCU from Javascript,PHP or any HTTP rest client directly. And, The application has self development environment.

Import program MbedFileServer

The program publishes files at local directory and SD filesystem. It is a full-fledged webServer somewhat.

サンプル

Import program MiMicSimpleHttpd

This is a simplest HTTP server made of libMiMic. It will echo back a request path.

Import program UPnPBasicDevice

Simplest UPnP basic device example. This program to run UPnP basic device on the mbed.

Import program WebSocketSample

MiMicSDK Websocket module sample program.

Import program HttpClientSamlpe

A http client sample program.

Import program TcpSocketClientSamlpe

MiMicSDK Tcp client socket sample program.

Import program UdpSocketSamlpe

Udp socket sample program. This program will send back the received packet.

チュートリアル

English

libMiMic(MiMic library for mbed) is SDK which provides Webservice functions. It can be created networking device easily using mbed.

See more MiMic information, See MiMic project website. http://nyatla.jp/mimic/wp/

Structure

libMiMic run on mbed RTOS and provides networking API to user application. This library has C++ class API for the mbed, and low-level C language API.

/media/uploads/nyatla/libmimic-sdk.png

For WebService general, it can be written in a simple C + + API.

libMiMic does not have the standard Ethernet driver of mbed.　It is not possible that will be used with the standard Ethernet driver.

MiMicIP - IPv4 protocol stack. This is based uip which is reduced memory and latency.
ARP / ICMP / UDP / TCP - Those are provide basic IP protocols.
HTTP/1.1 Server - The Http server compatible HTTP/1.1. It supports multi-session, chunked transport, persistent connection.
HTTP Modules - There are addon-module for HTTP server. The following modules.
- ROM file module - Publish the file images in ROM.
- File system module - Publish thefiles in mbed file system.
- Onchip configuration module - To save the network settings to the program flash via REST.
- MiMicVM module - To handle the (MiMicVM) RPC request.
- FileUpload module - Accept a file via HTTP POST.
- URL dedoce module - A versatility URL decoder.
- UPnP handle module - To handle UPnP messages.
- UPnP - This provides UPnP/1.0 device functions. It works together with UPnP handler.
- Websocket - websocket (version13) server
mDNS Service - DNS-SD protocol server.
UPnP - This provides UPnP/1.0 device functions which works with UPnP handler. (You have been implemented (SSDP) ? description only (Description) device search now.) It is a module zero configuration for - DHCP / APIPA. mbed C + + class library - C of mbed for + + is the CPI. It is simple than that of the C language.
DHCP/APIPA - It support zero-cpnfigulation.
mbed C++ class library. Almost APIs for Web applications are available.
HTTP/1.1 Client

Supported target

mbed(mbed LPC1768)
LPCXpresso1769

Application

Import program MiMicRemoteMCU-for-Mbed

Import program MbedFileServer

The program publishes files at local directory and SD filesystem. It is a full-fledged webServer somewhat.

Tutorial

HTTPD hello world.
How to make own UPnP device.
MiMicRemoteMCUの紹介(pdf)
MiMicRemoteMCUのマニュアル(pdf)

core/netif/mimicip/NyLPC_cMiMicIpTcpSocket.c@110:257739f9b31e, 2015-03-15 (annotated)

Committer:: nyatla
Date:: Sun Mar 15 09:33:38 2015 +0000
Revision:: 110:257739f9b31e
Parent:: 109:18f12ac01097

51d1c88c8a56d6295311cfd20aa197a9cd650b2d; ????; NetworkInterface???????

Who changed what in which revision?

User	Revision	Line number	New contents of line
nyatla	109:18f12ac01097	1	/*********************************************************************************
nyatla	109:18f12ac01097	2	* PROJECT: MiMic
nyatla	109:18f12ac01097	3	* --------------------------------------------------------------------------------
nyatla	109:18f12ac01097	4	*
nyatla	109:18f12ac01097	5	* This file is part of MiMic
nyatla	109:18f12ac01097	6	* Copyright (C)2011 Ryo Iizuka
nyatla	109:18f12ac01097	7	*
nyatla	109:18f12ac01097	8	* MiMic is free software: you can redistribute it and/or modify
nyatla	109:18f12ac01097	9	* it under the terms of the GNU Lesser General Public License as published
nyatla	109:18f12ac01097	10	* by　the Free Software Foundation, either version 3 of the　License, or
nyatla	109:18f12ac01097	11	* (at your option) any later version.
nyatla	109:18f12ac01097	12	*
nyatla	109:18f12ac01097	13	* This program is distributed in the hope that it will be useful,
nyatla	109:18f12ac01097	14	* but WITHOUT ANY WARRANTY; without even the implied warranty of
nyatla	109:18f12ac01097	15	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
nyatla	109:18f12ac01097	16	* GNU General Public License for more details.
nyatla	109:18f12ac01097	17	*
nyatla	109:18f12ac01097	18	* You should have received a copy of the GNU Lesser General Public License
nyatla	109:18f12ac01097	19	* along with this program. If not, see <http://www.gnu.org/licenses/>.
nyatla	109:18f12ac01097	20	*
nyatla	109:18f12ac01097	21	* For further information please contact.
nyatla	109:18f12ac01097	22	* http://nyatla.jp/
nyatla	109:18f12ac01097	23	* <airmail(at)ebony.plala.or.jp> or <nyatla(at)nyatla.jp>
nyatla	109:18f12ac01097	24	*
nyatla	109:18f12ac01097	25	*********************************************************************************/
nyatla	109:18f12ac01097	26	#include "NyLPC_cMiMicIpTcpSocket_protected.h"
nyatla	109:18f12ac01097	27	#include "NyLPC_stdlib.h"
nyatla	109:18f12ac01097	28	#include "NyLPC_cMiMicIpNetIf_protected.h"
nyatla	109:18f12ac01097	29
nyatla	109:18f12ac01097	30
nyatla	109:18f12ac01097	31	static NyLPC_TUInt32 iss32=3939;
nyatla	109:18f12ac01097	32	#define SIZE_OF_IPv4_TCPIP_HEADER 40
nyatla	109:18f12ac01097	33
nyatla	109:18f12ac01097	34	/**
nyatla	109:18f12ac01097	35	* TCPのRTOの最大値。
nyatla	109:18f12ac01097	36	* ms単位である。
nyatla	109:18f12ac01097	37	* defaultは64SEC
nyatla	109:18f12ac01097	38	*/
nyatla	109:18f12ac01097	39	#define UIP_IP_RTO_MAX_RTO 64000
nyatla	109:18f12ac01097	40	/**
nyatla	109:18f12ac01097	41	* TCPのRTOの初期値。
nyatla	109:18f12ac01097	42	* ms単位である。
nyatla	109:18f12ac01097	43	* 伝送路の特性に合わせて調整すること。
nyatla	109:18f12ac01097	44	*/
nyatla	109:18f12ac01097	45	#define UIP_TCP_RTO_INITIAL 3000
nyatla	109:18f12ac01097	46
nyatla	109:18f12ac01097	47	/**
nyatla	109:18f12ac01097	48	* CONNECTION時のRTO
nyatla	109:18f12ac01097	49	*/
nyatla	109:18f12ac01097	50	#define UIP_TCP_RTO_CONNECTION_INITIAL 200
nyatla	109:18f12ac01097	51
nyatla	109:18f12ac01097	52	/**
nyatla	109:18f12ac01097	53	* 下限値
nyatla	109:18f12ac01097	54	*/
nyatla	109:18f12ac01097	55	#define UIP_TCP_RTO_MINIMUM 100
nyatla	109:18f12ac01097	56
nyatla	109:18f12ac01097	57
nyatla	109:18f12ac01097	58	/**
nyatla	109:18f12ac01097	59	* for Debug
nyatla	109:18f12ac01097	60	* RTOの情報をログ領域に取る。
nyatla	109:18f12ac01097	61	*/
nyatla	109:18f12ac01097	62	#ifdef RTO_LOG
nyatla	109:18f12ac01097	63	NyLPC_TUInt32 rto_log[256];
nyatla	109:18f12ac01097	64	int rto_log_st=0;
nyatla	109:18f12ac01097	65	#define DEBUG_RTO_LOG(i_inst) if(rto_log_st<256){rto_log[rto_log_st++]=i_inst->uip_connr.current_rto32;};
nyatla	109:18f12ac01097	66	#else
nyatla	109:18f12ac01097	67	#define DEBUG_RTO_LOG(i_inst)
nyatla	109:18f12ac01097	68	#endif
nyatla	109:18f12ac01097	69
nyatla	109:18f12ac01097	70	//#define lockResource(i_inst) NyLPC_cMutex_lock(&((i_inst)->_smutex))
nyatla	109:18f12ac01097	71	//#define unlockResource(i_inst) NyLPC_cMutex_unlock(&((i_inst)->_smutex))
nyatla	110:257739f9b31e	72	#define lockResource(i_inst) NyLPC_cMutex_lock(NyLPC_cIPv4_getSockMutex(((i_inst)->_parent_ipv4)))
nyatla	110:257739f9b31e	73	#define unlockResource(i_inst) NyLPC_cMutex_unlock(NyLPC_cIPv4_getSockMutex(((i_inst)->_parent_ipv4)))
nyatla	109:18f12ac01097	74
nyatla	109:18f12ac01097	75	static void sendRst(NyLPC_TcMiMicIpTcpSocket_t* i_inst);
nyatla	109:18f12ac01097	76
nyatla	109:18f12ac01097	77
nyatla	109:18f12ac01097	78
nyatla	109:18f12ac01097	79
nyatla	109:18f12ac01097	80	////////////////////////////////////////////////////////////////////////////////////////////////////
nyatla	109:18f12ac01097	81	//
nyatla	109:18f12ac01097	82	// Packet writer
nyatla	109:18f12ac01097	83	//
nyatla	109:18f12ac01097	84	////////////////////////////////////////////////////////////////////////////////////////////////////
nyatla	109:18f12ac01097	85
nyatla	109:18f12ac01097	86
nyatla	109:18f12ac01097	87	/**
nyatla	109:18f12ac01097	88	* TCPヘッダに値をセットする。checksum,wndは0初期化する。
nyatla	109:18f12ac01097	89	*/
nyatla	109:18f12ac01097	90	static void setTcpTxHeader(struct NyLPC_TTcpHeader* i_struct,NyLPC_TUInt8 i_flag,const struct uip_conn* i_conn)
nyatla	109:18f12ac01097	91	{
nyatla	109:18f12ac01097	92	i_struct->flags = i_flag;
nyatla	109:18f12ac01097	93	//sorce & destination port
nyatla	109:18f12ac01097	94	i_struct->srcport = i_conn->lport;
nyatla	109:18f12ac01097	95	i_struct->destport = i_conn->rport;
nyatla	109:18f12ac01097	96	//ACK number
nyatla	109:18f12ac01097	97	i_struct->ackno32 = NyLPC_htonl(i_conn->rcv_nxt32);
nyatla	109:18f12ac01097	98	//Seq Number
nyatla	109:18f12ac01097	99	i_struct->seqno32 = NyLPC_htonl(i_conn->snd_nxt32);
nyatla	109:18f12ac01097	100	//uip_func_tcp_send_noconn(BUF);
nyatla	109:18f12ac01097	101	i_struct->urgp[0] = i_struct->urgp[1] = 0;
nyatla	109:18f12ac01097	102	i_struct->tcpchksum= 0;
nyatla	109:18f12ac01097	103	}
nyatla	109:18f12ac01097	104
nyatla	109:18f12ac01097	105	static void setTxPacket(const NyLPC_TcMiMicIpTcpSocket_t* i_inst,void* i_tx_buf,NyLPC_TUInt8 i_tcpf,const void* i_buf,NyLPC_TUInt16 i_len)
nyatla	109:18f12ac01097	106	{
nyatla	109:18f12ac01097	107	struct NyLPC_TIPv4Header* iph;
nyatla	109:18f12ac01097	108	struct NyLPC_TTcpHeader* tcph;
nyatla	109:18f12ac01097	109	NyLPC_TUInt8 iph_word=0x05;
nyatla	109:18f12ac01097	110	NyLPC_TUInt8 tcph_word=(UIP_TCPH_LEN) / 4;
nyatla	109:18f12ac01097	111	//IPヘッダの更新
nyatla	109:18f12ac01097	112	iph=(struct NyLPC_TIPv4Header*)i_tx_buf;
nyatla	109:18f12ac01097	113	iph->vhl=0x40\|(0x0f&iph_word);
nyatla	109:18f12ac01097	114	iph->destipaddr=i_inst->uip_connr.ripaddr;
nyatla	109:18f12ac01097	115	iph->srcipaddr =*(i_inst->uip_connr.lipaddr);
nyatla	109:18f12ac01097	116	NyLPC_TIPv4Header_writeTxIpHeader(iph,UIP_PROTO_TCP);
nyatla	109:18f12ac01097	117	//TCPヘッダの更新
nyatla	109:18f12ac01097	118	tcph=(struct NyLPC_TTcpHeader)(((NyLPC_TUInt8)i_tx_buf)+NyLPC_TIPv4Header_getHeaderLength(iph));
nyatla	109:18f12ac01097	119
nyatla	109:18f12ac01097	120
nyatla	109:18f12ac01097	121	//SYNが有るならMSSの書き込み
nyatla	109:18f12ac01097	122	if((TCP_SYN & i_tcpf)){
nyatla	109:18f12ac01097	123	tcph_word+=((TCP_OPT_MSS_LEN) / 4);
nyatla	109:18f12ac01097	124	NyLPC_TTcpHeader_setMmsOpt(((NyLPC_TUInt8*)(tcph+1)),i_inst->uip_connr.default_mss);
nyatla	109:18f12ac01097	125	}
nyatla	109:18f12ac01097	126	tcph->tcpoffset=(tcph_word<<4);
nyatla	109:18f12ac01097	127	setTcpTxHeader(tcph,i_tcpf,&(i_inst->uip_connr));
nyatla	109:18f12ac01097	128
nyatla	109:18f12ac01097	129	//最終的なパケットサイズと必要ならペイロードを書き込み
nyatla	109:18f12ac01097	130	if(i_buf!=NULL){
nyatla	109:18f12ac01097	131	iph->len16=NyLPC_htons(i_len+(iph_word+tcph_word)*4);
nyatla	109:18f12ac01097	132	memcpy(((NyLPC_TUInt8)i_tx_buf)+((iph_word+tcph_word)4),i_buf,i_len);
nyatla	109:18f12ac01097	133	}else{
nyatla	109:18f12ac01097	134	iph->len16=NyLPC_htons((iph_word+tcph_word)*4);
nyatla	109:18f12ac01097	135	}
nyatla	109:18f12ac01097	136	//WND設定
nyatla	109:18f12ac01097	137	tcph->wnd16=NyLPC_htons(NyLPC_cFifoBuffer_getSpace(&(i_inst->rxbuf)));
nyatla	109:18f12ac01097	138	//Checksumの生成
nyatla	109:18f12ac01097	139	tcph->tcpchksum=~(NyLPC_TIPv4Header_makeTcpChecksum(iph));
nyatla	109:18f12ac01097	140	iph->ipchksum = ~(NyLPC_TIPv4Header_makeIpChecksum(iph));
nyatla	109:18f12ac01097	141	return;
nyatla	109:18f12ac01097	142	}
nyatla	109:18f12ac01097	143
nyatla	109:18f12ac01097	144	/**
nyatla	109:18f12ac01097	145	* IP/TCPヘッダが40バイト固定として、i_tx_buf+40の位置にあるペイロードに対するIP/TCPヘッダを書き込みます。
nyatla	109:18f12ac01097	146	*/
nyatla	109:18f12ac01097	147	static void setTxPacketHeader(const NyLPC_TcMiMicIpTcpSocket_t* i_inst,void* i_tx_buf,NyLPC_TUInt8 i_tcpf,NyLPC_TUInt16 i_len)
nyatla	109:18f12ac01097	148	{
nyatla	109:18f12ac01097	149	struct NyLPC_TIPv4Header* iph;
nyatla	109:18f12ac01097	150	struct NyLPC_TTcpHeader* tcph;
nyatla	109:18f12ac01097	151	NyLPC_TUInt8 iph_word=0x05;
nyatla	109:18f12ac01097	152	NyLPC_TUInt8 tcph_word=(UIP_TCPH_LEN) / 4;
nyatla	109:18f12ac01097	153	//IPヘッダの更新
nyatla	109:18f12ac01097	154	iph=(struct NyLPC_TIPv4Header*)i_tx_buf;
nyatla	109:18f12ac01097	155	iph->vhl=0x40\|(0x0f&iph_word);
nyatla	109:18f12ac01097	156	iph->destipaddr=i_inst->uip_connr.ripaddr;
nyatla	109:18f12ac01097	157	iph->srcipaddr =*(i_inst->uip_connr.lipaddr);
nyatla	109:18f12ac01097	158	NyLPC_TIPv4Header_writeTxIpHeader(iph,UIP_PROTO_TCP);
nyatla	109:18f12ac01097	159
nyatla	109:18f12ac01097	160	//TCPヘッダの更新
nyatla	109:18f12ac01097	161	tcph=(struct NyLPC_TTcpHeader)(((NyLPC_TUInt8)i_tx_buf)+NyLPC_TIPv4Header_getHeaderLength(iph));
nyatla	109:18f12ac01097	162	tcph->tcpoffset=(tcph_word<<4);
nyatla	109:18f12ac01097	163	setTcpTxHeader(tcph,i_tcpf,&(i_inst->uip_connr));
nyatla	109:18f12ac01097	164
nyatla	109:18f12ac01097	165	//最終的なパケットサイズと必要ならペイロードを書き込み
nyatla	109:18f12ac01097	166	iph->len16=NyLPC_htons(i_len+(iph_word+tcph_word)*4);
nyatla	109:18f12ac01097	167	//WND設定
nyatla	109:18f12ac01097	168	tcph->wnd16=NyLPC_htons(NyLPC_cFifoBuffer_getSpace(&(i_inst->rxbuf)));
nyatla	109:18f12ac01097	169	//Checksumの生成
nyatla	109:18f12ac01097	170	tcph->tcpchksum=~(NyLPC_TIPv4Header_makeTcpChecksum(iph));
nyatla	109:18f12ac01097	171	iph->ipchksum = ~(NyLPC_TIPv4Header_makeIpChecksum(iph));
nyatla	109:18f12ac01097	172	return;
nyatla	109:18f12ac01097	173	}
nyatla	109:18f12ac01097	174
nyatla	109:18f12ac01097	175
nyatla	109:18f12ac01097	176
nyatla	109:18f12ac01097	177
nyatla	109:18f12ac01097	178
nyatla	109:18f12ac01097	179	////////////////////////////////////////////////////////////////////////////////////////////////////
nyatla	109:18f12ac01097	180	//
nyatla	109:18f12ac01097	181	// Mainclass::private
nyatla	109:18f12ac01097	182	//
nyatla	109:18f12ac01097	183	////////////////////////////////////////////////////////////////////////////////////////////////////
nyatla	109:18f12ac01097	184
nyatla	109:18f12ac01097	185	/**
nyatla	109:18f12ac01097	186	* ACK番号を更新する。
nyatla	109:18f12ac01097	187	* @param i_ackno
nyatla	109:18f12ac01097	188	* ネットワークオーダーのACK番号
nyatla	109:18f12ac01097	189	*/
nyatla	109:18f12ac01097	190	static void updateAckNo(void* i_tx_buf,NyLPC_TUInt32 i_ackno)
nyatla	109:18f12ac01097	191	{
nyatla	109:18f12ac01097	192	struct NyLPC_TIPv4Header* iph=(struct NyLPC_TIPv4Header*)i_tx_buf;
nyatla	109:18f12ac01097	193	struct NyLPC_TTcpHeader* tcph=(struct NyLPC_TTcpHeader)(((NyLPC_TUInt8)i_tx_buf)+NyLPC_TIPv4Header_getHeaderLength(iph));
nyatla	109:18f12ac01097	194
nyatla	109:18f12ac01097	195	/* union{
nyatla	109:18f12ac01097	196	NyLPC_TUInt32 l;
nyatla	109:18f12ac01097	197	NyLPC_TUInt8 b[4];
nyatla	109:18f12ac01097	198	}old_ack,new_ack;
nyatla	109:18f12ac01097	199	NyLPC_TUInt16 v1;
nyatla	109:18f12ac01097	200	//checksumの計算
nyatla	109:18f12ac01097	201	old_ack.l=i_inst->payload.tcp->ackno32;//古いACK番号
nyatla	109:18f12ac01097	202	new_ack.l=i_ackno;//新しいACK番号
nyatla	109:18f12ac01097	203	v1=NyLPC_ntohs(~(i_inst->payload.tcp->tcpchksum));//1の補数を取って、ホストオーダーに戻す。
nyatla	109:18f12ac01097	204	//減算
nyatla	109:18f12ac01097	205	v1=sub16c(v1,(old_ack.b[0]<<8)+old_ack.b[1]);
nyatla	109:18f12ac01097	206	v1=sub16c(v1,(old_ack.b[2]<<8)+old_ack.b[3]);
nyatla	109:18f12ac01097	207	//加算
nyatla	109:18f12ac01097	208	v1=add16c(v1,(new_ack.b[0]<<8)+new_ack.b[1]);
nyatla	109:18f12ac01097	209	v1=add16c(v1,(new_ack.b[2]<<8)+new_ack.b[3]);
nyatla	109:18f12ac01097	210	v1=~NyLPC_htons(v1);*/
nyatla	109:18f12ac01097	211	NyLPC_Trace();
nyatla	109:18f12ac01097	212	tcph->ackno32=i_ackno;
nyatla	109:18f12ac01097	213	NyLPC_Trace();
nyatla	109:18f12ac01097	214	tcph->tcpchksum = 0;
nyatla	109:18f12ac01097	215	NyLPC_Trace();
nyatla	109:18f12ac01097	216	tcph->tcpchksum = ~(NyLPC_TIPv4Header_makeTcpChecksum(iph));
nyatla	109:18f12ac01097	217	NyLPC_Trace();
nyatla	109:18f12ac01097	218
nyatla	109:18f12ac01097	219	/*
nyatla	109:18f12ac01097	220	if((i_inst->payload.tcp->tcpchksum!=v1)){
nyatla	109:18f12ac01097	221	NyLPC_Warning();
nyatla	109:18f12ac01097	222	}*/
nyatla	109:18f12ac01097	223	}
nyatla	109:18f12ac01097	224
nyatla	109:18f12ac01097	225
nyatla	109:18f12ac01097	226
nyatla	109:18f12ac01097	227	/**
nyatla	109:18f12ac01097	228	* 指定した送信パケットがACK済であるか調べる。
nyatla	109:18f12ac01097	229	*/
nyatla	109:18f12ac01097	230	static NyLPC_TBool isPacketAcked(NyLPC_TcMiMicIpTcpSocket_t* i_inst,NyLPC_TUInt32 i_sq)
nyatla	109:18f12ac01097	231	{
nyatla	109:18f12ac01097	232	int rp;
nyatla	109:18f12ac01097	233	struct NyLPC_TcTcpSocket_TxQItem* q=i_inst->txbuf.txq;
nyatla	109:18f12ac01097	234	rp=i_inst->txbuf.rp;
nyatla	109:18f12ac01097	235	while(rp!=i_inst->txbuf.wp){
nyatla	109:18f12ac01097	236	if(q[rp].ackno==i_sq){
nyatla	109:18f12ac01097	237	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	238	}
nyatla	109:18f12ac01097	239	rp=(rp+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ;
nyatla	109:18f12ac01097	240	}
nyatla	109:18f12ac01097	241	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	242	}
nyatla	109:18f12ac01097	243	/**
nyatla	109:18f12ac01097	244	* 送信キューからi_sq以前に送信したパケットを除外して、残り個数を返却する。
nyatla	109:18f12ac01097	245	*/
nyatla	109:18f12ac01097	246	static int getNumOfSending(NyLPC_TcMiMicIpTcpSocket_t* i_inst,NyLPC_TUInt32 i_sq)
nyatla	109:18f12ac01097	247	{
nyatla	109:18f12ac01097	248	int rp,n;
nyatla	109:18f12ac01097	249	struct NyLPC_TcTcpSocket_TxQItem* q=i_inst->txbuf.txq;
nyatla	109:18f12ac01097	250	rp=i_inst->txbuf.rp;
nyatla	109:18f12ac01097	251	n=0;
nyatla	109:18f12ac01097	252	while(rp!=i_inst->txbuf.wp){
nyatla	109:18f12ac01097	253	if(q[rp].ackno==i_sq){
nyatla	109:18f12ac01097	254	return n;
nyatla	109:18f12ac01097	255	}
nyatla	109:18f12ac01097	256	n++;
nyatla	109:18f12ac01097	257	rp=(rp+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ;
nyatla	109:18f12ac01097	258	}
nyatla	109:18f12ac01097	259	return n;
nyatla	109:18f12ac01097	260	}
nyatla	109:18f12ac01097	261	/**
nyatla	109:18f12ac01097	262	* この関数は、コネクションをリセットします。
nyatla	109:18f12ac01097	263	* ロック状態でコールしてください。
nyatla	109:18f12ac01097	264	* 関数は、現在バッファにある再送信待ちデータを開放します。
nyatla	109:18f12ac01097	265	*/
nyatla	109:18f12ac01097	266	static void resetTxQWithUnlock(NyLPC_TcMiMicIpTcpSocket_t* i_inst)
nyatla	109:18f12ac01097	267	{
nyatla	109:18f12ac01097	268	int i,l;
nyatla	109:18f12ac01097	269	struct NyLPC_TcTcpSocket_TxQItem* q=i_inst->txbuf.txq;
nyatla	109:18f12ac01097	270	void* dlist[NyLPC_TcTcpSocket_NUMBER_OF_TXQ];
nyatla	109:18f12ac01097	271
nyatla	109:18f12ac01097	272	l=0;
nyatla	109:18f12ac01097	273	while(i_inst->txbuf.rp!=i_inst->txbuf.wp){
nyatla	109:18f12ac01097	274	dlist[l]=q[i_inst->txbuf.rp].packet;
nyatla	109:18f12ac01097	275	l++;
nyatla	109:18f12ac01097	276	i_inst->txbuf.rp=(i_inst->txbuf.rp+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ;
nyatla	109:18f12ac01097	277	}
nyatla	109:18f12ac01097	278	i_inst->txbuf.rp=i_inst->txbuf.wp=0;
nyatla	109:18f12ac01097	279	//ロック解除
nyatla	109:18f12ac01097	280	unlockResource(i_inst);
nyatla	109:18f12ac01097	281	//セーブしたバッファを開放
nyatla	109:18f12ac01097	282	for(i=0;i<l;i++){
nyatla	109:18f12ac01097	283	NyLPC_cMiMicIpNetIf_releaseTxBuf(dlist[i]);
nyatla	109:18f12ac01097	284	}
nyatla	109:18f12ac01097	285	return;
nyatla	109:18f12ac01097	286	}
nyatla	109:18f12ac01097	287	/**
nyatla	109:18f12ac01097	288	* TXバッファの再送パケットのACK番号を更新します。
nyatla	109:18f12ac01097	289	* ロックして実行してください。
nyatla	109:18f12ac01097	290	* @param i_ackno
nyatla	109:18f12ac01097	291	* ネットワークオーダーのACK番号
nyatla	109:18f12ac01097	292	*/
nyatla	109:18f12ac01097	293	static void updateTxAck(NyLPC_TcMiMicIpTcpSocket_t* i_inst,NyLPC_TUInt32 i_ackno)
nyatla	109:18f12ac01097	294	{
nyatla	109:18f12ac01097	295	NyLPC_TUInt8 rp;
nyatla	109:18f12ac01097	296	struct NyLPC_TcTcpSocket_TxQItem* q=i_inst->txbuf.txq;
nyatla	109:18f12ac01097	297	NyLPC_ArgAssert(i_inst!=NULL);
nyatla	109:18f12ac01097	298	rp=i_inst->txbuf.rp;
nyatla	109:18f12ac01097	299	while(rp!=i_inst->txbuf.wp){
nyatla	109:18f12ac01097	300	updateAckNo(q[rp].packet,i_ackno);
nyatla	109:18f12ac01097	301	rp=(rp+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ;
nyatla	109:18f12ac01097	302	}
nyatla	109:18f12ac01097	303	}
nyatla	109:18f12ac01097	304
nyatla	109:18f12ac01097	305	/**
nyatla	109:18f12ac01097	306	* RTOの予測関数
nyatla	109:18f12ac01097	307	*/
nyatla	109:18f12ac01097	308	static void estimateRTO(NyLPC_TcMiMicIpTcpSocket_t* i_inst,int s,int n)
nyatla	109:18f12ac01097	309	{
nyatla	109:18f12ac01097	310	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	311	NyLPC_TUInt32 cr_rtt_min,cr_rtt_max,sk_rto,new_rto,w;
nyatla	109:18f12ac01097	312	int i;
nyatla	109:18f12ac01097	313	struct NyLPC_TcTcpSocket_TxQItem* q=i_inst->txbuf.txq;
nyatla	109:18f12ac01097	314	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	315
nyatla	109:18f12ac01097	316	sk_rto=i_inst->uip_connr.current_rto32;
nyatla	109:18f12ac01097	317	//ACKされたパケットの個数は？
nyatla	109:18f12ac01097	318	switch(n){
nyatla	109:18f12ac01097	319	case 1:
nyatla	109:18f12ac01097	320	NyLPC_cStopwatch_set(&sw,q[s].tick_of_sent);
nyatla	109:18f12ac01097	321	cr_rtt_min=NyLPC_cStopwatch_elapseInMsec(&sw);
nyatla	109:18f12ac01097	322	if(sk_rto<cr_rtt_min){
nyatla	109:18f12ac01097	323	//現在のRTOよりも大きい→再送があった。(再送の理由が回線遅延によるものかわからないので、基本RTOを25%増やす。)
nyatla	109:18f12ac01097	324	new_rto=sk_rto*10/8;
nyatla	109:18f12ac01097	325	}else if(sk_rto/4<cr_rtt_min){
nyatla	109:18f12ac01097	326	//現在のRTOの1/4< n < 現在のRTO　想定内の変動。1/8
nyatla	109:18f12ac01097	327	new_rto=(sk_rto+(cr_rtt_min37))/8;
nyatla	109:18f12ac01097	328	}else{
nyatla	109:18f12ac01097	329	//現在の1/4以下。RTOを再計算。 RTOが大きすぎるので再計算。(計測値を優先した現在値との平均値)
nyatla	109:18f12ac01097	330	new_rto=(sk_rto+(cr_rtt_min33))/4;
nyatla	109:18f12ac01097	331	}
nyatla	109:18f12ac01097	332	break;
nyatla	109:18f12ac01097	333	default:
nyatla	109:18f12ac01097	334	//複数のパケットなら、最大と最小の時刻を得る。
nyatla	109:18f12ac01097	335	NyLPC_cStopwatch_set(&sw,q[s].tick_of_sent);
nyatla	109:18f12ac01097	336	cr_rtt_min=cr_rtt_max=NyLPC_cStopwatch_elapseInMsec(&sw);
nyatla	109:18f12ac01097	337	for(i=1;i<n;i++){
nyatla	109:18f12ac01097	338	NyLPC_cStopwatch_set(&sw,q[(s+i)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ].tick_of_sent);
nyatla	109:18f12ac01097	339	w=NyLPC_cStopwatch_elapseInMsec(&sw);
nyatla	109:18f12ac01097	340	if(cr_rtt_min>w){
nyatla	109:18f12ac01097	341	cr_rtt_min=w;
nyatla	109:18f12ac01097	342	}
nyatla	109:18f12ac01097	343	if(cr_rtt_max<w){
nyatla	109:18f12ac01097	344	cr_rtt_max=w;
nyatla	109:18f12ac01097	345	}
nyatla	109:18f12ac01097	346	}
nyatla	109:18f12ac01097	347	if(sk_rto<cr_rtt_min && sk_rto<cr_rtt_max){
nyatla	109:18f12ac01097	348	//最大値,最小値とも現在のRTTより大きい→低速な回線を検出。
nyatla	109:18f12ac01097	349	new_rto=cr_rtt_max*10/8;//最大経過時間の25%増しの時間を設定。
nyatla	109:18f12ac01097	350	}else if(sk_rto/4<cr_rtt_min){
nyatla	109:18f12ac01097	351	//現在のRTOの1/4< n < 現在のRTO 想定範囲内。1/8の加重平均で速度計算。
nyatla	109:18f12ac01097	352	new_rto=(sk_rto+(cr_rtt_min37))/8;
nyatla	109:18f12ac01097	353	}else{
nyatla	109:18f12ac01097	354	//現在の1/4以下。RTOが大きすぎるので再計算。(計測値を優先した加重平均)
nyatla	109:18f12ac01097	355	new_rto=(sk_rto+(cr_rtt_min33))/4;
nyatla	109:18f12ac01097	356	}
nyatla	109:18f12ac01097	357	break;
nyatla	109:18f12ac01097	358	}
nyatla	109:18f12ac01097	359	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	360	if(new_rto<UIP_TCP_RTO_MINIMUM){
nyatla	109:18f12ac01097	361	new_rto=UIP_TCP_RTO_MINIMUM;
nyatla	109:18f12ac01097	362	}
nyatla	109:18f12ac01097	363	i_inst->uip_connr.current_rto32=new_rto;
nyatla	109:18f12ac01097	364	}
nyatla	109:18f12ac01097	365
nyatla	109:18f12ac01097	366	/**
nyatla	109:18f12ac01097	367	* TXキューから、入力されたシーケンス番号より前のパケットを除外します。
nyatla	109:18f12ac01097	368	* リングバッファのrp->wp-1までをチェックして、sqに等しいi_sq以前のパケットバッファをo_dlistへ返します。
nyatla	109:18f12ac01097	369	*
nyatla	109:18f12ac01097	370	*/
nyatla	109:18f12ac01097	371	static int updateTxQByIndex(NyLPC_TcMiMicIpTcpSocket_t* i_inst,NyLPC_TUInt32 i_sq,void* o_dlist[])
nyatla	109:18f12ac01097	372	{
nyatla	109:18f12ac01097	373	int rp,n;
nyatla	109:18f12ac01097	374	struct NyLPC_TcTcpSocket_TxQItem* q=i_inst->txbuf.txq;
nyatla	109:18f12ac01097	375	//ロック状態なう
nyatla	109:18f12ac01097	376	rp=i_inst->txbuf.rp;
nyatla	109:18f12ac01097	377	n=0;
nyatla	109:18f12ac01097	378	//This is debug
nyatla	109:18f12ac01097	379	DEBUG_RTO_LOG(i_inst);
nyatla	109:18f12ac01097	380
nyatla	109:18f12ac01097	381	while(rp!=i_inst->txbuf.wp){
nyatla	109:18f12ac01097	382	o_dlist[n]=q[rp].packet;
nyatla	109:18f12ac01097	383	if(q[rp].ackno==i_sq){
nyatla	109:18f12ac01097	384	//i_inst->txbuf.rp->rpのパケットのRTOからbaseRTOの値を再計算。
nyatla	109:18f12ac01097	385	estimateRTO(i_inst,i_inst->txbuf.rp,n+1);
nyatla	109:18f12ac01097	386	i_inst->txbuf.rp=(rp+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ;
nyatla	109:18f12ac01097	387	return n+1;
nyatla	109:18f12ac01097	388	}
nyatla	109:18f12ac01097	389	n++;
nyatla	109:18f12ac01097	390	rp=(rp+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ;
nyatla	109:18f12ac01097	391	}
nyatla	109:18f12ac01097	392	return 0;
nyatla	109:18f12ac01097	393	}
nyatla	109:18f12ac01097	394
nyatla	109:18f12ac01097	395
nyatla	109:18f12ac01097	396
nyatla	109:18f12ac01097	397	/**
nyatla	109:18f12ac01097	398	* 空きキューを1個返します。
nyatla	109:18f12ac01097	399	* 空きキューの
nyatla	109:18f12ac01097	400	*/
nyatla	109:18f12ac01097	401	static struct NyLPC_TcTcpSocket_TxQItem* getTxQ(NyLPC_TcMiMicIpTcpSocket_t* i_inst,NyLPC_TcStopwatch_t* i_timer)
nyatla	109:18f12ac01097	402	{
nyatla	109:18f12ac01097	403	int i;
nyatla	109:18f12ac01097	404	struct NyLPC_TcTcpSocket_TxQItem* q=i_inst->txbuf.txq;
nyatla	109:18f12ac01097	405	do{
nyatla	109:18f12ac01097	406	//クローズドに遷移してしまったら、エラーである。
nyatla	109:18f12ac01097	407	if(i_inst->tcpstateflags==UIP_CLOSED){
nyatla	109:18f12ac01097	408	return NULL;
nyatla	109:18f12ac01097	409	}
nyatla	109:18f12ac01097	410	//キューの空きをチェック。wp+1==rpなら、キューがいっぱい。rp==wpなら、キューが空。
nyatla	109:18f12ac01097	411	if(((i_inst->txbuf.wp+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ)==i_inst->txbuf.rp){
nyatla	109:18f12ac01097	412	//一時的なアンロック
nyatla	109:18f12ac01097	413	unlockResource(i_inst);
nyatla	109:18f12ac01097	414	//タスクスイッチ
nyatla	109:18f12ac01097	415	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	416	//ロック
nyatla	109:18f12ac01097	417	lockResource(i_inst);
nyatla	109:18f12ac01097	418	continue;
nyatla	109:18f12ac01097	419	}
nyatla	109:18f12ac01097	420	i=i_inst->txbuf.wp;
nyatla	109:18f12ac01097	421	i_inst->txbuf.wp=(i+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ;
nyatla	109:18f12ac01097	422	return &(q[i]);
nyatla	109:18f12ac01097	423	}while(!NyLPC_cStopwatch_isExpired(i_timer));
nyatla	109:18f12ac01097	424	//失敗。タイムアウト。
nyatla	109:18f12ac01097	425	return NULL;
nyatla	109:18f12ac01097	426	}
nyatla	109:18f12ac01097	427
nyatla	109:18f12ac01097	428
nyatla	109:18f12ac01097	429
nyatla	109:18f12ac01097	430
nyatla	109:18f12ac01097	431
nyatla	109:18f12ac01097	432
nyatla	109:18f12ac01097	433	/**********************************************************************
nyatla	109:18f12ac01097	434	* public 関数
nyatla	109:18f12ac01097	435	**********************************************************************/
nyatla	109:18f12ac01097	436	static const struct NyLPC_TIPv4Addr* getPeerAddr(const NyLPC_TiTcpSocket_t* i_inst);
nyatla	109:18f12ac01097	437	static NyLPC_TUInt16 getPeerPort(const NyLPC_TiTcpSocket_t* i_inst);
nyatla	109:18f12ac01097	438	static NyLPC_TBool accept(NyLPC_TiTcpSocket_t* i_inst,NyLPC_TUInt32 i_wait_in_msec);
nyatla	109:18f12ac01097	439	static NyLPC_TInt32 precv(NyLPC_TiTcpSocket_t* i_inst,const void** o_buf_ptr,NyLPC_TUInt32 i_wait_msec);
nyatla	109:18f12ac01097	440	static void pseek(NyLPC_TiTcpSocket_t* i_inst,NyLPC_TUInt16 i_seek);
nyatla	109:18f12ac01097	441	static NyLPC_TInt32 send(NyLPC_TiTcpSocket_t* i_inst,const void* i_buf_ptr,NyLPC_TInt32 i_len,NyLPC_TUInt32 i_wait_in_msec);
nyatla	109:18f12ac01097	442	static void close(NyLPC_TiTcpSocket_t* i_inst,NyLPC_TUInt32 i_wait_in_msec);
nyatla	109:18f12ac01097	443	static void* allocSendBuf(NyLPC_TiTcpSocket_t* i_inst,NyLPC_TUInt16 i_hint,NyLPC_TUInt16* o_buf_size,NyLPC_TUInt32 i_wait_in_msec);
nyatla	109:18f12ac01097	444	static void releaseSendBuf(NyLPC_TiTcpSocket_t* i_inst,void* i_buf_ptr);
nyatla	109:18f12ac01097	445	static NyLPC_TBool psend(NyLPC_TiTcpSocket_t* i_inst,void* i_buf_ptr,int i_len,NyLPC_TUInt32 i_wait_in_msec);
nyatla	109:18f12ac01097	446	static NyLPC_TBool connect(NyLPC_TiTcpSocket_t* i_inst,const struct NyLPC_TIPv4Addr* i_addr,NyLPC_TUInt16 i_peer_port,NyLPC_TUInt32 i_wait_in_msec);
nyatla	109:18f12ac01097	447	static void finalize(NyLPC_TiTcpSocket_t* i_inst);
nyatla	109:18f12ac01097	448
nyatla	109:18f12ac01097	449	const static struct NyLPC_TiTcpSocket_Interface _interface=
nyatla	109:18f12ac01097	450	{
nyatla	109:18f12ac01097	451	getPeerAddr,
nyatla	109:18f12ac01097	452	getPeerPort,
nyatla	109:18f12ac01097	453	accept,
nyatla	109:18f12ac01097	454	precv,
nyatla	109:18f12ac01097	455	pseek,
nyatla	109:18f12ac01097	456	send,
nyatla	109:18f12ac01097	457	close,
nyatla	109:18f12ac01097	458	allocSendBuf,
nyatla	109:18f12ac01097	459	releaseSendBuf,
nyatla	109:18f12ac01097	460	psend,
nyatla	109:18f12ac01097	461	connect,
nyatla	109:18f12ac01097	462	finalize
nyatla	109:18f12ac01097	463	};
nyatla	109:18f12ac01097	464
nyatla	109:18f12ac01097	465	static const struct NyLPC_TIPv4Addr* getPeerAddr(const NyLPC_TiTcpSocket_t* i_inst)
nyatla	109:18f12ac01097	466	{
nyatla	109:18f12ac01097	467	const NyLPC_TcMiMicIpTcpSocket_t* inst=(const NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	468	return &inst->uip_connr.ripaddr;
nyatla	109:18f12ac01097	469	}
nyatla	109:18f12ac01097	470	static NyLPC_TUInt16 getPeerPort(const NyLPC_TiTcpSocket_t* i_inst)
nyatla	109:18f12ac01097	471	{
nyatla	109:18f12ac01097	472	const NyLPC_TcMiMicIpTcpSocket_t* inst=(const NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	473	return inst->uip_connr.rport;
nyatla	109:18f12ac01097	474	}
nyatla	109:18f12ac01097	475
nyatla	109:18f12ac01097	476
nyatla	109:18f12ac01097	477
nyatla	109:18f12ac01097	478
nyatla	109:18f12ac01097	479	NyLPC_TBool NyLPC_cMiMicIpTcpSocket_initialize(NyLPC_TcMiMicIpTcpSocket_t* i_inst,void* i_rbuf,NyLPC_TUInt16 i_rbuf_len)
nyatla	109:18f12ac01097	480	{
nyatla	109:18f12ac01097	481	int i;
nyatla	109:18f12ac01097	482	NyLPC_TcMiMicIpNetIf_t* srv=_NyLPC_TcMiMicIpNetIf_inst;
nyatla	110:257739f9b31e	483	i_inst->_super._interface=&_interface;
nyatla	110:257739f9b31e	484	i_inst->_parent_ipv4=&srv->_tcpv4;
nyatla	110:257739f9b31e	485
nyatla	109:18f12ac01097	486	//uipサービスは初期化済であること。
nyatla	109:18f12ac01097	487	NyLPC_Assert(NyLPC_cMiMicIpNetIf_isInitService());
nyatla	109:18f12ac01097	488
nyatla	109:18f12ac01097	489	NyLPC_cFifoBuffer_initialize(&(i_inst->rxbuf),i_rbuf,i_rbuf_len);
nyatla	109:18f12ac01097	490	// NyLPC_AbortIfNot(NyLPC_cMutex_initialize(&(i_inst->_smutex)));//個別Mutex
nyatla	109:18f12ac01097	491	// i_inst->_smutex=NyLPC_cIPv4_getSockMutex(&(srv->_tcpv4));//共有Mutex
nyatla	109:18f12ac01097	492	i_inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	493	i_inst->txbuf.rp=i_inst->txbuf.wp=0;
nyatla	109:18f12ac01097	494	for(i=0;i<NyLPC_TcTcpSocket_NUMBER_OF_TXQ;i++){
nyatla	109:18f12ac01097	495	i_inst->txbuf.txq[i].packet=NULL;
nyatla	109:18f12ac01097	496	}
nyatla	109:18f12ac01097	497	//管理リストへ登録。
nyatla	110:257739f9b31e	498	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	499	}
nyatla	109:18f12ac01097	500
nyatla	109:18f12ac01097	501
nyatla	109:18f12ac01097	502
nyatla	109:18f12ac01097	503	NyLPC_TBool NyLPC_cMiMicIpTcpSocket_listenSyn(NyLPC_TcMiMicIpTcpSocket_t* i_inst,const struct NyLPC_TTcpSocketSynParam* i_lq,NyLPC_TUInt16 i_lport)
nyatla	109:18f12ac01097	504	{
nyatla	109:18f12ac01097	505	// NyLPC_Assert(NyLPC_cMutex_isLocked(i_inst->_smutex));
nyatla	109:18f12ac01097	506	lockResource(i_inst);
nyatla	109:18f12ac01097	507	//ソケットが無効であること。
nyatla	109:18f12ac01097	508	if(i_inst->tcpstateflags==UIP_CLOSED)
nyatla	109:18f12ac01097	509	{
nyatla	109:18f12ac01097	510	//localipとdefault_mmsは別枠で設定
nyatla	109:18f12ac01097	511	/* Fill in the necessary fields for the new connection. */
nyatla	109:18f12ac01097	512	i_inst->uip_connr.current_rto32 = UIP_TCP_RTO_INITIAL;
nyatla	109:18f12ac01097	513	i_inst->uip_connr.lport = i_lport;
nyatla	109:18f12ac01097	514	i_inst->uip_connr.rport = i_lq->rport;
nyatla	109:18f12ac01097	515	i_inst->uip_connr.ripaddr=i_lq->srcaddr;
nyatla	109:18f12ac01097	516	i_inst->uip_connr.snd_nxt32=iss32;
nyatla	109:18f12ac01097	517	/* rcv_nxt should be the seqno from the incoming packet + 1. */
nyatla	109:18f12ac01097	518	i_inst->uip_connr.rcv_nxt32= i_lq->rcv_nxt32;
nyatla	109:18f12ac01097	519	//MSSの設定
nyatla	109:18f12ac01097	520	i_inst->uip_connr.peer_mss=(i_lq->mss!=0)?i_lq->mss:i_inst->uip_connr.default_mss;
nyatla	109:18f12ac01097	521	i_inst->uip_connr.peer_win=0;
nyatla	109:18f12ac01097	522	NyLPC_cFifoBuffer_clear(&(i_inst->rxbuf));
nyatla	109:18f12ac01097	523	//ここでステータスがかわる。
nyatla	109:18f12ac01097	524	i_inst->tcpstateflags = UIP_SYN_RCVD;
nyatla	109:18f12ac01097	525	//前回のデータが残っていた場合の保険
nyatla	109:18f12ac01097	526	if(i_inst->txbuf.rp!=i_inst->txbuf.wp){
nyatla	109:18f12ac01097	527	resetTxQWithUnlock(i_inst);
nyatla	109:18f12ac01097	528	}else{
nyatla	109:18f12ac01097	529	unlockResource(i_inst);
nyatla	109:18f12ac01097	530	}
nyatla	109:18f12ac01097	531	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	532	}
nyatla	109:18f12ac01097	533	unlockResource(i_inst);
nyatla	109:18f12ac01097	534	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	535	}
nyatla	109:18f12ac01097	536
nyatla	109:18f12ac01097	537
nyatla	109:18f12ac01097	538	/**
nyatla	109:18f12ac01097	539	* sq番のTxがキューから消え去るのを待ちます。
nyatla	109:18f12ac01097	540	* この関数は、アンロック状態でコールしてください。
nyatla	109:18f12ac01097	541	* <div>
nyatla	109:18f12ac01097	542	* パケットがキューからなくなる条件は、以下の２つです。
nyatla	109:18f12ac01097	543	* <ul>
nyatla	109:18f12ac01097	544	* <li>ACKを受信してパケットキューが更新された。</li>
nyatla	109:18f12ac01097	545	* <li>RSTを受信して(CLOSEDに遷移して)、キューがクリアされた。</li>
nyatla	109:18f12ac01097	546	* <li>送信タイムアウトで関数が(CLOSEDに遷移させて)キューをクリアした。</li>
nyatla	109:18f12ac01097	547	* </ul>
nyatla	109:18f12ac01097	548	* </div>
nyatla	109:18f12ac01097	549	* @param i_wait_msec
nyatla	109:18f12ac01097	550	* @return
nyatla	109:18f12ac01097	551	* 1番目の条件でパケットが消失したときのみ、TRUEを返します。
nyatla	109:18f12ac01097	552	* 失敗した場合、TCPステータスがCLOSEDでなければ、RSTを送信してステータスをCLOSEDにします。
nyatla	109:18f12ac01097	553	*/
nyatla	109:18f12ac01097	554	static NyLPC_TBool waitForTxRemove(NyLPC_TcMiMicIpTcpSocket_t* i_inst,NyLPC_TUInt32 i_sq,NyLPC_TcStopwatch_t* i_timer)
nyatla	109:18f12ac01097	555	{
nyatla	109:18f12ac01097	556	NyLPC_TUInt8 f;
nyatla	109:18f12ac01097	557	lockResource(i_inst);
nyatla	109:18f12ac01097	558	do{
nyatla	109:18f12ac01097	559	//パケットが送信中か調べる。
nyatla	109:18f12ac01097	560	if(!isPacketAcked(i_inst,i_sq)){
nyatla	109:18f12ac01097	561	//まだある場合は、タスクスイッチを繰り返して消失を待つ。
nyatla	109:18f12ac01097	562	unlockResource(i_inst);
nyatla	109:18f12ac01097	563	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	564	lockResource(i_inst);
nyatla	109:18f12ac01097	565	continue;
nyatla	109:18f12ac01097	566	}
nyatla	109:18f12ac01097	567	//なくなった場合は、原因を調べる。
nyatla	109:18f12ac01097	568	f=i_inst->tcpstateflags;
nyatla	109:18f12ac01097	569	unlockResource(i_inst);
nyatla	109:18f12ac01097	570	return (f==UIP_CLOSED)?NyLPC_TBool_FALSE:NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	571	}while(!NyLPC_cStopwatch_isExpired(i_timer));
nyatla	109:18f12ac01097	572	unlockResource(i_inst);
nyatla	109:18f12ac01097	573	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	574	}
nyatla	109:18f12ac01097	575
nyatla	109:18f12ac01097	576
nyatla	109:18f12ac01097	577	/**
nyatla	109:18f12ac01097	578	* 再送信処理をセットして、パケットを送信します。
nyatla	109:18f12ac01097	579	* この関数は「アンロック状態で」実行してください。
nyatla	109:18f12ac01097	580	* @param i_len
nyatla	109:18f12ac01097	581	* 送信データサイズを指定します。
nyatla	109:18f12ac01097	582	* この番号は、シーケンス番号の加算値ではありませんので、注意をしてください。
nyatla	109:18f12ac01097	583	* @return
nyatla	109:18f12ac01097	584	* <ul>
nyatla	109:18f12ac01097	585	* <li>n=-1:送信キューへの投入に失敗した。</li>
nyatla	109:18f12ac01097	586	* <li>n>=0:nバイトのデータを送信キューへの投入することに成功した。</li>
nyatla	109:18f12ac01097	587	* </ul>
nyatla	109:18f12ac01097	588	* 送信キューに失敗する理由は2つあります。1つは、TXバッファがフルでタイムアウト。もうひとつは、非同期なコネクリョンのリセットです。
nyatla	109:18f12ac01097	589	* 失敗した場合、TCPステータスがCLOSEDでなければ、RSTを送信してステータスをCLOSEDにします。
nyatla	109:18f12ac01097	590	*/
nyatla	109:18f12ac01097	591	static NyLPC_TInt32 sendWithRetransmit(NyLPC_TcMiMicIpTcpSocket_t* i_inst,NyLPC_TUInt8 i_tcpf,const void* i_buf,NyLPC_TUInt16 i_len,NyLPC_TcStopwatch_t* i_timer,NyLPC_TUInt32* o_ack)
nyatla	109:18f12ac01097	592	{
nyatla	109:18f12ac01097	593	struct NyLPC_TcTcpSocket_TxQItem* txq;
nyatla	109:18f12ac01097	594	NyLPC_TUInt16 s;
nyatla	109:18f12ac01097	595	void* buf;
nyatla	109:18f12ac01097	596	NyLPC_TUInt32 next_ack;
nyatla	109:18f12ac01097	597	//送信バッファを取得
nyatla	109:18f12ac01097	598	//@bug オブションパケット送信時に4バイト足りないメモリ要求しない？問題になってないけど。
nyatla	109:18f12ac01097	599	for(;;){
nyatla	109:18f12ac01097	600	buf=NyLPC_cMiMicIpNetIf_allocTxBuf(i_len+(SIZE_OF_IPv4_TCPIP_HEADER),&s);
nyatla	109:18f12ac01097	601	if(buf!=NULL){
nyatla	109:18f12ac01097	602	break;
nyatla	109:18f12ac01097	603	}
nyatla	109:18f12ac01097	604	//タイムアウト確認
nyatla	109:18f12ac01097	605	if(NyLPC_cStopwatch_isExpired(i_timer)){
nyatla	109:18f12ac01097	606	return -1;
nyatla	109:18f12ac01097	607	}
nyatla	109:18f12ac01097	608	};
nyatla	109:18f12ac01097	609	lockResource(i_inst);
nyatla	109:18f12ac01097	610	//ペイロードがある場合のみ、相手のwindowサイズが0以上になるのを待つ。
nyatla	109:18f12ac01097	611	if(i_len>0){
nyatla	109:18f12ac01097	612	while(i_inst->uip_connr.peer_win==0){
nyatla	109:18f12ac01097	613	unlockResource(i_inst);
nyatla	109:18f12ac01097	614	//時間切れならエラー。
nyatla	109:18f12ac01097	615	if(NyLPC_cStopwatch_isExpired(i_timer)){
nyatla	109:18f12ac01097	616	return -1;
nyatla	109:18f12ac01097	617	}
nyatla	109:18f12ac01097	618	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	619	lockResource(i_inst);
nyatla	109:18f12ac01097	620	}
nyatla	109:18f12ac01097	621	}
nyatla	109:18f12ac01097	622	//送信キューの取得
nyatla	109:18f12ac01097	623	txq=getTxQ(i_inst,i_timer);
nyatla	109:18f12ac01097	624	//送信キューが取れなかった。
nyatla	109:18f12ac01097	625	if(txq==NULL){
nyatla	109:18f12ac01097	626	//シーケンス番号をロールバックできないので、エラーとする。
nyatla	109:18f12ac01097	627	unlockResource(i_inst);
nyatla	109:18f12ac01097	628	NyLPC_cMiMicIpNetIf_releaseTxBuf(buf);
nyatla	109:18f12ac01097	629	return -1;
nyatla	109:18f12ac01097	630	}
nyatla	109:18f12ac01097	631
nyatla	109:18f12ac01097	632	//送信バッファを基準とした送信サイズを計算
nyatla	109:18f12ac01097	633	s-=SIZE_OF_IPv4_TCPIP_HEADER;
nyatla	109:18f12ac01097	634	//送信サイズよりMMSが小さければ、送信サイズを修正
nyatla	109:18f12ac01097	635	if(i_inst->uip_connr.peer_mss<s){
nyatla	109:18f12ac01097	636	s=i_inst->uip_connr.peer_mss;
nyatla	109:18f12ac01097	637	}
nyatla	109:18f12ac01097	638	//送信サイズよりpeerのウインドウサイズが小さければ修正
nyatla	109:18f12ac01097	639	if(i_inst->uip_connr.peer_win<s){
nyatla	109:18f12ac01097	640	s=i_inst->uip_connr.peer_win;
nyatla	109:18f12ac01097	641	}
nyatla	109:18f12ac01097	642	//送信サイズより、データサイズが小さければ、送信サイズを修正
nyatla	109:18f12ac01097	643	if(i_len<s){
nyatla	109:18f12ac01097	644	s=i_len;
nyatla	109:18f12ac01097	645	}
nyatla	109:18f12ac01097	646	//ACK番号の計算
nyatla	109:18f12ac01097	647	next_ack=i_inst->uip_connr.snd_nxt32+s+(((i_tcpf&(TCP_FIN\|TCP_SYN))!=0x00)?1:0);
nyatla	109:18f12ac01097	648	txq->rto32=i_inst->uip_connr.current_rto32;
nyatla	109:18f12ac01097	649	txq->tick_of_sent=NyLPC_cStopwatch_now();
nyatla	109:18f12ac01097	650
nyatla	109:18f12ac01097	651	//パケットの書き込み
nyatla	109:18f12ac01097	652	setTxPacket(i_inst,buf,i_tcpf,i_buf,s);
nyatla	109:18f12ac01097	653	txq->packet=buf;
nyatla	109:18f12ac01097	654
nyatla	109:18f12ac01097	655	//シーケンス番号の更新
nyatla	109:18f12ac01097	656	i_inst->uip_connr.snd_nxt32=next_ack;
nyatla	109:18f12ac01097	657	//Peerのウインドウサイズを更新
nyatla	109:18f12ac01097	658	i_inst->uip_connr.peer_win-=s;
nyatla	109:18f12ac01097	659	//ACK番号の返却
nyatla	109:18f12ac01097	660	*o_ack=txq->ackno=NyLPC_HTONL(next_ack);
nyatla	109:18f12ac01097	661	unlockResource(i_inst);
nyatla	109:18f12ac01097	662	NyLPC_cMiMicIpNetIf_sendIPv4Tx(buf);
nyatla	109:18f12ac01097	663	return s;
nyatla	109:18f12ac01097	664	}
nyatla	109:18f12ac01097	665	/**
nyatla	109:18f12ac01097	666	* RSTを1フレームだけ送信します。
nyatla	109:18f12ac01097	667	* この関数は、クローズドステータスのソケットにしてからコールします。
nyatla	109:18f12ac01097	668	* この関数は、アンロック状態でコールしてね。
nyatla	109:18f12ac01097	669	*/
nyatla	109:18f12ac01097	670	static void sendRst(NyLPC_TcMiMicIpTcpSocket_t* i_inst)
nyatla	109:18f12ac01097	671	{
nyatla	109:18f12ac01097	672	void* buf;
nyatla	109:18f12ac01097	673
nyatla	109:18f12ac01097	674	NyLPC_Assert(i_inst->tcpstateflags==UIP_CLOSED);
nyatla	109:18f12ac01097	675	//ペイロードライタの初期化
nyatla	109:18f12ac01097	676
nyatla	109:18f12ac01097	677	//@bug バッファが取れるまで通信がブロックするの。ここはなんとかしないと。
nyatla	109:18f12ac01097	678	buf=NyLPC_cMiMicIpNetIf_allocSysTxBuf();
nyatla	109:18f12ac01097	679	lockResource(i_inst);
nyatla	109:18f12ac01097	680	i_inst->uip_connr.snd_nxt32++;
nyatla	109:18f12ac01097	681	unlockResource(i_inst);
nyatla	109:18f12ac01097	682	setTxPacket(i_inst,buf,TCP_RST\|TCP_ACK,NULL,0);
nyatla	109:18f12ac01097	683	NyLPC_cMiMicIpNetIf_sendIPv4Tx(buf);
nyatla	109:18f12ac01097	684	NyLPC_cMiMicIpNetIf_releaseTxBuf(buf);
nyatla	109:18f12ac01097	685	NyLPC_cIPv4Payload_finalize(&ipv4);
nyatla	109:18f12ac01097	686	return;
nyatla	109:18f12ac01097	687	}
nyatla	109:18f12ac01097	688
nyatla	109:18f12ac01097	689
nyatla	109:18f12ac01097	690
nyatla	109:18f12ac01097	691	/**
nyatla	109:18f12ac01097	692	* 受信データをバッファに書き込む。
nyatla	109:18f12ac01097	693	* 十分な空き領域がない場合、失敗する。
nyatla	109:18f12ac01097	694	* この関数は、ロックして実行してください。
nyatla	109:18f12ac01097	695	*/
nyatla	109:18f12ac01097	696	static NyLPC_TBool addRecvData(NyLPC_TcMiMicIpTcpSocket_t* i_inst,const void* i_data,NyLPC_TUInt16 i_data_size)
nyatla	109:18f12ac01097	697	{
nyatla	109:18f12ac01097	698	//受信データサイズを確認
nyatla	109:18f12ac01097	699	if(NyLPC_cFifoBuffer_getSpace(&(i_inst->rxbuf))>=i_data_size){
nyatla	109:18f12ac01097	700	//バッファに格納可能なら、格納。
nyatla	109:18f12ac01097	701	NyLPC_cFifoBuffer_push(&(i_inst->rxbuf),i_data,i_data_size);
nyatla	109:18f12ac01097	702	}else{
nyatla	109:18f12ac01097	703	//エラー:ドロップする。
nyatla	109:18f12ac01097	704	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	705	}
nyatla	109:18f12ac01097	706
nyatla	109:18f12ac01097	707	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	708	}
nyatla	109:18f12ac01097	709
nyatla	109:18f12ac01097	710
nyatla	109:18f12ac01097	711
nyatla	109:18f12ac01097	712
nyatla	109:18f12ac01097	713
nyatla	109:18f12ac01097	714	/**
nyatla	109:18f12ac01097	715	* Public function
nyatla	109:18f12ac01097	716	*/
nyatla	109:18f12ac01097	717	static void finalize(NyLPC_TiTcpSocket_t* i_inst)
nyatla	109:18f12ac01097	718	{
nyatla	109:18f12ac01097	719	int i;
nyatla	109:18f12ac01097	720	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	721	NyLPC_Assert(NyLPC_cMiMicIpNetIf_isInitService());
nyatla	109:18f12ac01097	722	//開放漏れの保険
nyatla	109:18f12ac01097	723	if(inst->txbuf.rp!=inst->txbuf.wp){
nyatla	109:18f12ac01097	724	lockResource(inst);
nyatla	109:18f12ac01097	725	resetTxQWithUnlock(inst);
nyatla	109:18f12ac01097	726	}
nyatla	109:18f12ac01097	727	for(i=0;i<NyLPC_TcTcpSocket_NUMBER_OF_TXQ;i++){
nyatla	109:18f12ac01097	728	inst->txbuf.txq[i].packet=NULL;
nyatla	109:18f12ac01097	729	}
nyatla	109:18f12ac01097	730	NyLPC_cFifoBuffer_finalize(&(inst->rxbuf));
nyatla	109:18f12ac01097	731	// NyLPC_cMutex_finalize(&(i_inst->_smutex));
nyatla	109:18f12ac01097	732	NyLPC_cMiMicIpNetIf_releaseTcpSocketMemory(inst);
nyatla	109:18f12ac01097	733
nyatla	109:18f12ac01097	734	return;
nyatla	109:18f12ac01097	735	}
nyatla	109:18f12ac01097	736
nyatla	109:18f12ac01097	737	static NyLPC_TBool connect(NyLPC_TiTcpSocket_t* i_inst,const struct NyLPC_TIPv4Addr* i_addr,NyLPC_TUInt16 i_peer_port,NyLPC_TUInt32 i_wait_in_msec)
nyatla	109:18f12ac01097	738	{
nyatla	109:18f12ac01097	739	volatile NyLPC_TUInt8 f;
nyatla	109:18f12ac01097	740	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	741	NyLPC_TUInt32 sq;
nyatla	109:18f12ac01097	742	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	743	NyLPC_TUInt16 lport;
nyatla	109:18f12ac01097	744	lockResource(inst);
nyatla	109:18f12ac01097	745	//ソケットが無効であること。
nyatla	109:18f12ac01097	746	if(inst->tcpstateflags!=UIP_CLOSED)
nyatla	109:18f12ac01097	747	{
nyatla	109:18f12ac01097	748	NyLPC_OnErrorGoto(Error);
nyatla	109:18f12ac01097	749	}
nyatla	109:18f12ac01097	750	//ポート番号の取得(lockResourceが他のソケットと共有なので、重複ポートの割当は起こりえない。でもちょっと注意して)
nyatla	110:257739f9b31e	751	lport=NyLPC_htons(NyLPC_cIPv4_getNewPortNumber(inst->_parent_ipv4));
nyatla	109:18f12ac01097	752	if(lport==0){
nyatla	109:18f12ac01097	753	NyLPC_OnErrorGoto(Error);
nyatla	109:18f12ac01097	754	}
nyatla	109:18f12ac01097	755	//connectの為の準備
nyatla	109:18f12ac01097	756
nyatla	109:18f12ac01097	757	//localipとdefault_mmsは別枠で設定
nyatla	109:18f12ac01097	758	/* Fill in the necessary fields for the new connection. */
nyatla	109:18f12ac01097	759	inst->uip_connr.current_rto32 = UIP_TCP_RTO_CONNECTION_INITIAL;//RTOを短くしてARP発行時の再接続短縮を期待する。
nyatla	109:18f12ac01097	760	inst->uip_connr.lport = lport;
nyatla	109:18f12ac01097	761	inst->uip_connr.rport = NyLPC_htons(i_peer_port);
nyatla	109:18f12ac01097	762	inst->uip_connr.ripaddr=*i_addr;
nyatla	109:18f12ac01097	763	inst->uip_connr.snd_nxt32=iss32;//should be random
nyatla	109:18f12ac01097	764	/* rcv_nxt should be the seqno from the incoming packet + 1. */
nyatla	109:18f12ac01097	765	inst->uip_connr.rcv_nxt32=0;
nyatla	109:18f12ac01097	766	//MSSの設定
nyatla	109:18f12ac01097	767	inst->uip_connr.peer_mss=inst->uip_connr.default_mss;
nyatla	109:18f12ac01097	768	inst->uip_connr.peer_win=1;//periodicの再送信を期待するために相手のWindowサイズは1と仮定する。
nyatla	109:18f12ac01097	769	NyLPC_cFifoBuffer_clear(&(inst->rxbuf));
nyatla	109:18f12ac01097	770	//ここでステータスがかわる。
nyatla	109:18f12ac01097	771	inst->tcpstateflags = UIP_SYN_SENT;
nyatla	109:18f12ac01097	772	//前回のデータが残っていた場合の保険
nyatla	109:18f12ac01097	773	if(inst->txbuf.rp!=inst->txbuf.wp){
nyatla	109:18f12ac01097	774	resetTxQWithUnlock(inst);
nyatla	109:18f12ac01097	775	}else{
nyatla	109:18f12ac01097	776	unlockResource(inst);
nyatla	109:18f12ac01097	777	}
nyatla	109:18f12ac01097	778
nyatla	109:18f12ac01097	779	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	780
nyatla	109:18f12ac01097	781	NyLPC_cStopwatch_startExpire(&sw,i_wait_in_msec);
nyatla	109:18f12ac01097	782	if(sendWithRetransmit(inst,TCP_SYN,NULL,0,&sw,&sq)==0){
nyatla	109:18f12ac01097	783	//ちょっと待つ。
nyatla	109:18f12ac01097	784	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	785	//キューにあるTXが消えるのを待つ。
nyatla	109:18f12ac01097	786	if(waitForTxRemove(inst,sq,&sw)){
nyatla	109:18f12ac01097	787	//ACK受信に成功して、TXが消失
nyatla	109:18f12ac01097	788	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	789	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	790	}
nyatla	109:18f12ac01097	791	}
nyatla	109:18f12ac01097	792	//ロックして、強制的なステータス遷移
nyatla	109:18f12ac01097	793	lockResource(inst);
nyatla	109:18f12ac01097	794	f=inst->tcpstateflags;
nyatla	109:18f12ac01097	795	if(f!=UIP_CLOSED){
nyatla	109:18f12ac01097	796	//もし、強制CLOSE遷移であれば、RSTも送信。
nyatla	109:18f12ac01097	797	inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	798	unlockResource(inst);
nyatla	109:18f12ac01097	799	sendRst(inst);
nyatla	109:18f12ac01097	800	}else{
nyatla	109:18f12ac01097	801	unlockResource(inst);
nyatla	109:18f12ac01097	802	}
nyatla	109:18f12ac01097	803	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	804	Error:
nyatla	109:18f12ac01097	805	unlockResource(inst);
nyatla	109:18f12ac01097	806	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	807	}
nyatla	109:18f12ac01097	808
nyatla	109:18f12ac01097	809	/**
nyatla	109:18f12ac01097	810	* この関数は、UIP_SYN_RCVDステータスのソケットを、ESTABLISHEDへ遷移させます。
nyatla	109:18f12ac01097	811	* cTcpListener_listen関数を通過したインスタンスに実行してください。
nyatla	109:18f12ac01097	812	* この関数は、アプリケーションが呼び出します。
nyatla	109:18f12ac01097	813	* @return
nyatla	109:18f12ac01097	814	*
nyatla	109:18f12ac01097	815	*/
nyatla	109:18f12ac01097	816	static NyLPC_TBool accept(NyLPC_TiTcpSocket_t* i_inst,NyLPC_TUInt32 i_wait_in_msec)
nyatla	109:18f12ac01097	817	{
nyatla	109:18f12ac01097	818	volatile NyLPC_TUInt8 f;
nyatla	109:18f12ac01097	819	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	820	NyLPC_TUInt32 sq;
nyatla	109:18f12ac01097	821	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	822
nyatla	109:18f12ac01097	823	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	824	//ステータスチェック
nyatla	109:18f12ac01097	825	f=inst->tcpstateflags;
nyatla	109:18f12ac01097	826	switch(f)
nyatla	109:18f12ac01097	827	{
nyatla	109:18f12ac01097	828	case UIP_ESTABLISHED:
nyatla	109:18f12ac01097	829	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	830	case UIP_SYN_RCVD:
nyatla	109:18f12ac01097	831	//処理対象
nyatla	109:18f12ac01097	832	break;
nyatla	109:18f12ac01097	833	default:
nyatla	109:18f12ac01097	834	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	835	}
nyatla	109:18f12ac01097	836	NyLPC_cStopwatch_startExpire(&sw,i_wait_in_msec);
nyatla	109:18f12ac01097	837	if(sendWithRetransmit(inst,TCP_SYN\|TCP_ACK,NULL,0,&sw,&sq)==0){
nyatla	109:18f12ac01097	838	//ちょっと待つ。
nyatla	109:18f12ac01097	839	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	840	//キューにあるTXが消えるのを待つ。
nyatla	109:18f12ac01097	841	if(waitForTxRemove(inst,sq,&sw)){
nyatla	109:18f12ac01097	842	//ACK受信に成功して、TXが消失
nyatla	109:18f12ac01097	843	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	844	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	845	}
nyatla	109:18f12ac01097	846	}
nyatla	109:18f12ac01097	847	//ロックして、強制的なステータス遷移
nyatla	109:18f12ac01097	848	lockResource(inst);
nyatla	109:18f12ac01097	849	f=inst->tcpstateflags;
nyatla	109:18f12ac01097	850	if(f!=UIP_CLOSED){
nyatla	109:18f12ac01097	851	//もし、強制CLOSE遷移であれば、RSTも送信。
nyatla	109:18f12ac01097	852	inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	853	unlockResource(inst);
nyatla	109:18f12ac01097	854	sendRst(inst);
nyatla	109:18f12ac01097	855	}else{
nyatla	109:18f12ac01097	856	unlockResource(inst);
nyatla	109:18f12ac01097	857	}
nyatla	109:18f12ac01097	858	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	859	}
nyatla	109:18f12ac01097	860
nyatla	109:18f12ac01097	861
nyatla	109:18f12ac01097	862	/**
nyatla	109:18f12ac01097	863	* この関数は、ソケットの受信バッファの読み取り位置と、読み出せるデータサイズを返却します。
nyatla	109:18f12ac01097	864	* 関数はポインターを返却するだけで、バッファの読み取り位置をシークしません。
nyatla	109:18f12ac01097	865	* シークするにはNyLPC_cTcpSocket_pseekを使います。
nyatla	109:18f12ac01097	866	*/
nyatla	109:18f12ac01097	867	static NyLPC_TInt32 precv(NyLPC_TiTcpSocket_t* i_inst,const void** o_buf_ptr,NyLPC_TUInt32 i_wait_msec)
nyatla	109:18f12ac01097	868	{
nyatla	109:18f12ac01097	869	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	870	volatile NyLPC_TUInt8 st;
nyatla	109:18f12ac01097	871	NyLPC_TUInt16 rlen;
nyatla	109:18f12ac01097	872	//タイマを生成
nyatla	109:18f12ac01097	873	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	874	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	875
nyatla	109:18f12ac01097	876	//ESTABLISHED以外の場合は、エラー。
nyatla	109:18f12ac01097	877	NyLPC_cStopwatch_setNow(&sw);
nyatla	109:18f12ac01097	878	do{
nyatla	109:18f12ac01097	879	//読み出しバッファ情報のコピー
nyatla	109:18f12ac01097	880	//MUTEX LOCK
nyatla	109:18f12ac01097	881	lockResource(inst);
nyatla	109:18f12ac01097	882	st=inst->tcpstateflags;
nyatla	109:18f12ac01097	883	rlen=NyLPC_cFifoBuffer_getLength(&(inst->rxbuf));
nyatla	109:18f12ac01097	884	*o_buf_ptr=NyLPC_cFifoBuffer_getPtr(&(inst->rxbuf));
nyatla	109:18f12ac01097	885	//MUTEX UNLOCK
nyatla	109:18f12ac01097	886	unlockResource(inst);
nyatla	109:18f12ac01097	887
nyatla	109:18f12ac01097	888	//バッファが空の場合は、ステータスチェック。ESTABLISHEDでなければ、エラー(PASVCLOSE等の場合)
nyatla	109:18f12ac01097	889	switch(st){
nyatla	109:18f12ac01097	890	case UIP_ESTABLISHED:
nyatla	109:18f12ac01097	891	if(rlen>0){
nyatla	109:18f12ac01097	892	//バッファにパケットがあれば返却
nyatla	109:18f12ac01097	893	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	894	return rlen;
nyatla	109:18f12ac01097	895	}
nyatla	109:18f12ac01097	896	break;
nyatla	109:18f12ac01097	897	case UIP_CLOSE_WAIT:
nyatla	109:18f12ac01097	898	if(rlen>0){
nyatla	109:18f12ac01097	899	//バッファにパケットがあれば返却
nyatla	109:18f12ac01097	900	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	901	return rlen;
nyatla	109:18f12ac01097	902	}
nyatla	109:18f12ac01097	903	//引き続きエラー処理
nyatla	109:18f12ac01097	904	default:
nyatla	109:18f12ac01097	905	//他の場合はエラー
nyatla	109:18f12ac01097	906	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	907	return -1;
nyatla	109:18f12ac01097	908	}
nyatla	109:18f12ac01097	909	//タスクスイッチ
nyatla	109:18f12ac01097	910	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	911	}while(NyLPC_cStopwatch_elapseInMsec(&sw)<i_wait_msec);
nyatla	109:18f12ac01097	912	//規定時間内に受信が成功しなかった。
nyatla	109:18f12ac01097	913	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	914	return 0;
nyatla	109:18f12ac01097	915	}
nyatla	109:18f12ac01097	916	/**
nyatla	109:18f12ac01097	917	* 受信バッファをシークします。
nyatla	109:18f12ac01097	918	* シーク後に、遅延ACKを送出します。
nyatla	109:18f12ac01097	919	*/
nyatla	109:18f12ac01097	920	static void pseek(NyLPC_TiTcpSocket_t* i_inst,NyLPC_TUInt16 i_seek)
nyatla	109:18f12ac01097	921	{
nyatla	109:18f12ac01097	922	void* buf;
nyatla	109:18f12ac01097	923	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	924
nyatla	109:18f12ac01097	925	NyLPC_ArgAssert(i_seek<=NyLPC_cFifoBuffer_getLength(&(inst->rxbuf)));
nyatla	109:18f12ac01097	926	if(i_seek==0){
nyatla	109:18f12ac01097	927	return;
nyatla	109:18f12ac01097	928	}
nyatla	109:18f12ac01097	929
nyatla	109:18f12ac01097	930	//ACK送信バッファの取得
nyatla	109:18f12ac01097	931	buf=NyLPC_cMiMicIpNetIf_allocSysTxBuf();
nyatla	109:18f12ac01097	932
nyatla	109:18f12ac01097	933	//MUTEX LOCK
nyatla	109:18f12ac01097	934	lockResource(inst);
nyatla	109:18f12ac01097	935
nyatla	109:18f12ac01097	936	//受信バッファを読み出しシーク
nyatla	109:18f12ac01097	937	NyLPC_cFifoBuffer_pop(&(inst->rxbuf),i_seek);
nyatla	109:18f12ac01097	938	//ACKパケットの生成
nyatla	109:18f12ac01097	939	setTxPacket(inst,buf,TCP_ACK,NULL,0);
nyatla	109:18f12ac01097	940	unlockResource(inst);
nyatla	109:18f12ac01097	941	//ACK送信
nyatla	109:18f12ac01097	942	NyLPC_cMiMicIpNetIf_sendIPv4Tx(buf);
nyatla	109:18f12ac01097	943	NyLPC_cMiMicIpNetIf_releaseTxBuf(buf);
nyatla	109:18f12ac01097	944
nyatla	109:18f12ac01097	945	}
nyatla	109:18f12ac01097	946
nyatla	109:18f12ac01097	947	/**
nyatla	109:18f12ac01097	948	* See header file.
nyatla	109:18f12ac01097	949	*/
nyatla	109:18f12ac01097	950	static void* allocSendBuf(NyLPC_TiTcpSocket_t* i_inst,NyLPC_TUInt16 i_hint,NyLPC_TUInt16* o_buf_size,NyLPC_TUInt32 i_wait_in_msec)
nyatla	109:18f12ac01097	951	{
nyatla	109:18f12ac01097	952	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	953
nyatla	109:18f12ac01097	954	NyLPC_TUInt16 s;
nyatla	109:18f12ac01097	955	void* buf;
nyatla	109:18f12ac01097	956	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	957
nyatla	109:18f12ac01097	958	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	959	NyLPC_cStopwatch_startExpire(&sw,i_wait_in_msec);
nyatla	109:18f12ac01097	960
nyatla	109:18f12ac01097	961	//送信バッファを取得
nyatla	109:18f12ac01097	962	//@bug バッファが取れるまで通信がブロックするの。ここはなんとかしないと。
nyatla	109:18f12ac01097	963	for(;;){
nyatla	109:18f12ac01097	964	//ESTABLISHED以外に非同期遷移
nyatla	109:18f12ac01097	965	if(inst->tcpstateflags!=UIP_ESTABLISHED){
nyatla	109:18f12ac01097	966	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	967	return NULL;
nyatla	109:18f12ac01097	968	}
nyatla	109:18f12ac01097	969	buf=NyLPC_cMiMicIpNetIf_allocTxBuf(i_hint+(SIZE_OF_IPv4_TCPIP_HEADER),&s);
nyatla	109:18f12ac01097	970	if(buf!=NULL){
nyatla	109:18f12ac01097	971	break;
nyatla	109:18f12ac01097	972	}
nyatla	109:18f12ac01097	973	//タイムアウト時もエラー
nyatla	109:18f12ac01097	974	if(NyLPC_cStopwatch_isExpired(&sw)){
nyatla	109:18f12ac01097	975	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	976	return NULL;
nyatla	109:18f12ac01097	977	}
nyatla	109:18f12ac01097	978	}
nyatla	109:18f12ac01097	979
nyatla	109:18f12ac01097	980	//@todo 前段処理と順番を入れ替えて、要求サイズとpeerのwinのうち、小さいほうを割り当てたほうが良くない？
nyatla	109:18f12ac01097	981	//ここで相手のwin待ちをする理由は、相手に確実に受け取れるサイズを決定する為。
nyatla	109:18f12ac01097	982	lockResource(inst);
nyatla	109:18f12ac01097	983	//ペイロードがある場合のみ、相手のwindowサイズが0以上になるのを待つ。
nyatla	109:18f12ac01097	984	while(inst->uip_connr.peer_win==0){
nyatla	109:18f12ac01097	985	unlockResource(inst);
nyatla	109:18f12ac01097	986	//ESTABLISHED以外に非同期遷移 orタイムアウト確認
nyatla	109:18f12ac01097	987	if(NyLPC_cStopwatch_isExpired(&sw)\|\|(inst->tcpstateflags!=UIP_ESTABLISHED)){
nyatla	109:18f12ac01097	988	NyLPC_cMiMicIpNetIf_releaseTxBuf(buf);
nyatla	109:18f12ac01097	989	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	990	return NULL;
nyatla	109:18f12ac01097	991	}
nyatla	109:18f12ac01097	992	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	993	lockResource(inst);
nyatla	109:18f12ac01097	994	}
nyatla	109:18f12ac01097	995	//送信バッファを基準とした送信サイズを計算
nyatla	109:18f12ac01097	996	s-=SIZE_OF_IPv4_TCPIP_HEADER;
nyatla	109:18f12ac01097	997	//送信サイズよりMMSが小さければ、送信サイズを修正
nyatla	109:18f12ac01097	998	if(inst->uip_connr.peer_mss<s){
nyatla	109:18f12ac01097	999	s=inst->uip_connr.peer_mss;
nyatla	109:18f12ac01097	1000	}
nyatla	109:18f12ac01097	1001	//送信サイズよりpeerのウインドウサイズが小さければ修正
nyatla	109:18f12ac01097	1002	if(inst->uip_connr.peer_win<s){
nyatla	109:18f12ac01097	1003	s=inst->uip_connr.peer_win;
nyatla	109:18f12ac01097	1004	}
nyatla	109:18f12ac01097	1005	unlockResource(inst);
nyatla	109:18f12ac01097	1006	//バッファサイズ確定。
nyatla	109:18f12ac01097	1007	*o_buf_size=s;
nyatla	109:18f12ac01097	1008	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	1009	return (NyLPC_TUInt8*)buf+SIZE_OF_IPv4_TCPIP_HEADER;
nyatla	109:18f12ac01097	1010	}
nyatla	109:18f12ac01097	1011	/**
nyatla	109:18f12ac01097	1012	* See Header file.
nyatla	109:18f12ac01097	1013	*/
nyatla	109:18f12ac01097	1014	static void releaseSendBuf(NyLPC_TiTcpSocket_t* i_inst,void* i_buf_ptr)
nyatla	109:18f12ac01097	1015	{
nyatla	109:18f12ac01097	1016	NyLPC_cMiMicIpNetIf_releaseTxBuf((NyLPC_TUInt8*)i_buf_ptr-SIZE_OF_IPv4_TCPIP_HEADER);
nyatla	109:18f12ac01097	1017	}
nyatla	109:18f12ac01097	1018
nyatla	109:18f12ac01097	1019
nyatla	109:18f12ac01097	1020	/**
nyatla	109:18f12ac01097	1021	* 事前にAllocしたTxパケットを送信します。
nyatla	109:18f12ac01097	1022	* このAPIはゼロコピー送信をサポートするためのものです。
nyatla	109:18f12ac01097	1023	* @param i_buf_ptr
nyatla	109:18f12ac01097	1024	* allocSendBufで取得したメモリを指定します。
nyatla	109:18f12ac01097	1025	* @return
nyatla	109:18f12ac01097	1026	* 関数が失敗した場合、i_buf_ptrは「開放されません。」
nyatla	109:18f12ac01097	1027	*/
nyatla	109:18f12ac01097	1028	static NyLPC_TBool psend(NyLPC_TiTcpSocket_t* i_inst,void* i_buf_ptr,int i_len,NyLPC_TUInt32 i_wait_in_msec)
nyatla	109:18f12ac01097	1029	{
nyatla	109:18f12ac01097	1030	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	1031	struct NyLPC_TcTcpSocket_TxQItem* txq;
nyatla	109:18f12ac01097	1032	void* buf;
nyatla	109:18f12ac01097	1033	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	1034	//ESTABLISHEDでなければエラー
nyatla	109:18f12ac01097	1035	if(inst->tcpstateflags!=UIP_ESTABLISHED){
nyatla	109:18f12ac01097	1036	//ESTABLISHEDでなければエラー
nyatla	109:18f12ac01097	1037	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	1038	}
nyatla	109:18f12ac01097	1039	//送信データ0なら何もしない。
nyatla	109:18f12ac01097	1040	if(i_len<1){
nyatla	109:18f12ac01097	1041	releaseSendBuf(i_inst,i_buf_ptr);
nyatla	109:18f12ac01097	1042	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	1043	}
nyatla	109:18f12ac01097	1044	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	1045	NyLPC_cStopwatch_startExpire(&sw,i_wait_in_msec);
nyatla	109:18f12ac01097	1046
nyatla	109:18f12ac01097	1047	//先頭ポインタは、i_buf-sizeof(SIZE_OF_IPv4_TCPIP_HEADER)固定
nyatla	109:18f12ac01097	1048	buf=(NyLPC_TUInt8*)i_buf_ptr-SIZE_OF_IPv4_TCPIP_HEADER;
nyatla	109:18f12ac01097	1049	lockResource(inst);
nyatla	109:18f12ac01097	1050	//送信キューの取得
nyatla	109:18f12ac01097	1051	txq=getTxQ(inst,&sw);
nyatla	109:18f12ac01097	1052	//送信キューが取れなかった。
nyatla	109:18f12ac01097	1053	if(txq==NULL){
nyatla	109:18f12ac01097	1054	//シーケンス番号をロールバックできないので、エラーとする。
nyatla	109:18f12ac01097	1055	unlockResource(inst);
nyatla	109:18f12ac01097	1056	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	1057	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	1058	}
nyatla	109:18f12ac01097	1059	//ここから先はi_bufの所有権はインスタンスになってる。
nyatla	109:18f12ac01097	1060
nyatla	109:18f12ac01097	1061	//IPv4ペイロードの書き込み
nyatla	109:18f12ac01097	1062
nyatla	109:18f12ac01097	1063	//allocをした時点でwin,mssは考慮されているので、そのままそうしんしる。
nyatla	109:18f12ac01097	1064
nyatla	109:18f12ac01097	1065	//ACK番号の計算
nyatla	109:18f12ac01097	1066	txq->rto32=inst->uip_connr.current_rto32;
nyatla	109:18f12ac01097	1067	txq->tick_of_sent=NyLPC_cStopwatch_now();
nyatla	109:18f12ac01097	1068	//パケットヘッダの生成(ヘッダ長はpreadで定義した値(4+6)*4=40です。)
nyatla	109:18f12ac01097	1069	setTxPacketHeader(inst,buf,TCP_ACK\|TCP_PSH,i_len);
nyatla	109:18f12ac01097	1070	txq->packet=buf;
nyatla	109:18f12ac01097	1071
nyatla	109:18f12ac01097	1072	//シーケンス番号の更新
nyatla	109:18f12ac01097	1073	inst->uip_connr.snd_nxt32=inst->uip_connr.snd_nxt32+i_len;
nyatla	109:18f12ac01097	1074	//Peerのウインドウサイズを更新
nyatla	109:18f12ac01097	1075	inst->uip_connr.peer_win-=i_len;
nyatla	109:18f12ac01097	1076	//ACK番号の返却
nyatla	109:18f12ac01097	1077	txq->ackno=NyLPC_HTONL(inst->uip_connr.snd_nxt32);
nyatla	109:18f12ac01097	1078	unlockResource(inst);
nyatla	109:18f12ac01097	1079	NyLPC_cMiMicIpNetIf_sendIPv4Tx(buf);
nyatla	109:18f12ac01097	1080	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	1081	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	1082	}
nyatla	109:18f12ac01097	1083
nyatla	109:18f12ac01097	1084	/**
nyatla	109:18f12ac01097	1085	* See header file.
nyatla	109:18f12ac01097	1086	*/
nyatla	109:18f12ac01097	1087	static NyLPC_TInt32 send(NyLPC_TiTcpSocket_t* i_inst,const void* i_buf_ptr,NyLPC_TInt32 i_len,NyLPC_TUInt32 i_wait_in_msec)
nyatla	109:18f12ac01097	1088	{
nyatla	109:18f12ac01097	1089	NyLPC_TInt16 hint;
nyatla	109:18f12ac01097	1090	NyLPC_TUInt16 s;
nyatla	109:18f12ac01097	1091	void* buf;
nyatla	109:18f12ac01097	1092	if(i_len<1){
nyatla	109:18f12ac01097	1093	return 0;
nyatla	109:18f12ac01097	1094	}
nyatla	109:18f12ac01097	1095	hint=(i_len>32767)?32767:i_len;
nyatla	109:18f12ac01097	1096	buf=allocSendBuf(i_inst,hint,&s,i_wait_in_msec);
nyatla	109:18f12ac01097	1097	if(buf==NULL){
nyatla	109:18f12ac01097	1098	return -1;
nyatla	109:18f12ac01097	1099	}
nyatla	109:18f12ac01097	1100	//送信サイズの計算
nyatla	109:18f12ac01097	1101	s=((NyLPC_TInt32)s<i_len)?s:(NyLPC_TUInt16)i_len;
nyatla	109:18f12ac01097	1102	memcpy(buf,i_buf_ptr,s);
nyatla	109:18f12ac01097	1103	if(!psend(i_inst,buf,s,i_wait_in_msec)){
nyatla	109:18f12ac01097	1104	releaseSendBuf(i_inst,buf);
nyatla	109:18f12ac01097	1105	return -1;//error
nyatla	109:18f12ac01097	1106	}
nyatla	109:18f12ac01097	1107	return s;
nyatla	109:18f12ac01097	1108	}
nyatla	109:18f12ac01097	1109
nyatla	109:18f12ac01097	1110
nyatla	109:18f12ac01097	1111	static void close(NyLPC_TiTcpSocket_t* i_inst,NyLPC_TUInt32 i_wait_in_msec)
nyatla	109:18f12ac01097	1112	{
nyatla	109:18f12ac01097	1113	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	1114	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	1115	volatile NyLPC_TUInt8 f;
nyatla	109:18f12ac01097	1116	NyLPC_TUInt32 sq;
nyatla	109:18f12ac01097	1117	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	1118	NyLPC_cStopwatch_startExpire(&sw,i_wait_in_msec);
nyatla	109:18f12ac01097	1119	lockResource(inst);
nyatla	109:18f12ac01097	1120
nyatla	109:18f12ac01097	1121	f=inst->tcpstateflags;
nyatla	109:18f12ac01097	1122	//ステータスチェック
nyatla	109:18f12ac01097	1123	switch(f)
nyatla	109:18f12ac01097	1124	{
nyatla	109:18f12ac01097	1125	case UIP_CLOSED:
nyatla	109:18f12ac01097	1126	//閉じている。
nyatla	109:18f12ac01097	1127	goto ReturnWithUnlock;
nyatla	109:18f12ac01097	1128	case UIP_ESTABLISHED:
nyatla	109:18f12ac01097	1129	//アクティブクローズ。
nyatla	109:18f12ac01097	1130	inst->tcpstateflags=UIP_FIN_WAIT_1;
nyatla	109:18f12ac01097	1131	//送信のために一旦解除
nyatla	109:18f12ac01097	1132	unlockResource(inst);
nyatla	109:18f12ac01097	1133	//FINの送信
nyatla	109:18f12ac01097	1134	if(sendWithRetransmit(inst,TCP_FIN\|TCP_ACK,NULL,0,&sw,&sq)==0){
nyatla	109:18f12ac01097	1135	//ちょっと待つ。
nyatla	109:18f12ac01097	1136	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	1137	//TXの消去待ち
nyatla	109:18f12ac01097	1138	if(waitForTxRemove(inst,sq,&sw)){
nyatla	109:18f12ac01097	1139	//再ロック
nyatla	109:18f12ac01097	1140	lockResource(inst);
nyatla	109:18f12ac01097	1141	//タイムアウトするか、UIP_CLOSED、もしくはTIME_WAITに遷移するのを待つ。(遷移はRxprocで自動的に実行。)
nyatla	109:18f12ac01097	1142	do{
nyatla	109:18f12ac01097	1143	switch(inst->tcpstateflags)
nyatla	109:18f12ac01097	1144	{
nyatla	109:18f12ac01097	1145	case UIP_TIME_WAIT:
nyatla	109:18f12ac01097	1146	inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	1147	case UIP_CLOSED:
nyatla	109:18f12ac01097	1148	NyLPC_Assert(inst->txbuf.rp==inst->txbuf.wp);
nyatla	109:18f12ac01097	1149	//成功。
nyatla	109:18f12ac01097	1150	goto ReturnWithUnlock;
nyatla	109:18f12ac01097	1151	case UIP_FIN_WAIT_1:
nyatla	109:18f12ac01097	1152	case UIP_FIN_WAIT_2:
nyatla	109:18f12ac01097	1153	case UIP_CLOSING:
nyatla	109:18f12ac01097	1154	//一時的なアンロック
nyatla	109:18f12ac01097	1155	unlockResource(inst);
nyatla	109:18f12ac01097	1156	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	1157	lockResource(inst);
nyatla	109:18f12ac01097	1158	default:
nyatla	109:18f12ac01097	1159	break;
nyatla	109:18f12ac01097	1160	}
nyatla	109:18f12ac01097	1161	}while(!NyLPC_cStopwatch_isExpired(&sw));
nyatla	109:18f12ac01097	1162	unlockResource(inst);
nyatla	109:18f12ac01097	1163	}
nyatla	109:18f12ac01097	1164	}
nyatla	109:18f12ac01097	1165	break;
nyatla	109:18f12ac01097	1166	case UIP_CLOSE_WAIT:
nyatla	109:18f12ac01097	1167	//LAST_ACKへ遷移
nyatla	109:18f12ac01097	1168	inst->tcpstateflags=UIP_LAST_ACK;
nyatla	109:18f12ac01097	1169	//送信のために一旦解除
nyatla	109:18f12ac01097	1170	unlockResource(inst);
nyatla	109:18f12ac01097	1171	if(sendWithRetransmit(inst,TCP_FIN\|TCP_ACK,NULL,0,&sw,&sq)==0){
nyatla	109:18f12ac01097	1172	//ちょっと待つ。
nyatla	109:18f12ac01097	1173	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	1174	//TXの消去待ち
nyatla	109:18f12ac01097	1175	if(waitForTxRemove(inst,sq,&sw)){
nyatla	109:18f12ac01097	1176	//再ロック
nyatla	109:18f12ac01097	1177	lockResource(inst);
nyatla	109:18f12ac01097	1178	//TX消去後にCLOSEDに遷移していればOK
nyatla	109:18f12ac01097	1179	if(inst->tcpstateflags==UIP_CLOSED)
nyatla	109:18f12ac01097	1180	{
nyatla	109:18f12ac01097	1181	NyLPC_Assert(inst->txbuf.rp==inst->txbuf.wp);
nyatla	109:18f12ac01097	1182	goto ReturnWithUnlock;
nyatla	109:18f12ac01097	1183	}
nyatla	109:18f12ac01097	1184	unlockResource(inst);
nyatla	109:18f12ac01097	1185	}
nyatla	109:18f12ac01097	1186	}
nyatla	109:18f12ac01097	1187	//エラー。RSTで切断。
nyatla	109:18f12ac01097	1188	break;
nyatla	109:18f12ac01097	1189	default:
nyatla	109:18f12ac01097	1190	unlockResource(inst);
nyatla	109:18f12ac01097	1191	NyLPC_Warning();
nyatla	109:18f12ac01097	1192	break;
nyatla	109:18f12ac01097	1193	}
nyatla	109:18f12ac01097	1194	// if(i_inst->_smutex._lock_count>0){
nyatla	109:18f12ac01097	1195	// NyLPC_Warning();
nyatla	109:18f12ac01097	1196	// }
nyatla	109:18f12ac01097	1197	//このパスに到達するのは、FIN送信/ACKに成功したにも拘らず、規定時間内にCLOSEDに遷移しなかった場合。
nyatla	109:18f12ac01097	1198	//コネクションを強制遷移して、RST
nyatla	109:18f12ac01097	1199	lockResource(inst);
nyatla	109:18f12ac01097	1200	f=inst->tcpstateflags;
nyatla	109:18f12ac01097	1201	if(f!=UIP_CLOSED){
nyatla	109:18f12ac01097	1202	//もし、強制CLOSE遷移であれば、RSTも送信。
nyatla	109:18f12ac01097	1203	inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	1204	unlockResource(inst);
nyatla	109:18f12ac01097	1205	sendRst(inst);
nyatla	109:18f12ac01097	1206	}else{
nyatla	109:18f12ac01097	1207	unlockResource(inst);
nyatla	109:18f12ac01097	1208	}
nyatla	109:18f12ac01097	1209	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	1210	return;
nyatla	109:18f12ac01097	1211	ReturnWithUnlock:
nyatla	109:18f12ac01097	1212	unlockResource(inst);
nyatla	109:18f12ac01097	1213	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	1214	return;
nyatla	109:18f12ac01097	1215	}
nyatla	109:18f12ac01097	1216
nyatla	109:18f12ac01097	1217	/**
nyatla	109:18f12ac01097	1218	* uipサービスタスクが実行する関数です。
nyatla	109:18f12ac01097	1219	* 定期的に実行する関数。最低でも1s単位で実行してください。
nyatla	109:18f12ac01097	1220	*/
nyatla	109:18f12ac01097	1221	void NyLPC_cMiMicIpTcpSocket_periodic(
nyatla	109:18f12ac01097	1222	NyLPC_TcMiMicIpTcpSocket_t* i_inst)
nyatla	109:18f12ac01097	1223	{
nyatla	109:18f12ac01097	1224	int i;
nyatla	109:18f12ac01097	1225	struct NyLPC_TcTcpSocket_TxQItem* q=i_inst->txbuf.txq;
nyatla	109:18f12ac01097	1226	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	1227	NyLPC_TUInt32 now;
nyatla	109:18f12ac01097	1228	int rp;
nyatla	109:18f12ac01097	1229	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	1230	now=NyLPC_cStopwatch_now();
nyatla	109:18f12ac01097	1231	//MUTEX LOCK
nyatla	109:18f12ac01097	1232	lockResource(i_inst);
nyatla	109:18f12ac01097	1233	if(i_inst->tcpstateflags==UIP_CLOSED)
nyatla	109:18f12ac01097	1234	{
nyatla	109:18f12ac01097	1235	//CLOSEDなら、バッファ開放。
nyatla	109:18f12ac01097	1236	resetTxQWithUnlock(i_inst);
nyatla	109:18f12ac01097	1237	}else if(i_inst->txbuf.rp==i_inst->txbuf.wp){
nyatla	109:18f12ac01097	1238	//再送信パケットがなければ何もしないよ。
nyatla	109:18f12ac01097	1239	unlockResource(i_inst);
nyatla	109:18f12ac01097	1240	}else if(i_inst->uip_connr.peer_win==0){
nyatla	109:18f12ac01097	1241	//peer_winが0の場合は何もしない。
nyatla	109:18f12ac01097	1242	unlockResource(i_inst);
nyatla	109:18f12ac01097	1243	}else{
nyatla	109:18f12ac01097	1244	//再送信処理
nyatla	109:18f12ac01097	1245	rp=i_inst->txbuf.rp;
nyatla	109:18f12ac01097	1246	NyLPC_cStopwatch_set(&sw,q[rp].tick_of_sent);
nyatla	109:18f12ac01097	1247	if(NyLPC_cStopwatch_elapseInMsec(&sw)>q[rp].rto32){
nyatla	109:18f12ac01097	1248	//最古のパケットの送信時間をチェックして、タイムアウトが発生したら、再送時間と送信時刻をセット
nyatla	109:18f12ac01097	1249	//最古パケットRTOを2倍。
nyatla	109:18f12ac01097	1250	q[rp].rto32*=2;
nyatla	109:18f12ac01097	1251	for(i=rp;i!=i_inst->txbuf.wp;i=(i+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ){
nyatla	109:18f12ac01097	1252	q[i].tick_of_sent=now;
nyatla	109:18f12ac01097	1253	}
nyatla	109:18f12ac01097	1254	if(q[rp].rto32>UIP_IP_RTO_MAX_RTO){
nyatla	109:18f12ac01097	1255	//最古のRTOが64秒を超えたら、CLOSED
nyatla	109:18f12ac01097	1256	i_inst->tcpstateflags =UIP_CLOSED;
nyatla	109:18f12ac01097	1257	resetTxQWithUnlock(i_inst);
nyatla	109:18f12ac01097	1258	sendRst(i_inst);
nyatla	109:18f12ac01097	1259	}else{
nyatla	109:18f12ac01097	1260	//規定時間内なら、再送処理
nyatla	109:18f12ac01097	1261	for(i=rp;i!=i_inst->txbuf.wp;i=(i+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ){
nyatla	109:18f12ac01097	1262	// NyLPC_cUipService_sendIPv4Tx(NyLPC_cIPv4Payload_getBuf(&(q[i].data)));
nyatla	109:18f12ac01097	1263	NyLPC_cMiMicIpNetIf_sendIPv4Tx(q[i].packet);
nyatla	109:18f12ac01097	1264	}
nyatla	109:18f12ac01097	1265	unlockResource(i_inst);
nyatla	109:18f12ac01097	1266	}
nyatla	109:18f12ac01097	1267	}else{
nyatla	109:18f12ac01097	1268	unlockResource(i_inst);
nyatla	109:18f12ac01097	1269	}
nyatla	109:18f12ac01097	1270	}
nyatla	109:18f12ac01097	1271	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	1272	return;
nyatla	109:18f12ac01097	1273	}
nyatla	109:18f12ac01097	1274	/**
nyatla	109:18f12ac01097	1275	* uipサービスタスクが実行する関数です。
nyatla	109:18f12ac01097	1276	* サービスの開始を通知します。
nyatla	109:18f12ac01097	1277	*/
nyatla	109:18f12ac01097	1278	void NyLPC_cMiMicIpTcpSocket_startService(NyLPC_TcMiMicIpTcpSocket_t* i_inst,const NyLPC_TcIPv4Config_t* i_config)
nyatla	109:18f12ac01097	1279	{
nyatla	109:18f12ac01097	1280	NyLPC_Assert(i_inst->tcpstateflags==UIP_CLOSED);//閉じてなければおかしい。
nyatla	109:18f12ac01097	1281	i_inst->uip_connr.lipaddr=&(i_config->ip_addr);
nyatla	109:18f12ac01097	1282	i_inst->uip_connr.default_mss=i_config->default_mss;
nyatla	109:18f12ac01097	1283	//NyLPC_cTcpSocket_setSynPayload関数でも実行するけど、IFのリセット時なのでここでもやる。
nyatla	109:18f12ac01097	1284	NyLPC_cFifoBuffer_clear(&(i_inst->rxbuf));
nyatla	109:18f12ac01097	1285	return;
nyatla	109:18f12ac01097	1286	}
nyatla	109:18f12ac01097	1287	/**
nyatla	109:18f12ac01097	1288	* uipサービスタスクが実行する関数です。
nyatla	109:18f12ac01097	1289	* サービスの停止を通知します。
nyatla	109:18f12ac01097	1290	*/
nyatla	109:18f12ac01097	1291	void NyLPC_cMiMicIpTcpSocket_stopService(NyLPC_TcMiMicIpTcpSocket_t* i_inst)
nyatla	109:18f12ac01097	1292	{
nyatla	109:18f12ac01097	1293	lockResource(i_inst);
nyatla	109:18f12ac01097	1294	if(i_inst->tcpstateflags==UIP_CLOSED)
nyatla	109:18f12ac01097	1295	{
nyatla	109:18f12ac01097	1296	unlockResource(i_inst);
nyatla	109:18f12ac01097	1297	}else{
nyatla	109:18f12ac01097	1298	i_inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	1299	resetTxQWithUnlock(i_inst);
nyatla	109:18f12ac01097	1300	sendRst(i_inst);
nyatla	109:18f12ac01097	1301	}
nyatla	109:18f12ac01097	1302	return;
nyatla	109:18f12ac01097	1303	}
nyatla	109:18f12ac01097	1304
nyatla	109:18f12ac01097	1305
nyatla	109:18f12ac01097	1306	void* NyLPC_cMiMicIpTcpSocket_parseRx(
nyatla	109:18f12ac01097	1307	NyLPC_TcMiMicIpTcpSocket_t* i_inst,
nyatla	109:18f12ac01097	1308	const NyLPC_TcIPv4Payload_t* i_ipp)
nyatla	109:18f12ac01097	1309	{
nyatla	109:18f12ac01097	1310	int i,s;
nyatla	109:18f12ac01097	1311	NyLPC_TUInt16 tmp16;
nyatla	109:18f12ac01097	1312	NyLPC_TUInt16 data_size;
nyatla	109:18f12ac01097	1313	NyLPC_TUInt8 in_tcpflag=i_ipp->payload.tcp->flags;
nyatla	109:18f12ac01097	1314	const void* tcp_data_offset;
nyatla	109:18f12ac01097	1315	NyLPC_TBool is_new_packet;
nyatla	109:18f12ac01097	1316	int num_of_noack;
nyatla	109:18f12ac01097	1317	void* dlist[NyLPC_TcTcpSocket_NUMBER_OF_TXQ];
nyatla	109:18f12ac01097	1318	void* ret;
nyatla	109:18f12ac01097	1319
nyatla	109:18f12ac01097	1320	//パラメータの計算
nyatla	109:18f12ac01097	1321
nyatla	109:18f12ac01097	1322	tmp16=NyLPC_TTcpHeader_getHeaderLength(i_ipp->payload.tcp);
nyatla	109:18f12ac01097	1323	//TCPペイロードの長さは、IPパケットの長さ-(IPヘッダ+TCPヘッダ)
nyatla	109:18f12ac01097	1324	data_size=NyLPC_TIPv4Header_getPacketLength(i_ipp->header)-NyLPC_TIPv4Header_getHeaderLength(i_ipp->header)-tmp16;
nyatla	109:18f12ac01097	1325	//TCPデータオフセット
nyatla	109:18f12ac01097	1326	tcp_data_offset=i_ipp->payload.rawbuf+tmp16;
nyatla	109:18f12ac01097	1327
nyatla	109:18f12ac01097	1328	//インスタンスをロックする。
nyatla	109:18f12ac01097	1329	lockResource(i_inst);
nyatla	109:18f12ac01097	1330
nyatla	109:18f12ac01097	1331	//RSTのチェック。RST受信時は、状態にかかわらず、CLOSEDステータスに移行する。
nyatla	109:18f12ac01097	1332	if (in_tcpflag & TCP_RST)
nyatla	109:18f12ac01097	1333	{
nyatla	109:18f12ac01097	1334	i_inst->tcpstateflags =UIP_CLOSED;
nyatla	109:18f12ac01097	1335	goto DROP;
nyatla	109:18f12ac01097	1336	}
nyatla	109:18f12ac01097	1337
nyatla	109:18f12ac01097	1338
nyatla	109:18f12ac01097	1339	is_new_packet=NyLPC_ntohl(i_ipp->payload.tcp->seqno32)==i_inst->uip_connr.rcv_nxt32;
nyatla	109:18f12ac01097	1340
nyatla	109:18f12ac01097	1341
nyatla	109:18f12ac01097	1342	//OPTIONの反映
nyatla	109:18f12ac01097	1343
nyatla	109:18f12ac01097	1344	//MSSの取得
nyatla	109:18f12ac01097	1345	if(NyLPC_TTcpHeader_getTcpMmsOpt(i_ipp->payload.tcp,&tmp16)){
nyatla	109:18f12ac01097	1346	//取得で着たら更新
nyatla	109:18f12ac01097	1347	i_inst->uip_connr.peer_mss=tmp16;
nyatla	109:18f12ac01097	1348	}
nyatla	109:18f12ac01097	1349	//受信パケットを元に、未ACKパケットの数を計算
nyatla	109:18f12ac01097	1350	num_of_noack=getNumOfSending(i_inst,i_ipp->payload.tcp->ackno32);//i_inst->txbuf.num_of_txq;
nyatla	109:18f12ac01097	1351
nyatla	109:18f12ac01097	1352	//ステータス毎のACK応答
nyatla	109:18f12ac01097	1353	switch(i_inst->tcpstateflags)
nyatla	109:18f12ac01097	1354	{
nyatla	109:18f12ac01097	1355	case UIP_SYN_RCVD:
nyatla	109:18f12ac01097	1356	//ACKを受信したら、ESTABLISHEDへ。
nyatla	109:18f12ac01097	1357	//すべてのパケットをACKしたかで判定。()
nyatla	109:18f12ac01097	1358	if(num_of_noack==0){
nyatla	109:18f12ac01097	1359	i_inst->tcpstateflags=UIP_ESTABLISHED;
nyatla	109:18f12ac01097	1360	}else{
nyatla	109:18f12ac01097	1361	//それ以外のパケットはドロップする。
nyatla	109:18f12ac01097	1362	break;//goto DROP;
nyatla	109:18f12ac01097	1363	}
nyatla	109:18f12ac01097	1364	//新しいパケットがなければ、無応答
nyatla	109:18f12ac01097	1365	if(!is_new_packet){
nyatla	109:18f12ac01097	1366	break;//goto DROP;
nyatla	109:18f12ac01097	1367	}
nyatla	109:18f12ac01097	1368	//引き続き、ESTABLISHEDの処理へ。
nyatla	109:18f12ac01097	1369	case UIP_ESTABLISHED:
nyatla	109:18f12ac01097	1370	if(data_size>0){
nyatla	109:18f12ac01097	1371	if(is_new_packet){
nyatla	109:18f12ac01097	1372	if(addRecvData(i_inst,tcp_data_offset,data_size)){
nyatla	109:18f12ac01097	1373	//通常のACK返却
nyatla	109:18f12ac01097	1374	i_inst->uip_connr.rcv_nxt32+=data_size;
nyatla	109:18f12ac01097	1375	}else{
nyatla	109:18f12ac01097	1376	//失敗したときは必要に応じて単純ACK
nyatla	109:18f12ac01097	1377	}
nyatla	109:18f12ac01097	1378	}
nyatla	109:18f12ac01097	1379	}
nyatla	109:18f12ac01097	1380	//どちらにしろ、ACK送信
nyatla	109:18f12ac01097	1381	if(is_new_packet && (in_tcpflag & TCP_FIN)){
nyatla	109:18f12ac01097	1382	//FINがあるときは、ステータスをCLOSE_WAITへセットして、ACKを返す。
nyatla	109:18f12ac01097	1383	i_inst->tcpstateflags = UIP_CLOSE_WAIT;
nyatla	109:18f12ac01097	1384	i_inst->uip_connr.rcv_nxt32++;
nyatla	109:18f12ac01097	1385	}
nyatla	109:18f12ac01097	1386	break;
nyatla	109:18f12ac01097	1387	case UIP_CLOSE_WAIT:
nyatla	109:18f12ac01097	1388	//必要に応じたACK応答
nyatla	109:18f12ac01097	1389	break;
nyatla	109:18f12ac01097	1390	case UIP_LAST_ACK:
nyatla	109:18f12ac01097	1391	//ACK(by FIN)が得られたなら、CLOSEDへ。
nyatla	109:18f12ac01097	1392	if(num_of_noack==0){
nyatla	109:18f12ac01097	1393	i_inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	1394	}
nyatla	109:18f12ac01097	1395	//必要に応じたACK応答
nyatla	109:18f12ac01097	1396	break;
nyatla	109:18f12ac01097	1397	case UIP_FIN_WAIT_1:
nyatla	109:18f12ac01097	1398	//FIN受信->CLOSINGへ
nyatla	109:18f12ac01097	1399	if(is_new_packet){
nyatla	109:18f12ac01097	1400	i_inst->uip_connr.rcv_nxt32+=data_size;
nyatla	109:18f12ac01097	1401	if(in_tcpflag & TCP_FIN){
nyatla	109:18f12ac01097	1402	i_inst->uip_connr.rcv_nxt32++;
nyatla	109:18f12ac01097	1403	if(num_of_noack==0){
nyatla	109:18f12ac01097	1404	//FINとACKを受信
nyatla	109:18f12ac01097	1405	i_inst->tcpstateflags=UIP_TIME_WAIT;
nyatla	109:18f12ac01097	1406	}else{
nyatla	109:18f12ac01097	1407	//FINのみ
nyatla	109:18f12ac01097	1408	i_inst->tcpstateflags=UIP_CLOSING;
nyatla	109:18f12ac01097	1409	}
nyatla	109:18f12ac01097	1410	}
nyatla	109:18f12ac01097	1411	}else if(num_of_noack==0){
nyatla	109:18f12ac01097	1412	//ACKのみ
nyatla	109:18f12ac01097	1413	i_inst->tcpstateflags=UIP_FIN_WAIT_2;
nyatla	109:18f12ac01097	1414	}
nyatla	109:18f12ac01097	1415	//必要に応じたACK応答
nyatla	109:18f12ac01097	1416	break;
nyatla	109:18f12ac01097	1417	case UIP_FIN_WAIT_2:
nyatla	109:18f12ac01097	1418	//FIN受信->TIME_WAITへ(pureACK)
nyatla	109:18f12ac01097	1419	if(is_new_packet && (in_tcpflag & TCP_FIN)){
nyatla	109:18f12ac01097	1420	i_inst->uip_connr.rcv_nxt32++;
nyatla	109:18f12ac01097	1421	i_inst->tcpstateflags=UIP_TIME_WAIT;
nyatla	109:18f12ac01097	1422	}
nyatla	109:18f12ac01097	1423	break;
nyatla	109:18f12ac01097	1424	case UIP_CLOSING:
nyatla	109:18f12ac01097	1425	//ACK受信したら、TIME_WAITへ
nyatla	109:18f12ac01097	1426	if(num_of_noack==0){
nyatla	109:18f12ac01097	1427	i_inst->tcpstateflags=UIP_TIME_WAIT;
nyatla	109:18f12ac01097	1428	}
nyatla	109:18f12ac01097	1429	break;
nyatla	109:18f12ac01097	1430	case UIP_CLOSED:
nyatla	109:18f12ac01097	1431	//何もできない。何もしない。
nyatla	109:18f12ac01097	1432	break;
nyatla	109:18f12ac01097	1433	case UIP_TIME_WAIT:
nyatla	109:18f12ac01097	1434	//最終ACKを送り続ける。
nyatla	109:18f12ac01097	1435	break;
nyatla	109:18f12ac01097	1436	case UIP_SYN_SENT:
nyatla	109:18f12ac01097	1437	//connect関数実行中しか起動しないステータス
nyatla	109:18f12ac01097	1438	if(num_of_noack==0){
nyatla	109:18f12ac01097	1439	i_inst->tcpstateflags=UIP_ESTABLISHED;
nyatla	109:18f12ac01097	1440	i_inst->uip_connr.rcv_nxt32=NyLPC_ntohl(i_ipp->payload.tcp->seqno32)+1;
nyatla	109:18f12ac01097	1441	}else{
nyatla	109:18f12ac01097	1442	//それ以外のパケットはドロップする。
nyatla	109:18f12ac01097	1443	break;//goto DROP;
nyatla	109:18f12ac01097	1444	}
nyatla	109:18f12ac01097	1445	//ACKを送る。
nyatla	109:18f12ac01097	1446	break;
nyatla	109:18f12ac01097	1447	default:
nyatla	109:18f12ac01097	1448	goto DROP;
nyatla	109:18f12ac01097	1449	}
nyatla	109:18f12ac01097	1450	//ウインドウサイズを更新
nyatla	109:18f12ac01097	1451	i_inst->uip_connr.peer_win=NyLPC_ntohs(i_ipp->payload.tcp->wnd16);
nyatla	109:18f12ac01097	1452
nyatla	109:18f12ac01097	1453	//送信キューから、Peerが受信したデータを削除する。
nyatla	109:18f12ac01097	1454	if(in_tcpflag & TCP_ACK){
nyatla	109:18f12ac01097	1455	//再送パケットキューから送信済みのデータを回収(後で開放)
nyatla	109:18f12ac01097	1456	NyLPC_Trace();
nyatla	109:18f12ac01097	1457	s=updateTxQByIndex(i_inst,i_ipp->payload.tcp->ackno32,dlist);
nyatla	109:18f12ac01097	1458	NyLPC_Trace();
nyatla	109:18f12ac01097	1459	}else{
nyatla	109:18f12ac01097	1460	s=0;
nyatla	109:18f12ac01097	1461	}
nyatla	109:18f12ac01097	1462	//新しいパケットがきた場合は、再送キューのACKを更新する。
nyatla	109:18f12ac01097	1463	if(is_new_packet){
nyatla	109:18f12ac01097	1464	//再送キューのACKを更新
nyatla	109:18f12ac01097	1465	updateTxAck(i_inst,NyLPC_htonl(i_inst->uip_connr.rcv_nxt32));
nyatla	109:18f12ac01097	1466	}
nyatla	109:18f12ac01097	1467
nyatla	109:18f12ac01097	1468	//送信キューのない
nyatla	109:18f12ac01097	1469	if(((in_tcpflag&(TCP_FIN\|TCP_SYN))!=0x00) \|\|
nyatla	109:18f12ac01097	1470	((!is_new_packet) && (data_size>0)))
nyatla	109:18f12ac01097	1471	{
nyatla	109:18f12ac01097	1472	//ソケットからPureACKを生成 as setPacket(i_inst,i_ipp,TCP_ACK,NULL,0);
nyatla	109:18f12ac01097	1473	ret=NyLPC_cMiMicIpNetIf_allocSysTxBuf();
nyatla	109:18f12ac01097	1474	setTxPacket(i_inst,ret,TCP_ACK,NULL,0);
nyatla	109:18f12ac01097	1475	}else{
nyatla	109:18f12ac01097	1476	ret=NULL;
nyatla	109:18f12ac01097	1477	}
nyatla	109:18f12ac01097	1478	unlockResource(i_inst);
nyatla	109:18f12ac01097	1479	//取り外したTXメモリの開放
nyatla	109:18f12ac01097	1480	for(i=0;i<s;i++){
nyatla	109:18f12ac01097	1481	//取り外したTXメモリを開放
nyatla	109:18f12ac01097	1482	NyLPC_cMiMicIpNetIf_releaseTxBuf(dlist[i]);
nyatla	109:18f12ac01097	1483	}
nyatla	109:18f12ac01097	1484	NyLPC_Trace();
nyatla	109:18f12ac01097	1485	return ret;
nyatla	109:18f12ac01097	1486	DROP:
nyatla	109:18f12ac01097	1487	//ACKしたパケットを送信キューから削除
nyatla	109:18f12ac01097	1488	unlockResource(i_inst);
nyatla	109:18f12ac01097	1489	NyLPC_Trace();
nyatla	109:18f12ac01097	1490	return NULL;
nyatla	109:18f12ac01097	1491	}
nyatla	109:18f12ac01097	1492
nyatla	109:18f12ac01097	1493
nyatla	109:18f12ac01097	1494	/**
nyatla	109:18f12ac01097	1495	* 入力されたパケットからRSTパケットを生成して返す。
nyatla	109:18f12ac01097	1496	*/
nyatla	109:18f12ac01097	1497	void* NyLPC_cMiMicIpTcpSocket_allocTcpReverseRstAck(
nyatla	109:18f12ac01097	1498	const NyLPC_TcIPv4Payload_t* i_src)
nyatla	109:18f12ac01097	1499	{
nyatla	109:18f12ac01097	1500	struct NyLPC_TIPv4Header* iph;
nyatla	109:18f12ac01097	1501	struct NyLPC_TTcpHeader* tcph;
nyatla	109:18f12ac01097	1502	NyLPC_TUInt8 iph_word=0x05;
nyatla	109:18f12ac01097	1503	NyLPC_TUInt8 tcph_word=(UIP_TCPH_LEN) / 4;
nyatla	109:18f12ac01097	1504	void* txb=NyLPC_cMiMicIpNetIf_allocSysTxBuf();
nyatla	109:18f12ac01097	1505	//IPヘッダの更新
nyatla	109:18f12ac01097	1506	iph=(struct NyLPC_TIPv4Header*)txb;
nyatla	109:18f12ac01097	1507	iph->vhl=0x40\|(0x0f&iph_word);
nyatla	109:18f12ac01097	1508	iph->destipaddr=i_src->header->srcipaddr;
nyatla	109:18f12ac01097	1509	iph->srcipaddr =i_src->header->destipaddr;
nyatla	109:18f12ac01097	1510	NyLPC_TIPv4Header_writeTxIpHeader(iph,UIP_PROTO_TCP);
nyatla	109:18f12ac01097	1511
nyatla	109:18f12ac01097	1512	//TCPヘッダの更新
nyatla	109:18f12ac01097	1513	tcph=(struct NyLPC_TTcpHeader)(((NyLPC_TUInt8)txb)+NyLPC_TIPv4Header_getHeaderLength(iph));
nyatla	109:18f12ac01097	1514
nyatla	109:18f12ac01097	1515	tcph->tcpoffset=(tcph_word<<4);
nyatla	109:18f12ac01097	1516
nyatla	109:18f12ac01097	1517	tcph->flags = TCP_RST \| TCP_ACK;
nyatla	109:18f12ac01097	1518	//sorce & destination port
nyatla	109:18f12ac01097	1519	tcph->srcport = i_src->payload.tcp->destport;
nyatla	109:18f12ac01097	1520	tcph->destport = i_src->payload.tcp->srcport;
nyatla	109:18f12ac01097	1521	//ACK number
nyatla	109:18f12ac01097	1522	tcph->ackno32 = NyLPC_htonl(NyLPC_ntohl(i_src->payload.tcp->seqno32)+1);
nyatla	109:18f12ac01097	1523	//Seq Number
nyatla	109:18f12ac01097	1524	tcph->seqno32 = i_src->payload.tcp->ackno32;
nyatla	109:18f12ac01097	1525	//uip_func_tcp_send_noconn(BUF);
nyatla	109:18f12ac01097	1526	tcph->urgp[0] = tcph->urgp[1] = 0;
nyatla	109:18f12ac01097	1527	tcph->tcpchksum= 0;
nyatla	109:18f12ac01097	1528
nyatla	109:18f12ac01097	1529
nyatla	109:18f12ac01097	1530	//最終的なパケットサイズと必要ならペイロードを書き込み
nyatla	109:18f12ac01097	1531	iph->len16=NyLPC_htons((iph_word+tcph_word)*4);
nyatla	109:18f12ac01097	1532	//WND設定
nyatla	109:18f12ac01097	1533	tcph->wnd16=0;
nyatla	109:18f12ac01097	1534	//Checksumの生成
nyatla	109:18f12ac01097	1535	tcph->tcpchksum=~(NyLPC_TIPv4Header_makeTcpChecksum(iph));
nyatla	109:18f12ac01097	1536	iph->ipchksum = ~(NyLPC_TIPv4Header_makeIpChecksum(iph));
nyatla	109:18f12ac01097	1537	return txb;
nyatla	109:18f12ac01097	1538	}
nyatla	109:18f12ac01097	1539
nyatla	109:18f12ac01097	1540
nyatla	109:18f12ac01097	1541
nyatla	109:18f12ac01097	1542

Repository toolbox

Export to desktop IDE

Repository details

Type:	Library
Created:	28 Mar 2013
Imports:	145
Forks:	1
Commits:	115
Dependents:	14
Dependencies:	0
Followers:	17
Issues:	5

Components

MiMic Webservice library

構成