English

Diff: core/uip/NyLPC_cTcpSocket.c

Revision:

69:8c5f220441f5

Parent:

63:157ee3202edb

--- a/core/uip/NyLPC_cTcpSocket.c	Thu May 22 12:59:50 2014 +0000
+++ b/core/uip/NyLPC_cTcpSocket.c	Thu May 29 14:29:15 2014 +0000
@@ -75,45 +75,155 @@
 static void sendRst(NyLPC_TcTcpSocket_t* i_inst);
 
 
+
+
+////////////////////////////////////////////////////////////////////////////////////////////////////
+//
+//  Packet writer
+//
+////////////////////////////////////////////////////////////////////////////////////////////////////
+
+
 /**
- * ソケットステータスを元に、IPパケットを構成します。
- * この関数は、ロック状態でコールしてください。
+ * TCPヘッダに値をセットする。checksum,wndは0初期化する。
  */
-static void setPacket(const NyLPC_TcTcpSocket_t* i_inst,NyLPC_TcIPv4Payload_t* i_payload,NyLPC_TUInt8 i_tcpf,const void* i_buf,NyLPC_TUInt16 i_len)
+static void setTcpTxHeader(struct NyLPC_TTcpHeader* i_struct,NyLPC_TUInt8 i_flag,const struct uip_conn* i_conn)
+{
+    i_struct->flags    = i_flag;
+    //sorce & destination port
+    i_struct->srcport  = i_conn->lport;
+    i_struct->destport = i_conn->rport;
+    //ACK number
+    i_struct->ackno32  = NyLPC_htonl(i_conn->rcv_nxt32);
+    //Seq Number
+    i_struct->seqno32  = NyLPC_htonl(i_conn->snd_nxt32);
+    //uip_func_tcp_send_noconn(BUF);
+    i_struct->urgp[0]  = i_struct->urgp[1] = 0;
+    i_struct->tcpchksum= 0;
+}
+
+static void setTxPacket(const NyLPC_TcTcpSocket_t* i_inst,void* i_tx_buf,NyLPC_TUInt8 i_tcpf,const void* i_buf,NyLPC_TUInt16 i_len)
 {
-    void* buf;
-    switch(i_tcpf){
-    case TCP_PSH|TCP_ACK:
-        buf=NyLPC_cIPv4Payload_initTcpTx(i_payload,0x05,((UIP_TCPH_LEN) / 4),i_len);
-        NyLPC_cIPv4Payload_setTcpTxHeaderByConnection(i_payload,&(i_inst->uip_connr),TCP_ACK|TCP_PSH);
-        //bufの書き込み
-        memcpy(buf,i_buf,i_len);
-        break;
-    case TCP_ACK:
-    case TCP_FIN|TCP_ACK:
-    case TCP_RST|TCP_ACK:
-        NyLPC_cIPv4Payload_initTcpTx(i_payload,0x05,((UIP_TCPH_LEN) / 4),0);
-        NyLPC_cIPv4Payload_setTcpTxHeaderByConnection(i_payload,&(i_inst->uip_connr),i_tcpf);
-        break;
-    case TCP_SYN|TCP_ACK:
-        NyLPC_cIPv4Payload_initTcpTx(i_payload,0x05,((UIP_TCPH_LEN + TCP_OPT_MSS_LEN) / 4),0);
-        NyLPC_cIPv4Payload_setTcpTxHeaderByConnection(i_payload,&(i_inst->uip_connr),i_tcpf);
-        //MSSの設定(OPTION領域のアドレス0)
-        NyLPC_TTcpHeader_setMmsOpt((NyLPC_TUInt8*)(i_payload->payload.tcp+1),i_inst->uip_connr.default_mss);
-        break;
-    case TCP_SYN:
-        NyLPC_cIPv4Payload_initTcpTx(i_payload,0x05,((UIP_TCPH_LEN + TCP_OPT_MSS_LEN) / 4),0);
-        NyLPC_cIPv4Payload_setTcpTxHeaderByConnection(i_payload,&(i_inst->uip_connr),i_tcpf);
-        //MSSの設定(OPTION領域のアドレス0)
-        NyLPC_TTcpHeader_setMmsOpt((NyLPC_TUInt8*)(i_payload->payload.tcp+1),i_inst->uip_connr.default_mss);
-        break;
-    default:
-        NyLPC_Abort();
+    struct NyLPC_TIPv4Header*   iph;
+    struct NyLPC_TTcpHeader*    tcph;
+    NyLPC_TUInt8 iph_word=0x05;
+    NyLPC_TUInt8 tcph_word=(UIP_TCPH_LEN) / 4;
+    //IPヘッダの更新
+    iph=(struct NyLPC_TIPv4Header*)i_tx_buf;
+    iph->vhl=0x40|(0x0f&iph_word);
+    iph->destipaddr=i_inst->uip_connr.ripaddr;
+    iph->srcipaddr =*(i_inst->uip_connr.lipaddr);
+    NyLPC_TIPv4Header_writeTxIpHeader(iph,UIP_PROTO_TCP);
+    //TCPヘッダの更新
+    tcph=(struct NyLPC_TTcpHeader*)(((NyLPC_TUInt8*)i_tx_buf)+NyLPC_TIPv4Header_getHeaderLength(iph));
+
+
+    //SYNが有るならMSSの書き込み
+    if((TCP_SYN & i_tcpf)){
+        tcph_word+=((TCP_OPT_MSS_LEN) / 4);
+        NyLPC_TTcpHeader_setMmsOpt(((NyLPC_TUInt8*)(tcph+1)),i_inst->uip_connr.default_mss);
     }
-    NyLPC_cIPv4Payload_setTcpWnd(i_payload,NyLPC_cFifoBuffer_getSpace(&(i_inst->rxbuf)));
-    NyLPC_cIPv4Payload_closeTcpTxPacket(i_payload);
+    tcph->tcpoffset=(tcph_word<<4);
+    setTcpTxHeader(tcph,i_tcpf,&(i_inst->uip_connr));
+
+    //最終的なパケットサイズと必要ならペイロードを書き込み
+    if(i_buf!=NULL){
+        iph->len16=NyLPC_htons(i_len+(iph_word+tcph_word)*4);
+        memcpy(((NyLPC_TUInt8*)i_tx_buf)+((iph_word+tcph_word)*4),i_buf,i_len);
+    }else{
+        iph->len16=NyLPC_htons((iph_word+tcph_word)*4);
+    }
+    //WND設定
+    tcph->wnd16=NyLPC_htons(NyLPC_cFifoBuffer_getSpace(&(i_inst->rxbuf)));
+    //Checksumの生成
+    tcph->tcpchksum=~(NyLPC_TIPv4Header_makeTcpChecksum(iph));
+    iph->ipchksum = ~(NyLPC_TIPv4Header_makeIpChecksum(iph));
     return;
 }
+
+/**
+ * IP/TCPヘッダが40バイト固定として、i_tx_buf+40の位置にあるペイロードに対するIP/TCPヘッダを書き込みます。
+ */
+static void setTxPacketHeader(const NyLPC_TcTcpSocket_t* i_inst,void* i_tx_buf,NyLPC_TUInt8 i_tcpf,NyLPC_TUInt16 i_len)
+{
+    struct NyLPC_TIPv4Header*   iph;
+    struct NyLPC_TTcpHeader*    tcph;
+    NyLPC_TUInt8 iph_word=0x05;
+    NyLPC_TUInt8 tcph_word=(UIP_TCPH_LEN) / 4;
+    //IPヘッダの更新
+    iph=(struct NyLPC_TIPv4Header*)i_tx_buf;
+    iph->vhl=0x40|(0x0f&iph_word);
+    iph->destipaddr=i_inst->uip_connr.ripaddr;
+    iph->srcipaddr =*(i_inst->uip_connr.lipaddr);
+    NyLPC_TIPv4Header_writeTxIpHeader(iph,UIP_PROTO_TCP);
+
+    //TCPヘッダの更新
+    tcph=(struct NyLPC_TTcpHeader*)(((NyLPC_TUInt8*)i_tx_buf)+NyLPC_TIPv4Header_getHeaderLength(iph));
+    tcph->tcpoffset=(tcph_word<<4);
+    setTcpTxHeader(tcph,i_tcpf,&(i_inst->uip_connr));
+
+    //最終的なパケットサイズと必要ならペイロードを書き込み
+    iph->len16=NyLPC_htons(i_len+(iph_word+tcph_word)*4);
+    //WND設定
+    tcph->wnd16=NyLPC_htons(NyLPC_cFifoBuffer_getSpace(&(i_inst->rxbuf)));
+    //Checksumの生成
+    tcph->tcpchksum=~(NyLPC_TIPv4Header_makeTcpChecksum(iph));
+    iph->ipchksum = ~(NyLPC_TIPv4Header_makeIpChecksum(iph));
+    return;
+}
+
+
+
+
+
+////////////////////////////////////////////////////////////////////////////////////////////////////
+//
+//  Mainclass::private
+//
+////////////////////////////////////////////////////////////////////////////////////////////////////
+
+/**
+ * ACK番号を更新する。
+ * @param i_ackno
+ * ネットワークオーダーのACK番号
+ */
+static void updateAckNo(void* i_tx_buf,NyLPC_TUInt32 i_ackno)
+{
+    struct NyLPC_TIPv4Header*   iph=(struct NyLPC_TIPv4Header*)i_tx_buf;
+    struct NyLPC_TTcpHeader*    tcph=(struct NyLPC_TTcpHeader*)(((NyLPC_TUInt8*)i_tx_buf)+NyLPC_TIPv4Header_getHeaderLength(iph));
+
+/*  union{
+        NyLPC_TUInt32 l;
+        NyLPC_TUInt8 b[4];
+    }old_ack,new_ack;
+    NyLPC_TUInt16 v1;
+    //checksumの計算
+    old_ack.l=i_inst->payload.tcp->ackno32;//古いACK番号
+    new_ack.l=i_ackno;//新しいACK番号
+    v1=NyLPC_ntohs(~(i_inst->payload.tcp->tcpchksum));//1の補数を取って、ホストオーダーに戻す。
+    //減算
+    v1=sub16c(v1,(old_ack.b[0]<<8)+old_ack.b[1]);
+    v1=sub16c(v1,(old_ack.b[2]<<8)+old_ack.b[3]);
+    //加算
+    v1=add16c(v1,(new_ack.b[0]<<8)+new_ack.b[1]);
+    v1=add16c(v1,(new_ack.b[2]<<8)+new_ack.b[3]);
+    v1=~NyLPC_htons(v1);*/
+NyLPC_Trace();
+    tcph->ackno32=i_ackno;
+NyLPC_Trace();
+    tcph->tcpchksum = 0;
+NyLPC_Trace();
+    tcph->tcpchksum = ~(NyLPC_TIPv4Header_makeTcpChecksum(iph));
+NyLPC_Trace();
+
+/*
+    if((i_inst->payload.tcp->tcpchksum!=v1)){
+        NyLPC_Warning();
+    }*/
+}
+
+
+
 /**
  * 指定した送信パケットがACK済であるか調べる。
  */
@@ -161,7 +271,7 @@
 
     l=0;
     while(i_inst->txbuf.rp!=i_inst->txbuf.wp){
-        dlist[l]=NyLPC_cIPv4Payload_detachBuf(&(q[i_inst->txbuf.rp].data));
+        dlist[l]=q[i_inst->txbuf.rp].packet;
         l++;
         i_inst->txbuf.rp=(i_inst->txbuf.rp+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ;
     }
@@ -187,7 +297,7 @@
     NyLPC_ArgAssert(i_inst!=NULL);
     rp=i_inst->txbuf.rp;
     while(rp!=i_inst->txbuf.wp){
-        NyLPC_cIPv4Payload_updateAckNo(&(q[rp].data),i_ackno);
+        updateAckNo(q[rp].packet,i_ackno);
         rp=(rp+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ;
     }
 }
@@ -269,7 +379,7 @@
     DEBUG_RTO_LOG(i_inst);
 
     while(rp!=i_inst->txbuf.wp){
-        o_dlist[n]=NyLPC_cIPv4Payload_getBuf(&(q[rp].data));
+        o_dlist[n]=q[rp].packet;
         if(q[rp].ackno==i_sq){
             //i_inst->txbuf.rp->rpのパケットのRTOからbaseRTOの値を再計算。
             estimateRTO(i_inst,i_inst->txbuf.rp,n+1);
@@ -338,7 +448,7 @@
     i_inst->tcpstateflags=UIP_CLOSED;
     i_inst->txbuf.rp=i_inst->txbuf.wp=0;
     for(i=0;i<NyLPC_TcTcpSocket_NUMBER_OF_TXQ;i++){
-        NyLPC_cIPv4Payload_initialize(&(i_inst->txbuf.txq[i].data));
+        i_inst->txbuf.txq[i].packet=NULL;
     }
     //管理リストへ登録。
     return NyLPC_cIPv4_addSocket(&(srv->_tcpv4),&(i_inst->_super));
@@ -359,7 +469,7 @@
         resetTxQWithUnlock(i_inst);
     }
     for(i=0;i<NyLPC_TcTcpSocket_NUMBER_OF_TXQ;i++){
-        NyLPC_cIPv4Payload_finalize(&(i_inst->txbuf.txq[i].data));
+        i_inst->txbuf.txq[i].packet=NULL;
     }
     NyLPC_cFifoBuffer_finalize(&(i_inst->rxbuf));
 //  NyLPC_cMutex_finalize(&(i_inst->_smutex));
@@ -464,7 +574,7 @@
     void* buf;
     NyLPC_TUInt32 next_ack;
     //送信バッファを取得
-    //@bug バッファが取れるまで通信がブロックするの。ここはなんとかしないと。
+    //@bug オブションパケット送信時に4バイト足りないメモリ要求しない？問題になってないけど。
     for(;;){
         buf=NyLPC_cUipService_allocTxBuf(i_len+(SIZE_OF_IPv4_TCPIP_HEADER),&s);
         if(buf!=NULL){
@@ -497,8 +607,6 @@
         NyLPC_cUipService_releaseTxBuf(buf);
         return -1;
     }
-    //IPv4ペイロードの書き込み
-    NyLPC_cIPv4Payload_setTxBuf(&(txq->data),buf);
 
     //送信バッファを基準とした送信サイズを計算
     s-=SIZE_OF_IPv4_TCPIP_HEADER;
@@ -520,7 +628,9 @@
     txq->tick_of_sent=NyLPC_cStopwatch_now();
 
     //パケットの書き込み
-    setPacket(i_inst,&(txq->data),i_tcpf,i_buf,s);
+    setTxPacket(i_inst,buf,i_tcpf,i_buf,s);
+    txq->packet=buf;
+
     //シーケンス番号の更新
     i_inst->uip_connr.snd_nxt32=next_ack;
     //Peerのウインドウサイズを更新
@@ -538,25 +648,17 @@
  */
 static void sendRst(NyLPC_TcTcpSocket_t* i_inst)
 {
-    NyLPC_TcIPv4Payload_t ipv4;
-    NyLPC_TUInt16 s;
     void* buf;
 
     NyLPC_Assert(i_inst->tcpstateflags==UIP_CLOSED);
     //ペイロードライタの初期化
-    NyLPC_cIPv4Payload_initialize(&ipv4);
 
-    //IPヘッダ+10バイトくらい。
     //@bug バッファが取れるまで通信がブロックするの。ここはなんとかしないと。
-    do{
-        buf=NyLPC_cUipService_allocTxBuf((SIZE_OF_IPv4_TCPIP_HEADER)+5,&s);
-    }while(buf==NULL);
+    buf=NyLPC_cUipService_allocSysTxBuf();
     lockResource(i_inst);
-    NyLPC_cIPv4Payload_setTxBuf(&ipv4,buf);
     i_inst->uip_connr.snd_nxt32++;
-    setPacket(i_inst,&ipv4,TCP_RST|TCP_ACK,buf,0);
     unlockResource(i_inst);
-
+    setTxPacket(i_inst,buf,TCP_RST|TCP_ACK,NULL,0);
     NyLPC_cUipService_sendIPv4Tx(buf);
     NyLPC_cUipService_releaseTxBuf(buf);
     NyLPC_cIPv4Payload_finalize(&ipv4);
@@ -570,7 +672,7 @@
  * 十分な空き領域がない場合、失敗する。
  * この関数は、ロックして実行してください。
  */
-static NyLPC_TBool addRecvData(NyLPC_TcTcpSocket_t* i_inst,void* i_data,NyLPC_TUInt16 i_data_size)
+static NyLPC_TBool addRecvData(NyLPC_TcTcpSocket_t* i_inst,const void* i_data,NyLPC_TUInt16 i_data_size)
 {
     //受信データサイズを確認
     if(NyLPC_cFifoBuffer_getSpace(&(i_inst->rxbuf))>=i_data_size){
@@ -773,21 +875,14 @@
  */
 void NyLPC_cTcpSocket_pseek(NyLPC_TcTcpSocket_t* i_inst,NyLPC_TUInt16 i_seek)
 {
-    NyLPC_TcIPv4Payload_t ipv4payload;
     void* buf;
-    NyLPC_TUInt16 s;
     NyLPC_ArgAssert(i_seek<=NyLPC_cFifoBuffer_getLength(&(i_inst->rxbuf)));
     if(i_seek==0){
         return;
     }
-    //ペイロードライタの初期化
-    NyLPC_cIPv4Payload_initialize(&ipv4payload);
 
     //ACK送信バッファの取得
-    //@bug バッファが取れるまで通信がブロックするの。ここはなんとかしないと。
-    do{
-        buf=NyLPC_cUipService_allocTxBuf((SIZE_OF_IPv4_TCPIP_HEADER)+5,&s);
-    }while(buf==NULL);
+    buf=NyLPC_cUipService_allocSysTxBuf();
 
     //MUTEX LOCK
     lockResource(i_inst);
@@ -795,14 +890,12 @@
     //受信バッファを読み出しシーク
     NyLPC_cFifoBuffer_pop(&(i_inst->rxbuf),i_seek);
     //ACKパケットの生成
-    NyLPC_cIPv4Payload_setTxBuf(&ipv4payload,buf);
-    setPacket(i_inst,&ipv4payload,TCP_ACK,buf,0);
+    setTxPacket(i_inst,buf,TCP_ACK,NULL,0);
     unlockResource(i_inst);
     //ACK送信
     NyLPC_cUipService_sendIPv4Tx(buf);
     NyLPC_cUipService_releaseTxBuf(buf);
-    //ペイロードライタの破棄
-    NyLPC_cIPv4Payload_finalize(&ipv4payload);
+
 }
 
 /**
@@ -917,16 +1010,16 @@
     //ここから先はi_bufの所有権はインスタンスになってる。
 
     //IPv4ペイロードの書き込み
-    NyLPC_cIPv4Payload_setTxBuf(&(txq->data),buf);
+
     //allocをした時点でwin,mssは考慮されているので、そのままそうしんしる。
+
     //ACK番号の計算
     txq->rto32=i_inst->uip_connr.current_rto32;
     txq->tick_of_sent=NyLPC_cStopwatch_now();
-    //パケットヘッダの生成
-    NyLPC_cIPv4Payload_initTcpTx(&(txq->data),0x05,((UIP_TCPH_LEN) / 4),i_len);
-    NyLPC_cIPv4Payload_setTcpTxHeaderByConnection(&(txq->data),&(i_inst->uip_connr),TCP_ACK|TCP_PSH);
-    NyLPC_cIPv4Payload_setTcpWnd(&(txq->data),NyLPC_cFifoBuffer_getSpace(&(i_inst->rxbuf)));
-    NyLPC_cIPv4Payload_closeTcpTxPacket(&(txq->data));
+    //パケットヘッダの生成(ヘッダ長はpreadで定義した値(4+6)*4=40です。)
+    setTxPacketHeader(i_inst,buf,TCP_ACK|TCP_PSH,i_len);
+    txq->packet=buf;
+
     //シーケンス番号の更新
     i_inst->uip_connr.snd_nxt32=i_inst->uip_connr.snd_nxt32+i_len;
     //Peerのウインドウサイズを更新
@@ -1116,7 +1209,8 @@
             }else{
                 //規定時間内なら、再送処理
                 for(i=rp;i!=i_inst->txbuf.wp;i=(i+1)%NyLPC_TcTcpSocket_NUMBER_OF_TXQ){
-                    NyLPC_cUipService_sendIPv4Tx(NyLPC_cIPv4Payload_getBuf(&(q[i].data)));
+//                  NyLPC_cUipService_sendIPv4Tx(NyLPC_cIPv4Payload_getBuf(&(q[i].data)));
+                    NyLPC_cUipService_sendIPv4Tx(q[i].packet);
                 }
                 unlockResource(i_inst);
             }
@@ -1158,33 +1252,28 @@
     return;
 }
 
-/**
- * この関数は、rxパケットを処理して、ソケットの状態を更新します。
- * uipサービスタスクが実行する関数です。
- * o_ippのペイロードに、応答ペイロードを設定することがあります。
- * この関数はNyLPC_cTcpSocket_periodicと排他実行すること。
- */
-NyLPC_TBool NyLPC_cTcpSocket_parseRx(
+
+void* NyLPC_cTcpSocket_parseRx(
     NyLPC_TcTcpSocket_t* i_inst,
-    NyLPC_TcIPv4Payload_t* o_ipp)
+    const NyLPC_TcIPv4Payload_t* i_ipp)
 {
     int i,s;
     NyLPC_TUInt16 tmp16;
     NyLPC_TUInt16 data_size;
-    NyLPC_TUInt8 in_tcpflag=o_ipp->payload.tcp->flags;
-    void* tcp_data_offset;
+    NyLPC_TUInt8 in_tcpflag=i_ipp->payload.tcp->flags;
+    const void* tcp_data_offset;
     NyLPC_TBool is_new_packet;
     int num_of_noack;
     void* dlist[NyLPC_TcTcpSocket_NUMBER_OF_TXQ];
-    NyLPC_TBool ret;
+    void* ret;
 
     //パラメータの計算
 
-    tmp16=NyLPC_TTcpHeader_getHeaderLength(o_ipp->payload.tcp);
+    tmp16=NyLPC_TTcpHeader_getHeaderLength(i_ipp->payload.tcp);
     //TCPペイロードの長さは、IPパケットの長さ-(IPヘッダ+TCPヘッダ)
-    data_size=NyLPC_TIPv4Header_getPacketLength(o_ipp->header)-NyLPC_TIPv4Header_getHeaderLength(o_ipp->header)-tmp16;
+    data_size=NyLPC_TIPv4Header_getPacketLength(i_ipp->header)-NyLPC_TIPv4Header_getHeaderLength(i_ipp->header)-tmp16;
     //TCPデータオフセット
-    tcp_data_offset=o_ipp->payload.rawbuf+tmp16;
+    tcp_data_offset=i_ipp->payload.rawbuf+tmp16;
 
     //インスタンスをロックする。
     lockResource(i_inst);
@@ -1197,18 +1286,18 @@
     }
 
 
-    is_new_packet=NyLPC_ntohl(o_ipp->payload.tcp->seqno32)==i_inst->uip_connr.rcv_nxt32;
+    is_new_packet=NyLPC_ntohl(i_ipp->payload.tcp->seqno32)==i_inst->uip_connr.rcv_nxt32;
 
 
     //OPTIONの反映
 
     //MSSの取得
-    if(NyLPC_TTcpHeader_getTcpMmsOpt(o_ipp->payload.tcp,&tmp16)){
+    if(NyLPC_TTcpHeader_getTcpMmsOpt(i_ipp->payload.tcp,&tmp16)){
         //取得で着たら更新
         i_inst->uip_connr.peer_mss=tmp16;
     }
     //受信パケットを元に、未ACKパケットの数を計算
-    num_of_noack=getNumOfSending(i_inst,o_ipp->payload.tcp->ackno32);//i_inst->txbuf.num_of_txq;
+    num_of_noack=getNumOfSending(i_inst,i_ipp->payload.tcp->ackno32);//i_inst->txbuf.num_of_txq;
 
     //ステータス毎のACK応答
     switch(i_inst->tcpstateflags)
@@ -1298,7 +1387,7 @@
         //connect関数実行中しか起動しないステータス
         if(num_of_noack==0){
             i_inst->tcpstateflags=UIP_ESTABLISHED;
-            i_inst->uip_connr.rcv_nxt32=NyLPC_ntohl(o_ipp->payload.tcp->seqno32)+1;
+            i_inst->uip_connr.rcv_nxt32=NyLPC_ntohl(i_ipp->payload.tcp->seqno32)+1;
         }else{
             //それ以外のパケットはドロップする。
             break;//goto DROP;
@@ -1309,13 +1398,13 @@
         goto DROP;
     }
     //ウインドウサイズを更新
-    i_inst->uip_connr.peer_win=NyLPC_ntohs(o_ipp->payload.tcp->wnd16);
+    i_inst->uip_connr.peer_win=NyLPC_ntohs(i_ipp->payload.tcp->wnd16);
 
     //送信キューから、Peerが受信したデータを削除する。
     if(in_tcpflag & TCP_ACK){
         //再送パケットキューから送信済みのデータを回収(後で開放)
         NyLPC_Trace();
-        s=updateTxQByIndex(i_inst,o_ipp->payload.tcp->ackno32,dlist);
+        s=updateTxQByIndex(i_inst,i_ipp->payload.tcp->ackno32,dlist);
         NyLPC_Trace();
     }else{
         s=0;
@@ -1327,14 +1416,14 @@
     }
 
     //送信キューのない
-    ret=NyLPC_TBool_FALSE;
     if(((in_tcpflag&(TCP_FIN|TCP_SYN))!=0x00) ||
         ((!is_new_packet) && (data_size>0)))
     {
-        setPacket(i_inst,o_ipp,TCP_ACK,NULL,0);
-        ret=NyLPC_TBool_TRUE;
+        //ソケットからPureACKを生成 as setPacket(i_inst,i_ipp,TCP_ACK,NULL,0);
+        ret=NyLPC_cUipService_allocSysTxBuf();
+        setTxPacket(i_inst,ret,TCP_ACK,NULL,0);
     }else{
-        ret=NyLPC_TBool_FALSE;
+        ret=NULL;
     }
     unlockResource(i_inst);
     //取り外したTXメモリの開放
@@ -1348,13 +1437,56 @@
     //ACKしたパケットを送信キューから削除
     unlockResource(i_inst);
 NyLPC_Trace();
-    return NyLPC_TBool_FALSE;
+    return NULL;
+}
+
+
+/**
+ * 入力されたパケットからRSTパケットを生成して返す。
+ */
+void* NyLPC_cTcpSocket_allocTcpReverseRstAck(
+    const NyLPC_TcIPv4Payload_t* i_src)
+{
+    struct NyLPC_TIPv4Header*   iph;
+    struct NyLPC_TTcpHeader*    tcph;
+    NyLPC_TUInt8 iph_word=0x05;
+    NyLPC_TUInt8 tcph_word=(UIP_TCPH_LEN) / 4;
+    void* txb=NyLPC_cUipService_allocSysTxBuf();
+    //IPヘッダの更新
+    iph=(struct NyLPC_TIPv4Header*)txb;
+    iph->vhl=0x40|(0x0f&iph_word);
+    iph->destipaddr=i_src->header->srcipaddr;
+    iph->srcipaddr =i_src->header->destipaddr;
+    NyLPC_TIPv4Header_writeTxIpHeader(iph,UIP_PROTO_TCP);
+
+    //TCPヘッダの更新
+    tcph=(struct NyLPC_TTcpHeader*)(((NyLPC_TUInt8*)txb)+NyLPC_TIPv4Header_getHeaderLength(iph));
+
+    tcph->tcpoffset=(tcph_word<<4);
+
+    tcph->flags    = TCP_RST | TCP_ACK;
+    //sorce & destination port
+    tcph->srcport  = i_src->payload.tcp->destport;
+    tcph->destport = i_src->payload.tcp->srcport;
+    //ACK number
+    tcph->ackno32  = NyLPC_htonl(NyLPC_ntohl(i_src->payload.tcp->seqno32)+1);
+    //Seq Number
+    tcph->seqno32  = i_src->payload.tcp->ackno32;
+    //uip_func_tcp_send_noconn(BUF);
+    tcph->urgp[0]  = tcph->urgp[1] = 0;
+    tcph->tcpchksum= 0;
+
+
+    //最終的なパケットサイズと必要ならペイロードを書き込み
+    iph->len16=NyLPC_htons((iph_word+tcph_word)*4);
+    //WND設定
+    tcph->wnd16=0;
+    //Checksumの生成
+    tcph->tcpchksum=~(NyLPC_TIPv4Header_makeTcpChecksum(iph));
+    iph->ipchksum = ~(NyLPC_TIPv4Header_makeIpChecksum(iph));
+    return txb;
 }
 
 
 
 
-
-
-
-