TcpSocket,LisnerのMutexをIPv4インスタンス直参照に変更

git-svn-id: http://svn.osdn.jp/svnroot/mimic/trunk@309 47198e57-cb75-475f-84c4-a814cd6f29e0

diff --git a/lib/src/uip/NyLPC_cTcpListener.c b/lib/src/uip/NyLPC_cTcpListener.c
index 7b87126..fda579a 100644 (file)
--- a/lib/src/uip/NyLPC_cTcpListener.c
+++ b/lib/src/uip/NyLPC_cTcpListener.c
@@ -98,9 +98,10 @@ void NyLPC_TTcpListenerListenQ_remove(struct NyLPC_TTcpListenerListenQ* i_struct
 \r
 \r
 \r
-\r
-#define lockResource(i_inst) NyLPC_cMutex_lock(((i_inst)->_mutex))\r
-#define unlockResource(i_inst) NyLPC_cMutex_unlock(((i_inst)->_mutex))\r
+//#define lockResource(i_inst) NyLPC_cMutex_lock(((i_inst)->_mutex))\r
+//#define unlockResource(i_inst) NyLPC_cMutex_unlock(((i_inst)->_mutex))\r
+#define lockResource(i_inst) NyLPC_cMutex_lock(NyLPC_cIPv4_getListenerMutex(((i_inst)->_super._parent_ipv4)))\r
+#define unlockResource(i_inst) NyLPC_cMutex_unlock(NyLPC_cIPv4_getListenerMutex(((i_inst)->_super._parent_ipv4)))\r
 \r
 \r
 /**\r
@@ -114,8 +115,8 @@ NyLPC_TBool NyLPC_cTcpListener_initialize(NyLPC_TcTcpListener_t* i_inst,NyLPC_TU
        //uipサービスは初期化済であること。\r
        NyLPC_Assert(NyLPC_TcUipService_isInitService());\r
        //初期化\r
-       //      NyLPC_cMutex_initialize(&(i_inst->_mutex));\r
-       i_inst->_mutex=NyLPC_cIPv4_getListenerMutex(&srv->_tcpv4);//    NyLPC_cMutex_initialize(&(i_inst->_mutex));\r
+//     //      NyLPC_cMutex_initialize(&(i_inst->_mutex));\r
+//     i_inst->_mutex=NyLPC_cIPv4_getListenerMutex(&srv->_tcpv4);//    NyLPC_cMutex_initialize(&(i_inst->_mutex));\r
        i_inst->_port=NyLPC_htons(i_port);\r
        //管理リストへ登録。\r
        return NyLPC_cIPv4_addSocket(&(srv->_tcpv4),&(i_inst->_super));\r

diff --git a/lib/src/uip/NyLPC_cTcpListener.h b/lib/src/uip/NyLPC_cTcpListener.h
index b0ae477..92485e5 100644 (file)
--- a/lib/src/uip/NyLPC_cTcpListener.h
+++ b/lib/src/uip/NyLPC_cTcpListener.h
@@ -65,11 +65,11 @@ struct NyLPC_TcTcpListener
 {\r
        NyLPC_TcBaseSocket_t _super;\r
        NyLPC_TUInt16 _port;                            /**<ネットワークオーダーのポート番号*/\r
-       /**\r
-        * タスク間の調停用Mutex\r
-        * Listener用の共通Mutexポインタ\r
-        */\r
-       NyLPC_TcMutex_t* _mutex;\r
+//     /**\r
+//      * タスク間の調停用Mutex\r
+//      * Listener用の共通Mutexポインタ\r
+//      */\r
+//     NyLPC_TcMutex_t* _mutex;\r
        /**\r
         * SYNパケットのキュー\r
         */\r

diff --git a/lib/src/uip/NyLPC_cTcpSocket.c b/lib/src/uip/NyLPC_cTcpSocket.c
index 15c33a2..661f409 100644 (file)
--- a/lib/src/uip/NyLPC_cTcpSocket.c
+++ b/lib/src/uip/NyLPC_cTcpSocket.c
@@ -67,11 +67,10 @@ static NyLPC_TUInt32 iss32=3939;
        #define DEBUG_RTO_LOG(i_inst)\r
 #endif\r
 \r
-\r
 //#define lockResource(i_inst) NyLPC_cMutex_lock(&((i_inst)->_smutex))\r
 //#define unlockResource(i_inst) NyLPC_cMutex_unlock(&((i_inst)->_smutex))\r
-#define lockResource(i_inst) NyLPC_cMutex_lock(((i_inst)->_smutex))\r
-#define unlockResource(i_inst) NyLPC_cMutex_unlock(((i_inst)->_smutex))\r
+#define lockResource(i_inst) NyLPC_cMutex_lock(NyLPC_cIPv4_getSockMutex(((i_inst)->_super._parent_ipv4)))\r
+#define unlockResource(i_inst) NyLPC_cMutex_unlock(NyLPC_cIPv4_getSockMutex(((i_inst)->_super._parent_ipv4)))\r
 \r
 static void sendRst(NyLPC_TcTcpSocket_t* i_inst);\r
 \r
@@ -335,7 +334,7 @@ NyLPC_TBool NyLPC_cTcpSocket_initialize(NyLPC_TcTcpSocket_t* i_inst,void* i_rbuf
 \r
        NyLPC_cFifoBuffer_initialize(&(i_inst->rxbuf),i_rbuf,i_rbuf_len);\r
        //      NyLPC_AbortIfNot(NyLPC_cMutex_initialize(&(i_inst->_smutex)));//個別Mutex\r
-       i_inst->_smutex=NyLPC_cIPv4_getSockMutex(&(srv->_tcpv4));//共有Mutex\r
+//     i_inst->_smutex=NyLPC_cIPv4_getSockMutex(&(srv->_tcpv4));//共有Mutex\r
        i_inst->tcpstateflags=UIP_CLOSED;\r
        i_inst->txbuf.rp=i_inst->txbuf.wp=0;\r
        for(i=0;i<NyLPC_TcTcpSocket_NUMBER_OF_TXQ;i++){\r

diff --git a/lib/src/uip/NyLPC_cTcpSocket.h b/lib/src/uip/NyLPC_cTcpSocket.h
index 33e1a58..2e787d8 100644 (file)
--- a/lib/src/uip/NyLPC_cTcpSocket.h
+++ b/lib/src/uip/NyLPC_cTcpSocket.h
@@ -139,8 +139,8 @@ struct NyLPC_TcTcpSocket
                struct NyLPC_TcTcpSocket_TxQItem txq[NyLPC_TcTcpSocket_NUMBER_OF_TXQ];\r
        }txbuf;\r
        volatile NyLPC_TUInt8 tcpstateflags; /**< TCP state and flags. */\r
-       /** 共通MUTEXへのポインタ(うまくいｔったらこのままで)*/\r
-       NyLPC_TcMutex_t* _smutex;\r
+//     /** 共通MUTEXへのポインタ(うまくいｔったらこのままで)*/\r
+//     NyLPC_TcMutex_t* _smutex;\r
 };\r
 \r
 /**\r