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@109:18f12ac01097, 2014-11-19 (annotated)

Committer:: nyatla
Date:: Wed Nov 19 14:45:17 2014 +0000
Revision:: 109:18f12ac01097
Child:: 110:257739f9b31e

new MiMicIP API;

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	109:18f12ac01097	72	#define lockResource(i_inst) NyLPC_cMutex_lock(NyLPC_cIPv4_getSockMutex(((i_inst)->_super._parent_ipv4)))
nyatla	109:18f12ac01097	73	#define unlockResource(i_inst) NyLPC_cMutex_unlock(NyLPC_cIPv4_getSockMutex(((i_inst)->_super._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	109:18f12ac01097	483	i_inst->_super._super.tcp_sock._interface=&_interface;
nyatla	109:18f12ac01097	484	NyLPC_cMiMicIpBaseSocket_initialize(&(i_inst->_super),NyLPC_TcMiMicIpBaseSocket_TYPEID_TCP_SOCK);
nyatla	109:18f12ac01097	485	//uipサービスは初期化済であること。
nyatla	109:18f12ac01097	486	NyLPC_Assert(NyLPC_cMiMicIpNetIf_isInitService());
nyatla	109:18f12ac01097	487
nyatla	109:18f12ac01097	488	NyLPC_cFifoBuffer_initialize(&(i_inst->rxbuf),i_rbuf,i_rbuf_len);
nyatla	109:18f12ac01097	489	// NyLPC_AbortIfNot(NyLPC_cMutex_initialize(&(i_inst->_smutex)));//個別Mutex
nyatla	109:18f12ac01097	490	// i_inst->_smutex=NyLPC_cIPv4_getSockMutex(&(srv->_tcpv4));//共有Mutex
nyatla	109:18f12ac01097	491	i_inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	492	i_inst->txbuf.rp=i_inst->txbuf.wp=0;
nyatla	109:18f12ac01097	493	for(i=0;i<NyLPC_TcTcpSocket_NUMBER_OF_TXQ;i++){
nyatla	109:18f12ac01097	494	i_inst->txbuf.txq[i].packet=NULL;
nyatla	109:18f12ac01097	495	}
nyatla	109:18f12ac01097	496	//管理リストへ登録。
nyatla	109:18f12ac01097	497	return NyLPC_cIPv4_addSocket(&(srv->_tcpv4),&(i_inst->_super));
nyatla	109:18f12ac01097	498	}
nyatla	109:18f12ac01097	499
nyatla	109:18f12ac01097	500
nyatla	109:18f12ac01097	501
nyatla	109:18f12ac01097	502	NyLPC_TBool NyLPC_cMiMicIpTcpSocket_listenSyn(NyLPC_TcMiMicIpTcpSocket_t* i_inst,const struct NyLPC_TTcpSocketSynParam* i_lq,NyLPC_TUInt16 i_lport)
nyatla	109:18f12ac01097	503	{
nyatla	109:18f12ac01097	504	// NyLPC_Assert(NyLPC_cMutex_isLocked(i_inst->_smutex));
nyatla	109:18f12ac01097	505	lockResource(i_inst);
nyatla	109:18f12ac01097	506	//ソケットが無効であること。
nyatla	109:18f12ac01097	507	if(i_inst->tcpstateflags==UIP_CLOSED)
nyatla	109:18f12ac01097	508	{
nyatla	109:18f12ac01097	509	//localipとdefault_mmsは別枠で設定
nyatla	109:18f12ac01097	510	/* Fill in the necessary fields for the new connection. */
nyatla	109:18f12ac01097	511	i_inst->uip_connr.current_rto32 = UIP_TCP_RTO_INITIAL;
nyatla	109:18f12ac01097	512	i_inst->uip_connr.lport = i_lport;
nyatla	109:18f12ac01097	513	i_inst->uip_connr.rport = i_lq->rport;
nyatla	109:18f12ac01097	514	i_inst->uip_connr.ripaddr=i_lq->srcaddr;
nyatla	109:18f12ac01097	515	i_inst->uip_connr.snd_nxt32=iss32;
nyatla	109:18f12ac01097	516	/* rcv_nxt should be the seqno from the incoming packet + 1. */
nyatla	109:18f12ac01097	517	i_inst->uip_connr.rcv_nxt32= i_lq->rcv_nxt32;
nyatla	109:18f12ac01097	518	//MSSの設定
nyatla	109:18f12ac01097	519	i_inst->uip_connr.peer_mss=(i_lq->mss!=0)?i_lq->mss:i_inst->uip_connr.default_mss;
nyatla	109:18f12ac01097	520	i_inst->uip_connr.peer_win=0;
nyatla	109:18f12ac01097	521	NyLPC_cFifoBuffer_clear(&(i_inst->rxbuf));
nyatla	109:18f12ac01097	522	//ここでステータスがかわる。
nyatla	109:18f12ac01097	523	i_inst->tcpstateflags = UIP_SYN_RCVD;
nyatla	109:18f12ac01097	524	//前回のデータが残っていた場合の保険
nyatla	109:18f12ac01097	525	if(i_inst->txbuf.rp!=i_inst->txbuf.wp){
nyatla	109:18f12ac01097	526	resetTxQWithUnlock(i_inst);
nyatla	109:18f12ac01097	527	}else{
nyatla	109:18f12ac01097	528	unlockResource(i_inst);
nyatla	109:18f12ac01097	529	}
nyatla	109:18f12ac01097	530	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	531	}
nyatla	109:18f12ac01097	532	unlockResource(i_inst);
nyatla	109:18f12ac01097	533	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	534	}
nyatla	109:18f12ac01097	535
nyatla	109:18f12ac01097	536
nyatla	109:18f12ac01097	537	/**
nyatla	109:18f12ac01097	538	* sq番のTxがキューから消え去るのを待ちます。
nyatla	109:18f12ac01097	539	* この関数は、アンロック状態でコールしてください。
nyatla	109:18f12ac01097	540	* <div>
nyatla	109:18f12ac01097	541	* パケットがキューからなくなる条件は、以下の２つです。
nyatla	109:18f12ac01097	542	* <ul>
nyatla	109:18f12ac01097	543	* <li>ACKを受信してパケットキューが更新された。</li>
nyatla	109:18f12ac01097	544	* <li>RSTを受信して(CLOSEDに遷移して)、キューがクリアされた。</li>
nyatla	109:18f12ac01097	545	* <li>送信タイムアウトで関数が(CLOSEDに遷移させて)キューをクリアした。</li>
nyatla	109:18f12ac01097	546	* </ul>
nyatla	109:18f12ac01097	547	* </div>
nyatla	109:18f12ac01097	548	* @param i_wait_msec
nyatla	109:18f12ac01097	549	* @return
nyatla	109:18f12ac01097	550	* 1番目の条件でパケットが消失したときのみ、TRUEを返します。
nyatla	109:18f12ac01097	551	* 失敗した場合、TCPステータスがCLOSEDでなければ、RSTを送信してステータスをCLOSEDにします。
nyatla	109:18f12ac01097	552	*/
nyatla	109:18f12ac01097	553	static NyLPC_TBool waitForTxRemove(NyLPC_TcMiMicIpTcpSocket_t* i_inst,NyLPC_TUInt32 i_sq,NyLPC_TcStopwatch_t* i_timer)
nyatla	109:18f12ac01097	554	{
nyatla	109:18f12ac01097	555	NyLPC_TUInt8 f;
nyatla	109:18f12ac01097	556	lockResource(i_inst);
nyatla	109:18f12ac01097	557	do{
nyatla	109:18f12ac01097	558	//パケットが送信中か調べる。
nyatla	109:18f12ac01097	559	if(!isPacketAcked(i_inst,i_sq)){
nyatla	109:18f12ac01097	560	//まだある場合は、タスクスイッチを繰り返して消失を待つ。
nyatla	109:18f12ac01097	561	unlockResource(i_inst);
nyatla	109:18f12ac01097	562	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	563	lockResource(i_inst);
nyatla	109:18f12ac01097	564	continue;
nyatla	109:18f12ac01097	565	}
nyatla	109:18f12ac01097	566	//なくなった場合は、原因を調べる。
nyatla	109:18f12ac01097	567	f=i_inst->tcpstateflags;
nyatla	109:18f12ac01097	568	unlockResource(i_inst);
nyatla	109:18f12ac01097	569	return (f==UIP_CLOSED)?NyLPC_TBool_FALSE:NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	570	}while(!NyLPC_cStopwatch_isExpired(i_timer));
nyatla	109:18f12ac01097	571	unlockResource(i_inst);
nyatla	109:18f12ac01097	572	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	573	}
nyatla	109:18f12ac01097	574
nyatla	109:18f12ac01097	575
nyatla	109:18f12ac01097	576	/**
nyatla	109:18f12ac01097	577	* 再送信処理をセットして、パケットを送信します。
nyatla	109:18f12ac01097	578	* この関数は「アンロック状態で」実行してください。
nyatla	109:18f12ac01097	579	* @param i_len
nyatla	109:18f12ac01097	580	* 送信データサイズを指定します。
nyatla	109:18f12ac01097	581	* この番号は、シーケンス番号の加算値ではありませんので、注意をしてください。
nyatla	109:18f12ac01097	582	* @return
nyatla	109:18f12ac01097	583	* <ul>
nyatla	109:18f12ac01097	584	* <li>n=-1:送信キューへの投入に失敗した。</li>
nyatla	109:18f12ac01097	585	* <li>n>=0:nバイトのデータを送信キューへの投入することに成功した。</li>
nyatla	109:18f12ac01097	586	* </ul>
nyatla	109:18f12ac01097	587	* 送信キューに失敗する理由は2つあります。1つは、TXバッファがフルでタイムアウト。もうひとつは、非同期なコネクリョンのリセットです。
nyatla	109:18f12ac01097	588	* 失敗した場合、TCPステータスがCLOSEDでなければ、RSTを送信してステータスをCLOSEDにします。
nyatla	109:18f12ac01097	589	*/
nyatla	109:18f12ac01097	590	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	591	{
nyatla	109:18f12ac01097	592	struct NyLPC_TcTcpSocket_TxQItem* txq;
nyatla	109:18f12ac01097	593	NyLPC_TUInt16 s;
nyatla	109:18f12ac01097	594	void* buf;
nyatla	109:18f12ac01097	595	NyLPC_TUInt32 next_ack;
nyatla	109:18f12ac01097	596	//送信バッファを取得
nyatla	109:18f12ac01097	597	//@bug オブションパケット送信時に4バイト足りないメモリ要求しない？問題になってないけど。
nyatla	109:18f12ac01097	598	for(;;){
nyatla	109:18f12ac01097	599	buf=NyLPC_cMiMicIpNetIf_allocTxBuf(i_len+(SIZE_OF_IPv4_TCPIP_HEADER),&s);
nyatla	109:18f12ac01097	600	if(buf!=NULL){
nyatla	109:18f12ac01097	601	break;
nyatla	109:18f12ac01097	602	}
nyatla	109:18f12ac01097	603	//タイムアウト確認
nyatla	109:18f12ac01097	604	if(NyLPC_cStopwatch_isExpired(i_timer)){
nyatla	109:18f12ac01097	605	return -1;
nyatla	109:18f12ac01097	606	}
nyatla	109:18f12ac01097	607	};
nyatla	109:18f12ac01097	608	lockResource(i_inst);
nyatla	109:18f12ac01097	609	//ペイロードがある場合のみ、相手のwindowサイズが0以上になるのを待つ。
nyatla	109:18f12ac01097	610	if(i_len>0){
nyatla	109:18f12ac01097	611	while(i_inst->uip_connr.peer_win==0){
nyatla	109:18f12ac01097	612	unlockResource(i_inst);
nyatla	109:18f12ac01097	613	//時間切れならエラー。
nyatla	109:18f12ac01097	614	if(NyLPC_cStopwatch_isExpired(i_timer)){
nyatla	109:18f12ac01097	615	return -1;
nyatla	109:18f12ac01097	616	}
nyatla	109:18f12ac01097	617	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	618	lockResource(i_inst);
nyatla	109:18f12ac01097	619	}
nyatla	109:18f12ac01097	620	}
nyatla	109:18f12ac01097	621	//送信キューの取得
nyatla	109:18f12ac01097	622	txq=getTxQ(i_inst,i_timer);
nyatla	109:18f12ac01097	623	//送信キューが取れなかった。
nyatla	109:18f12ac01097	624	if(txq==NULL){
nyatla	109:18f12ac01097	625	//シーケンス番号をロールバックできないので、エラーとする。
nyatla	109:18f12ac01097	626	unlockResource(i_inst);
nyatla	109:18f12ac01097	627	NyLPC_cMiMicIpNetIf_releaseTxBuf(buf);
nyatla	109:18f12ac01097	628	return -1;
nyatla	109:18f12ac01097	629	}
nyatla	109:18f12ac01097	630
nyatla	109:18f12ac01097	631	//送信バッファを基準とした送信サイズを計算
nyatla	109:18f12ac01097	632	s-=SIZE_OF_IPv4_TCPIP_HEADER;
nyatla	109:18f12ac01097	633	//送信サイズよりMMSが小さければ、送信サイズを修正
nyatla	109:18f12ac01097	634	if(i_inst->uip_connr.peer_mss<s){
nyatla	109:18f12ac01097	635	s=i_inst->uip_connr.peer_mss;
nyatla	109:18f12ac01097	636	}
nyatla	109:18f12ac01097	637	//送信サイズよりpeerのウインドウサイズが小さければ修正
nyatla	109:18f12ac01097	638	if(i_inst->uip_connr.peer_win<s){
nyatla	109:18f12ac01097	639	s=i_inst->uip_connr.peer_win;
nyatla	109:18f12ac01097	640	}
nyatla	109:18f12ac01097	641	//送信サイズより、データサイズが小さければ、送信サイズを修正
nyatla	109:18f12ac01097	642	if(i_len<s){
nyatla	109:18f12ac01097	643	s=i_len;
nyatla	109:18f12ac01097	644	}
nyatla	109:18f12ac01097	645	//ACK番号の計算
nyatla	109:18f12ac01097	646	next_ack=i_inst->uip_connr.snd_nxt32+s+(((i_tcpf&(TCP_FIN\|TCP_SYN))!=0x00)?1:0);
nyatla	109:18f12ac01097	647	txq->rto32=i_inst->uip_connr.current_rto32;
nyatla	109:18f12ac01097	648	txq->tick_of_sent=NyLPC_cStopwatch_now();
nyatla	109:18f12ac01097	649
nyatla	109:18f12ac01097	650	//パケットの書き込み
nyatla	109:18f12ac01097	651	setTxPacket(i_inst,buf,i_tcpf,i_buf,s);
nyatla	109:18f12ac01097	652	txq->packet=buf;
nyatla	109:18f12ac01097	653
nyatla	109:18f12ac01097	654	//シーケンス番号の更新
nyatla	109:18f12ac01097	655	i_inst->uip_connr.snd_nxt32=next_ack;
nyatla	109:18f12ac01097	656	//Peerのウインドウサイズを更新
nyatla	109:18f12ac01097	657	i_inst->uip_connr.peer_win-=s;
nyatla	109:18f12ac01097	658	//ACK番号の返却
nyatla	109:18f12ac01097	659	*o_ack=txq->ackno=NyLPC_HTONL(next_ack);
nyatla	109:18f12ac01097	660	unlockResource(i_inst);
nyatla	109:18f12ac01097	661	NyLPC_cMiMicIpNetIf_sendIPv4Tx(buf);
nyatla	109:18f12ac01097	662	return s;
nyatla	109:18f12ac01097	663	}
nyatla	109:18f12ac01097	664	/**
nyatla	109:18f12ac01097	665	* RSTを1フレームだけ送信します。
nyatla	109:18f12ac01097	666	* この関数は、クローズドステータスのソケットにしてからコールします。
nyatla	109:18f12ac01097	667	* この関数は、アンロック状態でコールしてね。
nyatla	109:18f12ac01097	668	*/
nyatla	109:18f12ac01097	669	static void sendRst(NyLPC_TcMiMicIpTcpSocket_t* i_inst)
nyatla	109:18f12ac01097	670	{
nyatla	109:18f12ac01097	671	void* buf;
nyatla	109:18f12ac01097	672
nyatla	109:18f12ac01097	673	NyLPC_Assert(i_inst->tcpstateflags==UIP_CLOSED);
nyatla	109:18f12ac01097	674	//ペイロードライタの初期化
nyatla	109:18f12ac01097	675
nyatla	109:18f12ac01097	676	//@bug バッファが取れるまで通信がブロックするの。ここはなんとかしないと。
nyatla	109:18f12ac01097	677	buf=NyLPC_cMiMicIpNetIf_allocSysTxBuf();
nyatla	109:18f12ac01097	678	lockResource(i_inst);
nyatla	109:18f12ac01097	679	i_inst->uip_connr.snd_nxt32++;
nyatla	109:18f12ac01097	680	unlockResource(i_inst);
nyatla	109:18f12ac01097	681	setTxPacket(i_inst,buf,TCP_RST\|TCP_ACK,NULL,0);
nyatla	109:18f12ac01097	682	NyLPC_cMiMicIpNetIf_sendIPv4Tx(buf);
nyatla	109:18f12ac01097	683	NyLPC_cMiMicIpNetIf_releaseTxBuf(buf);
nyatla	109:18f12ac01097	684	NyLPC_cIPv4Payload_finalize(&ipv4);
nyatla	109:18f12ac01097	685	return;
nyatla	109:18f12ac01097	686	}
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	static NyLPC_TBool addRecvData(NyLPC_TcMiMicIpTcpSocket_t* i_inst,const void* i_data,NyLPC_TUInt16 i_data_size)
nyatla	109:18f12ac01097	696	{
nyatla	109:18f12ac01097	697	//受信データサイズを確認
nyatla	109:18f12ac01097	698	if(NyLPC_cFifoBuffer_getSpace(&(i_inst->rxbuf))>=i_data_size){
nyatla	109:18f12ac01097	699	//バッファに格納可能なら、格納。
nyatla	109:18f12ac01097	700	NyLPC_cFifoBuffer_push(&(i_inst->rxbuf),i_data,i_data_size);
nyatla	109:18f12ac01097	701	}else{
nyatla	109:18f12ac01097	702	//エラー:ドロップする。
nyatla	109:18f12ac01097	703	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	704	}
nyatla	109:18f12ac01097	705
nyatla	109:18f12ac01097	706	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	707	}
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	* Public function
nyatla	109:18f12ac01097	715	*/
nyatla	109:18f12ac01097	716	static void finalize(NyLPC_TiTcpSocket_t* i_inst)
nyatla	109:18f12ac01097	717	{
nyatla	109:18f12ac01097	718	int i;
nyatla	109:18f12ac01097	719	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	720	NyLPC_Assert(NyLPC_cMiMicIpNetIf_isInitService());
nyatla	109:18f12ac01097	721	//uipサービスは初期化済であること。
nyatla	109:18f12ac01097	722	if(!NyLPC_cIPv4_removeSocket(&(_NyLPC_TcMiMicIpNetIf_inst->_tcpv4),&(inst->_super))){
nyatla	109:18f12ac01097	723	//削除失敗、それは死を意味する。
nyatla	109:18f12ac01097	724	NyLPC_Abort();
nyatla	109:18f12ac01097	725	}
nyatla	109:18f12ac01097	726	//開放漏れの保険
nyatla	109:18f12ac01097	727	if(inst->txbuf.rp!=inst->txbuf.wp){
nyatla	109:18f12ac01097	728	lockResource(inst);
nyatla	109:18f12ac01097	729	resetTxQWithUnlock(inst);
nyatla	109:18f12ac01097	730	}
nyatla	109:18f12ac01097	731	for(i=0;i<NyLPC_TcTcpSocket_NUMBER_OF_TXQ;i++){
nyatla	109:18f12ac01097	732	inst->txbuf.txq[i].packet=NULL;
nyatla	109:18f12ac01097	733	}
nyatla	109:18f12ac01097	734	NyLPC_cFifoBuffer_finalize(&(inst->rxbuf));
nyatla	109:18f12ac01097	735	// NyLPC_cMutex_finalize(&(i_inst->_smutex));
nyatla	109:18f12ac01097	736	NyLPC_cMiMicIpBaseSocket_finalize(&(inst->_super));
nyatla	109:18f12ac01097	737	NyLPC_cMiMicIpNetIf_releaseTcpSocketMemory(inst);
nyatla	109:18f12ac01097	738
nyatla	109:18f12ac01097	739	return;
nyatla	109:18f12ac01097	740	}
nyatla	109:18f12ac01097	741
nyatla	109:18f12ac01097	742	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	743	{
nyatla	109:18f12ac01097	744	volatile NyLPC_TUInt8 f;
nyatla	109:18f12ac01097	745	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	746	NyLPC_TUInt32 sq;
nyatla	109:18f12ac01097	747	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	748	NyLPC_TUInt16 lport;
nyatla	109:18f12ac01097	749	lockResource(inst);
nyatla	109:18f12ac01097	750	//ソケットが無効であること。
nyatla	109:18f12ac01097	751	if(inst->tcpstateflags!=UIP_CLOSED)
nyatla	109:18f12ac01097	752	{
nyatla	109:18f12ac01097	753	NyLPC_OnErrorGoto(Error);
nyatla	109:18f12ac01097	754	}
nyatla	109:18f12ac01097	755	//ポート番号の取得(lockResourceが他のソケットと共有なので、重複ポートの割当は起こりえない。でもちょっと注意して)
nyatla	109:18f12ac01097	756	lport=NyLPC_htons(NyLPC_cIPv4_getNewPortNumber(inst->_super._parent_ipv4));
nyatla	109:18f12ac01097	757	if(lport==0){
nyatla	109:18f12ac01097	758	NyLPC_OnErrorGoto(Error);
nyatla	109:18f12ac01097	759	}
nyatla	109:18f12ac01097	760	//connectの為の準備
nyatla	109:18f12ac01097	761
nyatla	109:18f12ac01097	762	//localipとdefault_mmsは別枠で設定
nyatla	109:18f12ac01097	763	/* Fill in the necessary fields for the new connection. */
nyatla	109:18f12ac01097	764	inst->uip_connr.current_rto32 = UIP_TCP_RTO_CONNECTION_INITIAL;//RTOを短くしてARP発行時の再接続短縮を期待する。
nyatla	109:18f12ac01097	765	inst->uip_connr.lport = lport;
nyatla	109:18f12ac01097	766	inst->uip_connr.rport = NyLPC_htons(i_peer_port);
nyatla	109:18f12ac01097	767	inst->uip_connr.ripaddr=*i_addr;
nyatla	109:18f12ac01097	768	inst->uip_connr.snd_nxt32=iss32;//should be random
nyatla	109:18f12ac01097	769	/* rcv_nxt should be the seqno from the incoming packet + 1. */
nyatla	109:18f12ac01097	770	inst->uip_connr.rcv_nxt32=0;
nyatla	109:18f12ac01097	771	//MSSの設定
nyatla	109:18f12ac01097	772	inst->uip_connr.peer_mss=inst->uip_connr.default_mss;
nyatla	109:18f12ac01097	773	inst->uip_connr.peer_win=1;//periodicの再送信を期待するために相手のWindowサイズは1と仮定する。
nyatla	109:18f12ac01097	774	NyLPC_cFifoBuffer_clear(&(inst->rxbuf));
nyatla	109:18f12ac01097	775	//ここでステータスがかわる。
nyatla	109:18f12ac01097	776	inst->tcpstateflags = UIP_SYN_SENT;
nyatla	109:18f12ac01097	777	//前回のデータが残っていた場合の保険
nyatla	109:18f12ac01097	778	if(inst->txbuf.rp!=inst->txbuf.wp){
nyatla	109:18f12ac01097	779	resetTxQWithUnlock(inst);
nyatla	109:18f12ac01097	780	}else{
nyatla	109:18f12ac01097	781	unlockResource(inst);
nyatla	109:18f12ac01097	782	}
nyatla	109:18f12ac01097	783
nyatla	109:18f12ac01097	784	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	785
nyatla	109:18f12ac01097	786	NyLPC_cStopwatch_startExpire(&sw,i_wait_in_msec);
nyatla	109:18f12ac01097	787	if(sendWithRetransmit(inst,TCP_SYN,NULL,0,&sw,&sq)==0){
nyatla	109:18f12ac01097	788	//ちょっと待つ。
nyatla	109:18f12ac01097	789	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	790	//キューにあるTXが消えるのを待つ。
nyatla	109:18f12ac01097	791	if(waitForTxRemove(inst,sq,&sw)){
nyatla	109:18f12ac01097	792	//ACK受信に成功して、TXが消失
nyatla	109:18f12ac01097	793	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	794	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	795	}
nyatla	109:18f12ac01097	796	}
nyatla	109:18f12ac01097	797	//ロックして、強制的なステータス遷移
nyatla	109:18f12ac01097	798	lockResource(inst);
nyatla	109:18f12ac01097	799	f=inst->tcpstateflags;
nyatla	109:18f12ac01097	800	if(f!=UIP_CLOSED){
nyatla	109:18f12ac01097	801	//もし、強制CLOSE遷移であれば、RSTも送信。
nyatla	109:18f12ac01097	802	inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	803	unlockResource(inst);
nyatla	109:18f12ac01097	804	sendRst(inst);
nyatla	109:18f12ac01097	805	}else{
nyatla	109:18f12ac01097	806	unlockResource(inst);
nyatla	109:18f12ac01097	807	}
nyatla	109:18f12ac01097	808	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	809	Error:
nyatla	109:18f12ac01097	810	unlockResource(inst);
nyatla	109:18f12ac01097	811	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	812	}
nyatla	109:18f12ac01097	813
nyatla	109:18f12ac01097	814	/**
nyatla	109:18f12ac01097	815	* この関数は、UIP_SYN_RCVDステータスのソケットを、ESTABLISHEDへ遷移させます。
nyatla	109:18f12ac01097	816	* cTcpListener_listen関数を通過したインスタンスに実行してください。
nyatla	109:18f12ac01097	817	* この関数は、アプリケーションが呼び出します。
nyatla	109:18f12ac01097	818	* @return
nyatla	109:18f12ac01097	819	*
nyatla	109:18f12ac01097	820	*/
nyatla	109:18f12ac01097	821	static NyLPC_TBool accept(NyLPC_TiTcpSocket_t* i_inst,NyLPC_TUInt32 i_wait_in_msec)
nyatla	109:18f12ac01097	822	{
nyatla	109:18f12ac01097	823	volatile NyLPC_TUInt8 f;
nyatla	109:18f12ac01097	824	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	825	NyLPC_TUInt32 sq;
nyatla	109:18f12ac01097	826	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	827
nyatla	109:18f12ac01097	828	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	829	//ステータスチェック
nyatla	109:18f12ac01097	830	f=inst->tcpstateflags;
nyatla	109:18f12ac01097	831	switch(f)
nyatla	109:18f12ac01097	832	{
nyatla	109:18f12ac01097	833	case UIP_ESTABLISHED:
nyatla	109:18f12ac01097	834	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	835	case UIP_SYN_RCVD:
nyatla	109:18f12ac01097	836	//処理対象
nyatla	109:18f12ac01097	837	break;
nyatla	109:18f12ac01097	838	default:
nyatla	109:18f12ac01097	839	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	840	}
nyatla	109:18f12ac01097	841	NyLPC_cStopwatch_startExpire(&sw,i_wait_in_msec);
nyatla	109:18f12ac01097	842	if(sendWithRetransmit(inst,TCP_SYN\|TCP_ACK,NULL,0,&sw,&sq)==0){
nyatla	109:18f12ac01097	843	//ちょっと待つ。
nyatla	109:18f12ac01097	844	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	845	//キューにあるTXが消えるのを待つ。
nyatla	109:18f12ac01097	846	if(waitForTxRemove(inst,sq,&sw)){
nyatla	109:18f12ac01097	847	//ACK受信に成功して、TXが消失
nyatla	109:18f12ac01097	848	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	849	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	850	}
nyatla	109:18f12ac01097	851	}
nyatla	109:18f12ac01097	852	//ロックして、強制的なステータス遷移
nyatla	109:18f12ac01097	853	lockResource(inst);
nyatla	109:18f12ac01097	854	f=inst->tcpstateflags;
nyatla	109:18f12ac01097	855	if(f!=UIP_CLOSED){
nyatla	109:18f12ac01097	856	//もし、強制CLOSE遷移であれば、RSTも送信。
nyatla	109:18f12ac01097	857	inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	858	unlockResource(inst);
nyatla	109:18f12ac01097	859	sendRst(inst);
nyatla	109:18f12ac01097	860	}else{
nyatla	109:18f12ac01097	861	unlockResource(inst);
nyatla	109:18f12ac01097	862	}
nyatla	109:18f12ac01097	863	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	864	}
nyatla	109:18f12ac01097	865
nyatla	109:18f12ac01097	866
nyatla	109:18f12ac01097	867	/**
nyatla	109:18f12ac01097	868	* この関数は、ソケットの受信バッファの読み取り位置と、読み出せるデータサイズを返却します。
nyatla	109:18f12ac01097	869	* 関数はポインターを返却するだけで、バッファの読み取り位置をシークしません。
nyatla	109:18f12ac01097	870	* シークするにはNyLPC_cTcpSocket_pseekを使います。
nyatla	109:18f12ac01097	871	*/
nyatla	109:18f12ac01097	872	static NyLPC_TInt32 precv(NyLPC_TiTcpSocket_t* i_inst,const void** o_buf_ptr,NyLPC_TUInt32 i_wait_msec)
nyatla	109:18f12ac01097	873	{
nyatla	109:18f12ac01097	874	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	875	volatile NyLPC_TUInt8 st;
nyatla	109:18f12ac01097	876	NyLPC_TUInt16 rlen;
nyatla	109:18f12ac01097	877	//タイマを生成
nyatla	109:18f12ac01097	878	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	879	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	880
nyatla	109:18f12ac01097	881	//ESTABLISHED以外の場合は、エラー。
nyatla	109:18f12ac01097	882	NyLPC_cStopwatch_setNow(&sw);
nyatla	109:18f12ac01097	883	do{
nyatla	109:18f12ac01097	884	//読み出しバッファ情報のコピー
nyatla	109:18f12ac01097	885	//MUTEX LOCK
nyatla	109:18f12ac01097	886	lockResource(inst);
nyatla	109:18f12ac01097	887	st=inst->tcpstateflags;
nyatla	109:18f12ac01097	888	rlen=NyLPC_cFifoBuffer_getLength(&(inst->rxbuf));
nyatla	109:18f12ac01097	889	*o_buf_ptr=NyLPC_cFifoBuffer_getPtr(&(inst->rxbuf));
nyatla	109:18f12ac01097	890	//MUTEX UNLOCK
nyatla	109:18f12ac01097	891	unlockResource(inst);
nyatla	109:18f12ac01097	892
nyatla	109:18f12ac01097	893	//バッファが空の場合は、ステータスチェック。ESTABLISHEDでなければ、エラー(PASVCLOSE等の場合)
nyatla	109:18f12ac01097	894	switch(st){
nyatla	109:18f12ac01097	895	case UIP_ESTABLISHED:
nyatla	109:18f12ac01097	896	if(rlen>0){
nyatla	109:18f12ac01097	897	//バッファにパケットがあれば返却
nyatla	109:18f12ac01097	898	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	899	return rlen;
nyatla	109:18f12ac01097	900	}
nyatla	109:18f12ac01097	901	break;
nyatla	109:18f12ac01097	902	case UIP_CLOSE_WAIT:
nyatla	109:18f12ac01097	903	if(rlen>0){
nyatla	109:18f12ac01097	904	//バッファにパケットがあれば返却
nyatla	109:18f12ac01097	905	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	906	return rlen;
nyatla	109:18f12ac01097	907	}
nyatla	109:18f12ac01097	908	//引き続きエラー処理
nyatla	109:18f12ac01097	909	default:
nyatla	109:18f12ac01097	910	//他の場合はエラー
nyatla	109:18f12ac01097	911	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	912	return -1;
nyatla	109:18f12ac01097	913	}
nyatla	109:18f12ac01097	914	//タスクスイッチ
nyatla	109:18f12ac01097	915	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	916	}while(NyLPC_cStopwatch_elapseInMsec(&sw)<i_wait_msec);
nyatla	109:18f12ac01097	917	//規定時間内に受信が成功しなかった。
nyatla	109:18f12ac01097	918	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	919	return 0;
nyatla	109:18f12ac01097	920	}
nyatla	109:18f12ac01097	921	/**
nyatla	109:18f12ac01097	922	* 受信バッファをシークします。
nyatla	109:18f12ac01097	923	* シーク後に、遅延ACKを送出します。
nyatla	109:18f12ac01097	924	*/
nyatla	109:18f12ac01097	925	static void pseek(NyLPC_TiTcpSocket_t* i_inst,NyLPC_TUInt16 i_seek)
nyatla	109:18f12ac01097	926	{
nyatla	109:18f12ac01097	927	void* buf;
nyatla	109:18f12ac01097	928	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	929
nyatla	109:18f12ac01097	930	NyLPC_ArgAssert(i_seek<=NyLPC_cFifoBuffer_getLength(&(inst->rxbuf)));
nyatla	109:18f12ac01097	931	if(i_seek==0){
nyatla	109:18f12ac01097	932	return;
nyatla	109:18f12ac01097	933	}
nyatla	109:18f12ac01097	934
nyatla	109:18f12ac01097	935	//ACK送信バッファの取得
nyatla	109:18f12ac01097	936	buf=NyLPC_cMiMicIpNetIf_allocSysTxBuf();
nyatla	109:18f12ac01097	937
nyatla	109:18f12ac01097	938	//MUTEX LOCK
nyatla	109:18f12ac01097	939	lockResource(inst);
nyatla	109:18f12ac01097	940
nyatla	109:18f12ac01097	941	//受信バッファを読み出しシーク
nyatla	109:18f12ac01097	942	NyLPC_cFifoBuffer_pop(&(inst->rxbuf),i_seek);
nyatla	109:18f12ac01097	943	//ACKパケットの生成
nyatla	109:18f12ac01097	944	setTxPacket(inst,buf,TCP_ACK,NULL,0);
nyatla	109:18f12ac01097	945	unlockResource(inst);
nyatla	109:18f12ac01097	946	//ACK送信
nyatla	109:18f12ac01097	947	NyLPC_cMiMicIpNetIf_sendIPv4Tx(buf);
nyatla	109:18f12ac01097	948	NyLPC_cMiMicIpNetIf_releaseTxBuf(buf);
nyatla	109:18f12ac01097	949
nyatla	109:18f12ac01097	950	}
nyatla	109:18f12ac01097	951
nyatla	109:18f12ac01097	952	/**
nyatla	109:18f12ac01097	953	* See header file.
nyatla	109:18f12ac01097	954	*/
nyatla	109:18f12ac01097	955	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	956	{
nyatla	109:18f12ac01097	957	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	958
nyatla	109:18f12ac01097	959	NyLPC_TUInt16 s;
nyatla	109:18f12ac01097	960	void* buf;
nyatla	109:18f12ac01097	961	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	962
nyatla	109:18f12ac01097	963	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	964	NyLPC_cStopwatch_startExpire(&sw,i_wait_in_msec);
nyatla	109:18f12ac01097	965
nyatla	109:18f12ac01097	966	//送信バッファを取得
nyatla	109:18f12ac01097	967	//@bug バッファが取れるまで通信がブロックするの。ここはなんとかしないと。
nyatla	109:18f12ac01097	968	for(;;){
nyatla	109:18f12ac01097	969	//ESTABLISHED以外に非同期遷移
nyatla	109:18f12ac01097	970	if(inst->tcpstateflags!=UIP_ESTABLISHED){
nyatla	109:18f12ac01097	971	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	972	return NULL;
nyatla	109:18f12ac01097	973	}
nyatla	109:18f12ac01097	974	buf=NyLPC_cMiMicIpNetIf_allocTxBuf(i_hint+(SIZE_OF_IPv4_TCPIP_HEADER),&s);
nyatla	109:18f12ac01097	975	if(buf!=NULL){
nyatla	109:18f12ac01097	976	break;
nyatla	109:18f12ac01097	977	}
nyatla	109:18f12ac01097	978	//タイムアウト時もエラー
nyatla	109:18f12ac01097	979	if(NyLPC_cStopwatch_isExpired(&sw)){
nyatla	109:18f12ac01097	980	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	981	return NULL;
nyatla	109:18f12ac01097	982	}
nyatla	109:18f12ac01097	983	}
nyatla	109:18f12ac01097	984
nyatla	109:18f12ac01097	985	//@todo 前段処理と順番を入れ替えて、要求サイズとpeerのwinのうち、小さいほうを割り当てたほうが良くない？
nyatla	109:18f12ac01097	986	//ここで相手のwin待ちをする理由は、相手に確実に受け取れるサイズを決定する為。
nyatla	109:18f12ac01097	987	lockResource(inst);
nyatla	109:18f12ac01097	988	//ペイロードがある場合のみ、相手のwindowサイズが0以上になるのを待つ。
nyatla	109:18f12ac01097	989	while(inst->uip_connr.peer_win==0){
nyatla	109:18f12ac01097	990	unlockResource(inst);
nyatla	109:18f12ac01097	991	//ESTABLISHED以外に非同期遷移 orタイムアウト確認
nyatla	109:18f12ac01097	992	if(NyLPC_cStopwatch_isExpired(&sw)\|\|(inst->tcpstateflags!=UIP_ESTABLISHED)){
nyatla	109:18f12ac01097	993	NyLPC_cMiMicIpNetIf_releaseTxBuf(buf);
nyatla	109:18f12ac01097	994	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	995	return NULL;
nyatla	109:18f12ac01097	996	}
nyatla	109:18f12ac01097	997	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	998	lockResource(inst);
nyatla	109:18f12ac01097	999	}
nyatla	109:18f12ac01097	1000	//送信バッファを基準とした送信サイズを計算
nyatla	109:18f12ac01097	1001	s-=SIZE_OF_IPv4_TCPIP_HEADER;
nyatla	109:18f12ac01097	1002	//送信サイズよりMMSが小さければ、送信サイズを修正
nyatla	109:18f12ac01097	1003	if(inst->uip_connr.peer_mss<s){
nyatla	109:18f12ac01097	1004	s=inst->uip_connr.peer_mss;
nyatla	109:18f12ac01097	1005	}
nyatla	109:18f12ac01097	1006	//送信サイズよりpeerのウインドウサイズが小さければ修正
nyatla	109:18f12ac01097	1007	if(inst->uip_connr.peer_win<s){
nyatla	109:18f12ac01097	1008	s=inst->uip_connr.peer_win;
nyatla	109:18f12ac01097	1009	}
nyatla	109:18f12ac01097	1010	unlockResource(inst);
nyatla	109:18f12ac01097	1011	//バッファサイズ確定。
nyatla	109:18f12ac01097	1012	*o_buf_size=s;
nyatla	109:18f12ac01097	1013	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	1014	return (NyLPC_TUInt8*)buf+SIZE_OF_IPv4_TCPIP_HEADER;
nyatla	109:18f12ac01097	1015	}
nyatla	109:18f12ac01097	1016	/**
nyatla	109:18f12ac01097	1017	* See Header file.
nyatla	109:18f12ac01097	1018	*/
nyatla	109:18f12ac01097	1019	static void releaseSendBuf(NyLPC_TiTcpSocket_t* i_inst,void* i_buf_ptr)
nyatla	109:18f12ac01097	1020	{
nyatla	109:18f12ac01097	1021	NyLPC_cMiMicIpNetIf_releaseTxBuf((NyLPC_TUInt8*)i_buf_ptr-SIZE_OF_IPv4_TCPIP_HEADER);
nyatla	109:18f12ac01097	1022	}
nyatla	109:18f12ac01097	1023
nyatla	109:18f12ac01097	1024
nyatla	109:18f12ac01097	1025	/**
nyatla	109:18f12ac01097	1026	* 事前にAllocしたTxパケットを送信します。
nyatla	109:18f12ac01097	1027	* このAPIはゼロコピー送信をサポートするためのものです。
nyatla	109:18f12ac01097	1028	* @param i_buf_ptr
nyatla	109:18f12ac01097	1029	* allocSendBufで取得したメモリを指定します。
nyatla	109:18f12ac01097	1030	* @return
nyatla	109:18f12ac01097	1031	* 関数が失敗した場合、i_buf_ptrは「開放されません。」
nyatla	109:18f12ac01097	1032	*/
nyatla	109:18f12ac01097	1033	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	1034	{
nyatla	109:18f12ac01097	1035	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	1036	struct NyLPC_TcTcpSocket_TxQItem* txq;
nyatla	109:18f12ac01097	1037	void* buf;
nyatla	109:18f12ac01097	1038	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	1039	//ESTABLISHEDでなければエラー
nyatla	109:18f12ac01097	1040	if(inst->tcpstateflags!=UIP_ESTABLISHED){
nyatla	109:18f12ac01097	1041	//ESTABLISHEDでなければエラー
nyatla	109:18f12ac01097	1042	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	1043	}
nyatla	109:18f12ac01097	1044	//送信データ0なら何もしない。
nyatla	109:18f12ac01097	1045	if(i_len<1){
nyatla	109:18f12ac01097	1046	releaseSendBuf(i_inst,i_buf_ptr);
nyatla	109:18f12ac01097	1047	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	1048	}
nyatla	109:18f12ac01097	1049	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	1050	NyLPC_cStopwatch_startExpire(&sw,i_wait_in_msec);
nyatla	109:18f12ac01097	1051
nyatla	109:18f12ac01097	1052	//先頭ポインタは、i_buf-sizeof(SIZE_OF_IPv4_TCPIP_HEADER)固定
nyatla	109:18f12ac01097	1053	buf=(NyLPC_TUInt8*)i_buf_ptr-SIZE_OF_IPv4_TCPIP_HEADER;
nyatla	109:18f12ac01097	1054	lockResource(inst);
nyatla	109:18f12ac01097	1055	//送信キューの取得
nyatla	109:18f12ac01097	1056	txq=getTxQ(inst,&sw);
nyatla	109:18f12ac01097	1057	//送信キューが取れなかった。
nyatla	109:18f12ac01097	1058	if(txq==NULL){
nyatla	109:18f12ac01097	1059	//シーケンス番号をロールバックできないので、エラーとする。
nyatla	109:18f12ac01097	1060	unlockResource(inst);
nyatla	109:18f12ac01097	1061	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	1062	return NyLPC_TBool_FALSE;
nyatla	109:18f12ac01097	1063	}
nyatla	109:18f12ac01097	1064	//ここから先はi_bufの所有権はインスタンスになってる。
nyatla	109:18f12ac01097	1065
nyatla	109:18f12ac01097	1066	//IPv4ペイロードの書き込み
nyatla	109:18f12ac01097	1067
nyatla	109:18f12ac01097	1068	//allocをした時点でwin,mssは考慮されているので、そのままそうしんしる。
nyatla	109:18f12ac01097	1069
nyatla	109:18f12ac01097	1070	//ACK番号の計算
nyatla	109:18f12ac01097	1071	txq->rto32=inst->uip_connr.current_rto32;
nyatla	109:18f12ac01097	1072	txq->tick_of_sent=NyLPC_cStopwatch_now();
nyatla	109:18f12ac01097	1073	//パケットヘッダの生成(ヘッダ長はpreadで定義した値(4+6)*4=40です。)
nyatla	109:18f12ac01097	1074	setTxPacketHeader(inst,buf,TCP_ACK\|TCP_PSH,i_len);
nyatla	109:18f12ac01097	1075	txq->packet=buf;
nyatla	109:18f12ac01097	1076
nyatla	109:18f12ac01097	1077	//シーケンス番号の更新
nyatla	109:18f12ac01097	1078	inst->uip_connr.snd_nxt32=inst->uip_connr.snd_nxt32+i_len;
nyatla	109:18f12ac01097	1079	//Peerのウインドウサイズを更新
nyatla	109:18f12ac01097	1080	inst->uip_connr.peer_win-=i_len;
nyatla	109:18f12ac01097	1081	//ACK番号の返却
nyatla	109:18f12ac01097	1082	txq->ackno=NyLPC_HTONL(inst->uip_connr.snd_nxt32);
nyatla	109:18f12ac01097	1083	unlockResource(inst);
nyatla	109:18f12ac01097	1084	NyLPC_cMiMicIpNetIf_sendIPv4Tx(buf);
nyatla	109:18f12ac01097	1085	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	1086	return NyLPC_TBool_TRUE;
nyatla	109:18f12ac01097	1087	}
nyatla	109:18f12ac01097	1088
nyatla	109:18f12ac01097	1089	/**
nyatla	109:18f12ac01097	1090	* See header file.
nyatla	109:18f12ac01097	1091	*/
nyatla	109:18f12ac01097	1092	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	1093	{
nyatla	109:18f12ac01097	1094	NyLPC_TInt16 hint;
nyatla	109:18f12ac01097	1095	NyLPC_TUInt16 s;
nyatla	109:18f12ac01097	1096	void* buf;
nyatla	109:18f12ac01097	1097	if(i_len<1){
nyatla	109:18f12ac01097	1098	return 0;
nyatla	109:18f12ac01097	1099	}
nyatla	109:18f12ac01097	1100	hint=(i_len>32767)?32767:i_len;
nyatla	109:18f12ac01097	1101	buf=allocSendBuf(i_inst,hint,&s,i_wait_in_msec);
nyatla	109:18f12ac01097	1102	if(buf==NULL){
nyatla	109:18f12ac01097	1103	return -1;
nyatla	109:18f12ac01097	1104	}
nyatla	109:18f12ac01097	1105	//送信サイズの計算
nyatla	109:18f12ac01097	1106	s=((NyLPC_TInt32)s<i_len)?s:(NyLPC_TUInt16)i_len;
nyatla	109:18f12ac01097	1107	memcpy(buf,i_buf_ptr,s);
nyatla	109:18f12ac01097	1108	if(!psend(i_inst,buf,s,i_wait_in_msec)){
nyatla	109:18f12ac01097	1109	releaseSendBuf(i_inst,buf);
nyatla	109:18f12ac01097	1110	return -1;//error
nyatla	109:18f12ac01097	1111	}
nyatla	109:18f12ac01097	1112	return s;
nyatla	109:18f12ac01097	1113	}
nyatla	109:18f12ac01097	1114
nyatla	109:18f12ac01097	1115
nyatla	109:18f12ac01097	1116	static void close(NyLPC_TiTcpSocket_t* i_inst,NyLPC_TUInt32 i_wait_in_msec)
nyatla	109:18f12ac01097	1117	{
nyatla	109:18f12ac01097	1118	NyLPC_TcMiMicIpTcpSocket_t* inst=(NyLPC_TcMiMicIpTcpSocket_t*)i_inst;
nyatla	109:18f12ac01097	1119	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	1120	volatile NyLPC_TUInt8 f;
nyatla	109:18f12ac01097	1121	NyLPC_TUInt32 sq;
nyatla	109:18f12ac01097	1122	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	1123	NyLPC_cStopwatch_startExpire(&sw,i_wait_in_msec);
nyatla	109:18f12ac01097	1124	lockResource(inst);
nyatla	109:18f12ac01097	1125
nyatla	109:18f12ac01097	1126	f=inst->tcpstateflags;
nyatla	109:18f12ac01097	1127	//ステータスチェック
nyatla	109:18f12ac01097	1128	switch(f)
nyatla	109:18f12ac01097	1129	{
nyatla	109:18f12ac01097	1130	case UIP_CLOSED:
nyatla	109:18f12ac01097	1131	//閉じている。
nyatla	109:18f12ac01097	1132	goto ReturnWithUnlock;
nyatla	109:18f12ac01097	1133	case UIP_ESTABLISHED:
nyatla	109:18f12ac01097	1134	//アクティブクローズ。
nyatla	109:18f12ac01097	1135	inst->tcpstateflags=UIP_FIN_WAIT_1;
nyatla	109:18f12ac01097	1136	//送信のために一旦解除
nyatla	109:18f12ac01097	1137	unlockResource(inst);
nyatla	109:18f12ac01097	1138	//FINの送信
nyatla	109:18f12ac01097	1139	if(sendWithRetransmit(inst,TCP_FIN\|TCP_ACK,NULL,0,&sw,&sq)==0){
nyatla	109:18f12ac01097	1140	//ちょっと待つ。
nyatla	109:18f12ac01097	1141	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	1142	//TXの消去待ち
nyatla	109:18f12ac01097	1143	if(waitForTxRemove(inst,sq,&sw)){
nyatla	109:18f12ac01097	1144	//再ロック
nyatla	109:18f12ac01097	1145	lockResource(inst);
nyatla	109:18f12ac01097	1146	//タイムアウトするか、UIP_CLOSED、もしくはTIME_WAITに遷移するのを待つ。(遷移はRxprocで自動的に実行。)
nyatla	109:18f12ac01097	1147	do{
nyatla	109:18f12ac01097	1148	switch(inst->tcpstateflags)
nyatla	109:18f12ac01097	1149	{
nyatla	109:18f12ac01097	1150	case UIP_TIME_WAIT:
nyatla	109:18f12ac01097	1151	inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	1152	case UIP_CLOSED:
nyatla	109:18f12ac01097	1153	NyLPC_Assert(inst->txbuf.rp==inst->txbuf.wp);
nyatla	109:18f12ac01097	1154	//成功。
nyatla	109:18f12ac01097	1155	goto ReturnWithUnlock;
nyatla	109:18f12ac01097	1156	case UIP_FIN_WAIT_1:
nyatla	109:18f12ac01097	1157	case UIP_FIN_WAIT_2:
nyatla	109:18f12ac01097	1158	case UIP_CLOSING:
nyatla	109:18f12ac01097	1159	//一時的なアンロック
nyatla	109:18f12ac01097	1160	unlockResource(inst);
nyatla	109:18f12ac01097	1161	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	1162	lockResource(inst);
nyatla	109:18f12ac01097	1163	default:
nyatla	109:18f12ac01097	1164	break;
nyatla	109:18f12ac01097	1165	}
nyatla	109:18f12ac01097	1166	}while(!NyLPC_cStopwatch_isExpired(&sw));
nyatla	109:18f12ac01097	1167	unlockResource(inst);
nyatla	109:18f12ac01097	1168	}
nyatla	109:18f12ac01097	1169	}
nyatla	109:18f12ac01097	1170	break;
nyatla	109:18f12ac01097	1171	case UIP_CLOSE_WAIT:
nyatla	109:18f12ac01097	1172	//LAST_ACKへ遷移
nyatla	109:18f12ac01097	1173	inst->tcpstateflags=UIP_LAST_ACK;
nyatla	109:18f12ac01097	1174	//送信のために一旦解除
nyatla	109:18f12ac01097	1175	unlockResource(inst);
nyatla	109:18f12ac01097	1176	if(sendWithRetransmit(inst,TCP_FIN\|TCP_ACK,NULL,0,&sw,&sq)==0){
nyatla	109:18f12ac01097	1177	//ちょっと待つ。
nyatla	109:18f12ac01097	1178	NyLPC_cThread_yield();
nyatla	109:18f12ac01097	1179	//TXの消去待ち
nyatla	109:18f12ac01097	1180	if(waitForTxRemove(inst,sq,&sw)){
nyatla	109:18f12ac01097	1181	//再ロック
nyatla	109:18f12ac01097	1182	lockResource(inst);
nyatla	109:18f12ac01097	1183	//TX消去後にCLOSEDに遷移していればOK
nyatla	109:18f12ac01097	1184	if(inst->tcpstateflags==UIP_CLOSED)
nyatla	109:18f12ac01097	1185	{
nyatla	109:18f12ac01097	1186	NyLPC_Assert(inst->txbuf.rp==inst->txbuf.wp);
nyatla	109:18f12ac01097	1187	goto ReturnWithUnlock;
nyatla	109:18f12ac01097	1188	}
nyatla	109:18f12ac01097	1189	unlockResource(inst);
nyatla	109:18f12ac01097	1190	}
nyatla	109:18f12ac01097	1191	}
nyatla	109:18f12ac01097	1192	//エラー。RSTで切断。
nyatla	109:18f12ac01097	1193	break;
nyatla	109:18f12ac01097	1194	default:
nyatla	109:18f12ac01097	1195	unlockResource(inst);
nyatla	109:18f12ac01097	1196	NyLPC_Warning();
nyatla	109:18f12ac01097	1197	break;
nyatla	109:18f12ac01097	1198	}
nyatla	109:18f12ac01097	1199	// if(i_inst->_smutex._lock_count>0){
nyatla	109:18f12ac01097	1200	// NyLPC_Warning();
nyatla	109:18f12ac01097	1201	// }
nyatla	109:18f12ac01097	1202	//このパスに到達するのは、FIN送信/ACKに成功したにも拘らず、規定時間内にCLOSEDに遷移しなかった場合。
nyatla	109:18f12ac01097	1203	//コネクションを強制遷移して、RST
nyatla	109:18f12ac01097	1204	lockResource(inst);
nyatla	109:18f12ac01097	1205	f=inst->tcpstateflags;
nyatla	109:18f12ac01097	1206	if(f!=UIP_CLOSED){
nyatla	109:18f12ac01097	1207	//もし、強制CLOSE遷移であれば、RSTも送信。
nyatla	109:18f12ac01097	1208	inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	1209	unlockResource(inst);
nyatla	109:18f12ac01097	1210	sendRst(inst);
nyatla	109:18f12ac01097	1211	}else{
nyatla	109:18f12ac01097	1212	unlockResource(inst);
nyatla	109:18f12ac01097	1213	}
nyatla	109:18f12ac01097	1214	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	1215	return;
nyatla	109:18f12ac01097	1216	ReturnWithUnlock:
nyatla	109:18f12ac01097	1217	unlockResource(inst);
nyatla	109:18f12ac01097	1218	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	1219	return;
nyatla	109:18f12ac01097	1220	}
nyatla	109:18f12ac01097	1221
nyatla	109:18f12ac01097	1222	/**
nyatla	109:18f12ac01097	1223	* uipサービスタスクが実行する関数です。
nyatla	109:18f12ac01097	1224	* 定期的に実行する関数。最低でも1s単位で実行してください。
nyatla	109:18f12ac01097	1225	*/
nyatla	109:18f12ac01097	1226	void NyLPC_cMiMicIpTcpSocket_periodic(
nyatla	109:18f12ac01097	1227	NyLPC_TcMiMicIpTcpSocket_t* i_inst)
nyatla	109:18f12ac01097	1228	{
nyatla	109:18f12ac01097	1229	int i;
nyatla	109:18f12ac01097	1230	struct NyLPC_TcTcpSocket_TxQItem* q=i_inst->txbuf.txq;
nyatla	109:18f12ac01097	1231	NyLPC_TcStopwatch_t sw;
nyatla	109:18f12ac01097	1232	NyLPC_TUInt32 now;
nyatla	109:18f12ac01097	1233	int rp;
nyatla	109:18f12ac01097	1234	NyLPC_cStopwatch_initialize(&sw);
nyatla	109:18f12ac01097	1235	now=NyLPC_cStopwatch_now();
nyatla	109:18f12ac01097	1236	//MUTEX LOCK
nyatla	109:18f12ac01097	1237	lockResource(i_inst);
nyatla	109:18f12ac01097	1238	if(i_inst->tcpstateflags==UIP_CLOSED)
nyatla	109:18f12ac01097	1239	{
nyatla	109:18f12ac01097	1240	//CLOSEDなら、バッファ開放。
nyatla	109:18f12ac01097	1241	resetTxQWithUnlock(i_inst);
nyatla	109:18f12ac01097	1242	}else if(i_inst->txbuf.rp==i_inst->txbuf.wp){
nyatla	109:18f12ac01097	1243	//再送信パケットがなければ何もしないよ。
nyatla	109:18f12ac01097	1244	unlockResource(i_inst);
nyatla	109:18f12ac01097	1245	}else if(i_inst->uip_connr.peer_win==0){
nyatla	109:18f12ac01097	1246	//peer_winが0の場合は何もしない。
nyatla	109:18f12ac01097	1247	unlockResource(i_inst);
nyatla	109:18f12ac01097	1248	}else{
nyatla	109:18f12ac01097	1249	//再送信処理
nyatla	109:18f12ac01097	1250	rp=i_inst->txbuf.rp;
nyatla	109:18f12ac01097	1251	NyLPC_cStopwatch_set(&sw,q[rp].tick_of_sent);
nyatla	109:18f12ac01097	1252	if(NyLPC_cStopwatch_elapseInMsec(&sw)>q[rp].rto32){
nyatla	109:18f12ac01097	1253	//最古のパケットの送信時間をチェックして、タイムアウトが発生したら、再送時間と送信時刻をセット
nyatla	109:18f12ac01097	1254	//最古パケットRTOを2倍。
nyatla	109:18f12ac01097	1255	q[rp].rto32*=2;
nyatla	109:18f12ac01097	1256	for(i=rp;i!=i_inst->txbuf.wp;i=(i+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ){
nyatla	109:18f12ac01097	1257	q[i].tick_of_sent=now;
nyatla	109:18f12ac01097	1258	}
nyatla	109:18f12ac01097	1259	if(q[rp].rto32>UIP_IP_RTO_MAX_RTO){
nyatla	109:18f12ac01097	1260	//最古のRTOが64秒を超えたら、CLOSED
nyatla	109:18f12ac01097	1261	i_inst->tcpstateflags =UIP_CLOSED;
nyatla	109:18f12ac01097	1262	resetTxQWithUnlock(i_inst);
nyatla	109:18f12ac01097	1263	sendRst(i_inst);
nyatla	109:18f12ac01097	1264	}else{
nyatla	109:18f12ac01097	1265	//規定時間内なら、再送処理
nyatla	109:18f12ac01097	1266	for(i=rp;i!=i_inst->txbuf.wp;i=(i+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ){
nyatla	109:18f12ac01097	1267	// NyLPC_cUipService_sendIPv4Tx(NyLPC_cIPv4Payload_getBuf(&(q[i].data)));
nyatla	109:18f12ac01097	1268	NyLPC_cMiMicIpNetIf_sendIPv4Tx(q[i].packet);
nyatla	109:18f12ac01097	1269	}
nyatla	109:18f12ac01097	1270	unlockResource(i_inst);
nyatla	109:18f12ac01097	1271	}
nyatla	109:18f12ac01097	1272	}else{
nyatla	109:18f12ac01097	1273	unlockResource(i_inst);
nyatla	109:18f12ac01097	1274	}
nyatla	109:18f12ac01097	1275	}
nyatla	109:18f12ac01097	1276	NyLPC_cStopwatch_finalize(&sw);
nyatla	109:18f12ac01097	1277	return;
nyatla	109:18f12ac01097	1278	}
nyatla	109:18f12ac01097	1279	/**
nyatla	109:18f12ac01097	1280	* uipサービスタスクが実行する関数です。
nyatla	109:18f12ac01097	1281	* サービスの開始を通知します。
nyatla	109:18f12ac01097	1282	*/
nyatla	109:18f12ac01097	1283	void NyLPC_cMiMicIpTcpSocket_startService(NyLPC_TcMiMicIpTcpSocket_t* i_inst,const NyLPC_TcIPv4Config_t* i_config)
nyatla	109:18f12ac01097	1284	{
nyatla	109:18f12ac01097	1285	NyLPC_Assert(i_inst->tcpstateflags==UIP_CLOSED);//閉じてなければおかしい。
nyatla	109:18f12ac01097	1286	i_inst->uip_connr.lipaddr=&(i_config->ip_addr);
nyatla	109:18f12ac01097	1287	i_inst->uip_connr.default_mss=i_config->default_mss;
nyatla	109:18f12ac01097	1288	//NyLPC_cTcpSocket_setSynPayload関数でも実行するけど、IFのリセット時なのでここでもやる。
nyatla	109:18f12ac01097	1289	NyLPC_cFifoBuffer_clear(&(i_inst->rxbuf));
nyatla	109:18f12ac01097	1290	return;
nyatla	109:18f12ac01097	1291	}
nyatla	109:18f12ac01097	1292	/**
nyatla	109:18f12ac01097	1293	* uipサービスタスクが実行する関数です。
nyatla	109:18f12ac01097	1294	* サービスの停止を通知します。
nyatla	109:18f12ac01097	1295	*/
nyatla	109:18f12ac01097	1296	void NyLPC_cMiMicIpTcpSocket_stopService(NyLPC_TcMiMicIpTcpSocket_t* i_inst)
nyatla	109:18f12ac01097	1297	{
nyatla	109:18f12ac01097	1298	lockResource(i_inst);
nyatla	109:18f12ac01097	1299	if(i_inst->tcpstateflags==UIP_CLOSED)
nyatla	109:18f12ac01097	1300	{
nyatla	109:18f12ac01097	1301	unlockResource(i_inst);
nyatla	109:18f12ac01097	1302	}else{
nyatla	109:18f12ac01097	1303	i_inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	1304	resetTxQWithUnlock(i_inst);
nyatla	109:18f12ac01097	1305	sendRst(i_inst);
nyatla	109:18f12ac01097	1306	}
nyatla	109:18f12ac01097	1307	return;
nyatla	109:18f12ac01097	1308	}
nyatla	109:18f12ac01097	1309
nyatla	109:18f12ac01097	1310
nyatla	109:18f12ac01097	1311	void* NyLPC_cMiMicIpTcpSocket_parseRx(
nyatla	109:18f12ac01097	1312	NyLPC_TcMiMicIpTcpSocket_t* i_inst,
nyatla	109:18f12ac01097	1313	const NyLPC_TcIPv4Payload_t* i_ipp)
nyatla	109:18f12ac01097	1314	{
nyatla	109:18f12ac01097	1315	int i,s;
nyatla	109:18f12ac01097	1316	NyLPC_TUInt16 tmp16;
nyatla	109:18f12ac01097	1317	NyLPC_TUInt16 data_size;
nyatla	109:18f12ac01097	1318	NyLPC_TUInt8 in_tcpflag=i_ipp->payload.tcp->flags;
nyatla	109:18f12ac01097	1319	const void* tcp_data_offset;
nyatla	109:18f12ac01097	1320	NyLPC_TBool is_new_packet;
nyatla	109:18f12ac01097	1321	int num_of_noack;
nyatla	109:18f12ac01097	1322	void* dlist[NyLPC_TcTcpSocket_NUMBER_OF_TXQ];
nyatla	109:18f12ac01097	1323	void* ret;
nyatla	109:18f12ac01097	1324
nyatla	109:18f12ac01097	1325	//パラメータの計算
nyatla	109:18f12ac01097	1326
nyatla	109:18f12ac01097	1327	tmp16=NyLPC_TTcpHeader_getHeaderLength(i_ipp->payload.tcp);
nyatla	109:18f12ac01097	1328	//TCPペイロードの長さは、IPパケットの長さ-(IPヘッダ+TCPヘッダ)
nyatla	109:18f12ac01097	1329	data_size=NyLPC_TIPv4Header_getPacketLength(i_ipp->header)-NyLPC_TIPv4Header_getHeaderLength(i_ipp->header)-tmp16;
nyatla	109:18f12ac01097	1330	//TCPデータオフセット
nyatla	109:18f12ac01097	1331	tcp_data_offset=i_ipp->payload.rawbuf+tmp16;
nyatla	109:18f12ac01097	1332
nyatla	109:18f12ac01097	1333	//インスタンスをロックする。
nyatla	109:18f12ac01097	1334	lockResource(i_inst);
nyatla	109:18f12ac01097	1335
nyatla	109:18f12ac01097	1336	//RSTのチェック。RST受信時は、状態にかかわらず、CLOSEDステータスに移行する。
nyatla	109:18f12ac01097	1337	if (in_tcpflag & TCP_RST)
nyatla	109:18f12ac01097	1338	{
nyatla	109:18f12ac01097	1339	i_inst->tcpstateflags =UIP_CLOSED;
nyatla	109:18f12ac01097	1340	goto DROP;
nyatla	109:18f12ac01097	1341	}
nyatla	109:18f12ac01097	1342
nyatla	109:18f12ac01097	1343
nyatla	109:18f12ac01097	1344	is_new_packet=NyLPC_ntohl(i_ipp->payload.tcp->seqno32)==i_inst->uip_connr.rcv_nxt32;
nyatla	109:18f12ac01097	1345
nyatla	109:18f12ac01097	1346
nyatla	109:18f12ac01097	1347	//OPTIONの反映
nyatla	109:18f12ac01097	1348
nyatla	109:18f12ac01097	1349	//MSSの取得
nyatla	109:18f12ac01097	1350	if(NyLPC_TTcpHeader_getTcpMmsOpt(i_ipp->payload.tcp,&tmp16)){
nyatla	109:18f12ac01097	1351	//取得で着たら更新
nyatla	109:18f12ac01097	1352	i_inst->uip_connr.peer_mss=tmp16;
nyatla	109:18f12ac01097	1353	}
nyatla	109:18f12ac01097	1354	//受信パケットを元に、未ACKパケットの数を計算
nyatla	109:18f12ac01097	1355	num_of_noack=getNumOfSending(i_inst,i_ipp->payload.tcp->ackno32);//i_inst->txbuf.num_of_txq;
nyatla	109:18f12ac01097	1356
nyatla	109:18f12ac01097	1357	//ステータス毎のACK応答
nyatla	109:18f12ac01097	1358	switch(i_inst->tcpstateflags)
nyatla	109:18f12ac01097	1359	{
nyatla	109:18f12ac01097	1360	case UIP_SYN_RCVD:
nyatla	109:18f12ac01097	1361	//ACKを受信したら、ESTABLISHEDへ。
nyatla	109:18f12ac01097	1362	//すべてのパケットをACKしたかで判定。()
nyatla	109:18f12ac01097	1363	if(num_of_noack==0){
nyatla	109:18f12ac01097	1364	i_inst->tcpstateflags=UIP_ESTABLISHED;
nyatla	109:18f12ac01097	1365	}else{
nyatla	109:18f12ac01097	1366	//それ以外のパケットはドロップする。
nyatla	109:18f12ac01097	1367	break;//goto DROP;
nyatla	109:18f12ac01097	1368	}
nyatla	109:18f12ac01097	1369	//新しいパケットがなければ、無応答
nyatla	109:18f12ac01097	1370	if(!is_new_packet){
nyatla	109:18f12ac01097	1371	break;//goto DROP;
nyatla	109:18f12ac01097	1372	}
nyatla	109:18f12ac01097	1373	//引き続き、ESTABLISHEDの処理へ。
nyatla	109:18f12ac01097	1374	case UIP_ESTABLISHED:
nyatla	109:18f12ac01097	1375	if(data_size>0){
nyatla	109:18f12ac01097	1376	if(is_new_packet){
nyatla	109:18f12ac01097	1377	if(addRecvData(i_inst,tcp_data_offset,data_size)){
nyatla	109:18f12ac01097	1378	//通常のACK返却
nyatla	109:18f12ac01097	1379	i_inst->uip_connr.rcv_nxt32+=data_size;
nyatla	109:18f12ac01097	1380	}else{
nyatla	109:18f12ac01097	1381	//失敗したときは必要に応じて単純ACK
nyatla	109:18f12ac01097	1382	}
nyatla	109:18f12ac01097	1383	}
nyatla	109:18f12ac01097	1384	}
nyatla	109:18f12ac01097	1385	//どちらにしろ、ACK送信
nyatla	109:18f12ac01097	1386	if(is_new_packet && (in_tcpflag & TCP_FIN)){
nyatla	109:18f12ac01097	1387	//FINがあるときは、ステータスをCLOSE_WAITへセットして、ACKを返す。
nyatla	109:18f12ac01097	1388	i_inst->tcpstateflags = UIP_CLOSE_WAIT;
nyatla	109:18f12ac01097	1389	i_inst->uip_connr.rcv_nxt32++;
nyatla	109:18f12ac01097	1390	}
nyatla	109:18f12ac01097	1391	break;
nyatla	109:18f12ac01097	1392	case UIP_CLOSE_WAIT:
nyatla	109:18f12ac01097	1393	//必要に応じたACK応答
nyatla	109:18f12ac01097	1394	break;
nyatla	109:18f12ac01097	1395	case UIP_LAST_ACK:
nyatla	109:18f12ac01097	1396	//ACK(by FIN)が得られたなら、CLOSEDへ。
nyatla	109:18f12ac01097	1397	if(num_of_noack==0){
nyatla	109:18f12ac01097	1398	i_inst->tcpstateflags=UIP_CLOSED;
nyatla	109:18f12ac01097	1399	}
nyatla	109:18f12ac01097	1400	//必要に応じたACK応答
nyatla	109:18f12ac01097	1401	break;
nyatla	109:18f12ac01097	1402	case UIP_FIN_WAIT_1:
nyatla	109:18f12ac01097	1403	//FIN受信->CLOSINGへ
nyatla	109:18f12ac01097	1404	if(is_new_packet){
nyatla	109:18f12ac01097	1405	i_inst->uip_connr.rcv_nxt32+=data_size;
nyatla	109:18f12ac01097	1406	if(in_tcpflag & TCP_FIN){
nyatla	109:18f12ac01097	1407	i_inst->uip_connr.rcv_nxt32++;
nyatla	109:18f12ac01097	1408	if(num_of_noack==0){
nyatla	109:18f12ac01097	1409	//FINとACKを受信
nyatla	109:18f12ac01097	1410	i_inst->tcpstateflags=UIP_TIME_WAIT;
nyatla	109:18f12ac01097	1411	}else{
nyatla	109:18f12ac01097	1412	//FINのみ
nyatla	109:18f12ac01097	1413	i_inst->tcpstateflags=UIP_CLOSING;
nyatla	109:18f12ac01097	1414	}
nyatla	109:18f12ac01097	1415	}
nyatla	109:18f12ac01097	1416	}else if(num_of_noack==0){
nyatla	109:18f12ac01097	1417	//ACKのみ
nyatla	109:18f12ac01097	1418	i_inst->tcpstateflags=UIP_FIN_WAIT_2;
nyatla	109:18f12ac01097	1419	}
nyatla	109:18f12ac01097	1420	//必要に応じたACK応答
nyatla	109:18f12ac01097	1421	break;
nyatla	109:18f12ac01097	1422	case UIP_FIN_WAIT_2:
nyatla	109:18f12ac01097	1423	//FIN受信->TIME_WAITへ(pureACK)
nyatla	109:18f12ac01097	1424	if(is_new_packet && (in_tcpflag & TCP_FIN)){
nyatla	109:18f12ac01097	1425	i_inst->uip_connr.rcv_nxt32++;
nyatla	109:18f12ac01097	1426	i_inst->tcpstateflags=UIP_TIME_WAIT;
nyatla	109:18f12ac01097	1427	}
nyatla	109:18f12ac01097	1428	break;
nyatla	109:18f12ac01097	1429	case UIP_CLOSING:
nyatla	109:18f12ac01097	1430	//ACK受信したら、TIME_WAITへ
nyatla	109:18f12ac01097	1431	if(num_of_noack==0){
nyatla	109:18f12ac01097	1432	i_inst->tcpstateflags=UIP_TIME_WAIT;
nyatla	109:18f12ac01097	1433	}
nyatla	109:18f12ac01097	1434	break;
nyatla	109:18f12ac01097	1435	case UIP_CLOSED:
nyatla	109:18f12ac01097	1436	//何もできない。何もしない。
nyatla	109:18f12ac01097	1437	break;
nyatla	109:18f12ac01097	1438	case UIP_TIME_WAIT:
nyatla	109:18f12ac01097	1439	//最終ACKを送り続ける。
nyatla	109:18f12ac01097	1440	break;
nyatla	109:18f12ac01097	1441	case UIP_SYN_SENT:
nyatla	109:18f12ac01097	1442	//connect関数実行中しか起動しないステータス
nyatla	109:18f12ac01097	1443	if(num_of_noack==0){
nyatla	109:18f12ac01097	1444	i_inst->tcpstateflags=UIP_ESTABLISHED;
nyatla	109:18f12ac01097	1445	i_inst->uip_connr.rcv_nxt32=NyLPC_ntohl(i_ipp->payload.tcp->seqno32)+1;
nyatla	109:18f12ac01097	1446	}else{
nyatla	109:18f12ac01097	1447	//それ以外のパケットはドロップする。
nyatla	109:18f12ac01097	1448	break;//goto DROP;
nyatla	109:18f12ac01097	1449	}
nyatla	109:18f12ac01097	1450	//ACKを送る。
nyatla	109:18f12ac01097	1451	break;
nyatla	109:18f12ac01097	1452	default:
nyatla	109:18f12ac01097	1453	goto DROP;
nyatla	109:18f12ac01097	1454	}
nyatla	109:18f12ac01097	1455	//ウインドウサイズを更新
nyatla	109:18f12ac01097	1456	i_inst->uip_connr.peer_win=NyLPC_ntohs(i_ipp->payload.tcp->wnd16);
nyatla	109:18f12ac01097	1457
nyatla	109:18f12ac01097	1458	//送信キューから、Peerが受信したデータを削除する。
nyatla	109:18f12ac01097	1459	if(in_tcpflag & TCP_ACK){
nyatla	109:18f12ac01097	1460	//再送パケットキューから送信済みのデータを回収(後で開放)
nyatla	109:18f12ac01097	1461	NyLPC_Trace();
nyatla	109:18f12ac01097	1462	s=updateTxQByIndex(i_inst,i_ipp->payload.tcp->ackno32,dlist);
nyatla	109:18f12ac01097	1463	NyLPC_Trace();
nyatla	109:18f12ac01097	1464	}else{
nyatla	109:18f12ac01097	1465	s=0;
nyatla	109:18f12ac01097	1466	}
nyatla	109:18f12ac01097	1467	//新しいパケットがきた場合は、再送キューのACKを更新する。
nyatla	109:18f12ac01097	1468	if(is_new_packet){
nyatla	109:18f12ac01097	1469	//再送キューのACKを更新
nyatla	109:18f12ac01097	1470	updateTxAck(i_inst,NyLPC_htonl(i_inst->uip_connr.rcv_nxt32));
nyatla	109:18f12ac01097	1471	}
nyatla	109:18f12ac01097	1472
nyatla	109:18f12ac01097	1473	//送信キューのない
nyatla	109:18f12ac01097	1474	if(((in_tcpflag&(TCP_FIN\|TCP_SYN))!=0x00) \|\|
nyatla	109:18f12ac01097	1475	((!is_new_packet) && (data_size>0)))
nyatla	109:18f12ac01097	1476	{
nyatla	109:18f12ac01097	1477	//ソケットからPureACKを生成 as setPacket(i_inst,i_ipp,TCP_ACK,NULL,0);
nyatla	109:18f12ac01097	1478	ret=NyLPC_cMiMicIpNetIf_allocSysTxBuf();
nyatla	109:18f12ac01097	1479	setTxPacket(i_inst,ret,TCP_ACK,NULL,0);
nyatla	109:18f12ac01097	1480	}else{
nyatla	109:18f12ac01097	1481	ret=NULL;
nyatla	109:18f12ac01097	1482	}
nyatla	109:18f12ac01097	1483	unlockResource(i_inst);
nyatla	109:18f12ac01097	1484	//取り外したTXメモリの開放
nyatla	109:18f12ac01097	1485	for(i=0;i<s;i++){
nyatla	109:18f12ac01097	1486	//取り外したTXメモリを開放
nyatla	109:18f12ac01097	1487	NyLPC_cMiMicIpNetIf_releaseTxBuf(dlist[i]);
nyatla	109:18f12ac01097	1488	}
nyatla	109:18f12ac01097	1489	NyLPC_Trace();
nyatla	109:18f12ac01097	1490	return ret;
nyatla	109:18f12ac01097	1491	DROP:
nyatla	109:18f12ac01097	1492	//ACKしたパケットを送信キューから削除
nyatla	109:18f12ac01097	1493	unlockResource(i_inst);
nyatla	109:18f12ac01097	1494	NyLPC_Trace();
nyatla	109:18f12ac01097	1495	return NULL;
nyatla	109:18f12ac01097	1496	}
nyatla	109:18f12ac01097	1497
nyatla	109:18f12ac01097	1498
nyatla	109:18f12ac01097	1499	/**
nyatla	109:18f12ac01097	1500	* 入力されたパケットからRSTパケットを生成して返す。
nyatla	109:18f12ac01097	1501	*/
nyatla	109:18f12ac01097	1502	void* NyLPC_cMiMicIpTcpSocket_allocTcpReverseRstAck(
nyatla	109:18f12ac01097	1503	const NyLPC_TcIPv4Payload_t* i_src)
nyatla	109:18f12ac01097	1504	{
nyatla	109:18f12ac01097	1505	struct NyLPC_TIPv4Header* iph;
nyatla	109:18f12ac01097	1506	struct NyLPC_TTcpHeader* tcph;
nyatla	109:18f12ac01097	1507	NyLPC_TUInt8 iph_word=0x05;
nyatla	109:18f12ac01097	1508	NyLPC_TUInt8 tcph_word=(UIP_TCPH_LEN) / 4;
nyatla	109:18f12ac01097	1509	void* txb=NyLPC_cMiMicIpNetIf_allocSysTxBuf();
nyatla	109:18f12ac01097	1510	//IPヘッダの更新
nyatla	109:18f12ac01097	1511	iph=(struct NyLPC_TIPv4Header*)txb;
nyatla	109:18f12ac01097	1512	iph->vhl=0x40\|(0x0f&iph_word);
nyatla	109:18f12ac01097	1513	iph->destipaddr=i_src->header->srcipaddr;
nyatla	109:18f12ac01097	1514	iph->srcipaddr =i_src->header->destipaddr;
nyatla	109:18f12ac01097	1515	NyLPC_TIPv4Header_writeTxIpHeader(iph,UIP_PROTO_TCP);
nyatla	109:18f12ac01097	1516
nyatla	109:18f12ac01097	1517	//TCPヘッダの更新
nyatla	109:18f12ac01097	1518	tcph=(struct NyLPC_TTcpHeader)(((NyLPC_TUInt8)txb)+NyLPC_TIPv4Header_getHeaderLength(iph));
nyatla	109:18f12ac01097	1519
nyatla	109:18f12ac01097	1520	tcph->tcpoffset=(tcph_word<<4);
nyatla	109:18f12ac01097	1521
nyatla	109:18f12ac01097	1522	tcph->flags = TCP_RST \| TCP_ACK;
nyatla	109:18f12ac01097	1523	//sorce & destination port
nyatla	109:18f12ac01097	1524	tcph->srcport = i_src->payload.tcp->destport;
nyatla	109:18f12ac01097	1525	tcph->destport = i_src->payload.tcp->srcport;
nyatla	109:18f12ac01097	1526	//ACK number
nyatla	109:18f12ac01097	1527	tcph->ackno32 = NyLPC_htonl(NyLPC_ntohl(i_src->payload.tcp->seqno32)+1);
nyatla	109:18f12ac01097	1528	//Seq Number
nyatla	109:18f12ac01097	1529	tcph->seqno32 = i_src->payload.tcp->ackno32;
nyatla	109:18f12ac01097	1530	//uip_func_tcp_send_noconn(BUF);
nyatla	109:18f12ac01097	1531	tcph->urgp[0] = tcph->urgp[1] = 0;
nyatla	109:18f12ac01097	1532	tcph->tcpchksum= 0;
nyatla	109:18f12ac01097	1533
nyatla	109:18f12ac01097	1534
nyatla	109:18f12ac01097	1535	//最終的なパケットサイズと必要ならペイロードを書き込み
nyatla	109:18f12ac01097	1536	iph->len16=NyLPC_htons((iph_word+tcph_word)*4);
nyatla	109:18f12ac01097	1537	//WND設定
nyatla	109:18f12ac01097	1538	tcph->wnd16=0;
nyatla	109:18f12ac01097	1539	//Checksumの生成
nyatla	109:18f12ac01097	1540	tcph->tcpchksum=~(NyLPC_TIPv4Header_makeTcpChecksum(iph));
nyatla	109:18f12ac01097	1541	iph->ipchksum = ~(NyLPC_TIPv4Header_makeIpChecksum(iph));
nyatla	109:18f12ac01097	1542	return txb;
nyatla	109:18f12ac01097	1543	}
nyatla	109:18f12ac01097	1544
nyatla	109:18f12ac01097	1545
nyatla	109:18f12ac01097	1546
nyatla	109:18f12ac01097	1547
nyatla	109:18f12ac01097	1548

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

構成