English

Diff: core/uip/NyLPC_cUipService.c

Revision:

68:f7def7eb5504

Parent:

57:bc4330dfa62f

Child:

69:8c5f220441f5

--- a/core/uip/NyLPC_cUipService.c	Wed Oct 23 04:49:08 2013 +0000
+++ b/core/uip/NyLPC_cUipService.c	Thu May 22 12:59:50 2014 +0000
@@ -62,25 +62,7 @@
 
 
 
-/****************************************************
- * UipServiceに関する宣言:タスクメッセージ
- ***************************************************/
-/*
-#define TTaskMsg_NOP 0
-#define TTaskMsg_START 1
-#define TTaskMsg_STOP 2
-*/
-/**
- * サービスの起動メッセージです。
- *//*
-struct TTaskMsg{
-    NyLPC_TUInt16 msg;
-    union{
-        struct{
-            const NyLPC_TcIPv4Config_t* ref_config;
-        }start;
-    };
-};*/
+
 
 /****************************************************
  * UipServiceに関する宣言:その他
@@ -117,6 +99,9 @@
  */
 static int uipTask(void *pvParameters);
 
+/** イーサネットドライバからのハンドラ*/
+static void ethernet_handler(void* i_param,NyLPC_TiEthernetDevice_EVENT i_type);
+
 //--------------------------------------------------------------
 
 
@@ -124,7 +109,6 @@
 static void copyAndSendIPv4Tx(const struct TEthPacket* i_buf);
 //static void sendArpReqest(const struct TEthPacket* i_eth_packet);
 static void sendRawEthFrame(void* i_buf,NyLPC_TUInt16 i_len);
-static void emacIsrHandler(unsigned long i_status);
 
 /**メッセージなし*/
 #define TTaskMessage_MSG_NULL    0x0000
@@ -143,8 +127,6 @@
     NyLPC_Assert(!NyLPC_TcUipService_isInitService());
     //IP処理部分の初期化
     NyLPC_cIPv4_initialize(&(inst->_tcpv4));
-    //EMACからの割込処理
-    NyLPC_cIsr_setEnetISR(emacIsrHandler);
     //EMAC割込セマフォ
     NyLPC_cSemaphore_initialize(&inst->_emac_semapho);
 
@@ -219,7 +201,7 @@
 const char* NyLPC_cUipService_refDeviceName(void)
 {
     NyLPC_TcUipService_t* inst=&_service_instance;
-    return NyLPC_cUipService_isRun()?inst->_ethif->device_name:NULL;
+    return NyLPC_cUipService_isRun()?NyLPC_iEthernetDevice_getDevicName(inst->_ethif):NULL;
 }
 const NyLPC_TcIPv4Config_t* NyLPC_cUipService_refCurrentConfig(void)
 {
@@ -232,23 +214,6 @@
  *
  *********************************************************************/
 
-/**
- * EMACからのハンドラ
- */
-static void emacIsrHandler(unsigned long i_status)
-{
-    NyLPC_TcUipService_t* inst=&_service_instance;
-
-    if( i_status & INT_RX_DONE )
-    {
-        //受信系のセマフォブロックの解除
-        NyLPC_cSemaphore_giveFromISR(&inst->_emac_semapho);
-    }
-    if( i_status & INT_TX_DONE )
-    {
-    }
-}
-
 
 //PERIODIC rate
 #define PERIODIC_TIMER (1*200)
@@ -270,7 +235,7 @@
         if(NyLPC_TUInt16_isBitOn(inst->_status,NyLPC_TcUipService_ORDER_STOP))
         {
             //停止操作
-            inst->_ethif->stop();
+            NyLPC_iEthernetDevice_stop(inst->_ethif);
             NyLPC_cIPv4_stop(&(inst->_tcpv4));
             NyLPC_cIPv4IComp_finalize(&(inst->_icomp));
             NyLPC_cIPv4Arp_finalize(&(inst->_arp));
@@ -295,7 +260,7 @@
             inst->stx.h.is_lock=NyLPC_TUInt8_FALSE;
             inst->stx.h.ref=0;
             //EtherNETデバイス初期化
-            while(!inst->_ethif->start(&(inst->_ref_config->eth_mac)));
+            while(!NyLPC_iEthernetDevice_start(inst->_ethif,&(inst->_ref_config->eth_mac),ethernet_handler,inst));
             NyLPC_TUInt16_setBit(inst->_status,NyLPC_TcUipService_STATUSBIT_IS_RUNNING);
             NyLPC_TUInt16_unsetBit(inst->_status,NyLPC_TcUipService_ORDER_START);
             return NyLPC_TBool_TRUE;
@@ -326,7 +291,7 @@
         //イーサネットフレームの取得
         //Ethernet Device Lock(ARPを含む)
         NyLPC_cMutex_lock(&(inst->_mutex));
-        ethbuf= (struct TEthPacket*)inst->_ethif->getRxEthFrame(&rx_len);
+        ethbuf= (struct TEthPacket*)NyLPC_iEthernetDevice_getRxEthFrame(inst->_ethif,&rx_len);
         tx_len=0;
         while(ethbuf != NULL){
             if(rx_len>0)
@@ -370,9 +335,9 @@
                 }
             }
             //受信キューを進行。
-            inst->_ethif->nextRxEthFrame();
+            NyLPC_iEthernetDevice_nextRxEthFrame(inst->_ethif);
             //受信処理
-            ethbuf= (struct TEthPacket*)inst->_ethif->getRxEthFrame(&rx_len);
+            ethbuf= (struct TEthPacket*)NyLPC_iEthernetDevice_getRxEthFrame(inst->_ethif,&rx_len);
         }
         //データが無い。
         if(NyLPC_cStopwatch_isExpired(&(inst->_arp_sw))){
@@ -396,6 +361,21 @@
 
 
 /**
+ * イーサネットドライバからのハンドラ
+ */
+static void ethernet_handler(void* i_param,NyLPC_TiEthernetDevice_EVENT i_type)
+{
+    switch(i_type){
+    case NyLPC_TiEthernetDevice_EVENT_ON_RX:
+        //受信系のセマフォブロックの解除
+        NyLPC_cSemaphore_giveFromISR(&(((NyLPC_TcUipService_t*)i_param)->_emac_semapho));
+        break;
+    default:
+        break;
+    }
+}
+
+/**
  * IPv4パケットのpeerIPを問い合わせるARPパケットを送信します。
  */
 static void sendArpReqest(const struct NyLPC_TIPv4Addr* i_addr)
@@ -405,14 +385,14 @@
     struct TEthPacket* ethbuf;
     //ACK送信用の自己バッファが空くまで待つ
     while(inst->stx.h.is_lock){
-        inst->_ethif->processTx();
+        NyLPC_iEthernetDevice_processTx(inst->_ethif);
     }
     //ARPパケットを作る。
     ethbuf=(struct TEthPacket*)(inst->stx.buf);
     NyLPC_TArpHeader_setArpRequest(&(ethbuf->data.arp),inst->_ref_config->ip_addr,&(inst->_ref_config->eth_mac),i_addr);
     tx_len=NyLPC_TEthernetIIHeader_setArpTx(&(ethbuf->header),&(inst->_ref_config->eth_mac));
     //送信
-    inst->_ethif->sendTxEthFrame(&(inst->stx.h),tx_len);
+    NyLPC_iEthernetDevice_sendTxEthFrame(inst->_ethif,&(inst->stx.h),tx_len);
 }
 
 
@@ -484,7 +464,7 @@
     struct NyLPC_TTxBufferHeader* ethbuf;
     //排他処理をして、メモリを取得する。
     NyLPC_cMutex_lock(&(inst->_mutex));
-    ethbuf=(struct NyLPC_TTxBufferHeader*)inst->_ethif->allocTxBuf(i_hint+sizeof(struct NyLPC_TEthernetIIHeader),o_size);
+    ethbuf=(struct NyLPC_TTxBufferHeader*)NyLPC_iEthernetDevice_allocTxBuf(inst->_ethif,i_hint+sizeof(struct NyLPC_TEthernetIIHeader),o_size);
     NyLPC_cMutex_unlock(&(inst->_mutex));
     if(ethbuf==NULL){
         return NULL;
@@ -502,7 +482,7 @@
     NyLPC_TcUipService_t* inst=_NyLPC_TcUipService_inst;
     NyLPC_cMutex_lock(&(inst->_mutex));
     //ペイロードの位置から、メモリブロックを再生。
-    inst->_ethif->releaseTxBuf(((struct NyLPC_TTxBufferHeader*)(((struct NyLPC_TEthernetIIHeader*)i_buf)-1))-1);
+    NyLPC_iEthernetDevice_releaseTxBuf(inst->_ethif,((struct NyLPC_TTxBufferHeader*)(((struct NyLPC_TEthernetIIHeader*)i_buf)-1))-1);
     NyLPC_cMutex_unlock(&(inst->_mutex));
     return NULL;
 }
@@ -528,7 +508,7 @@
     NyLPC_TUInt16 s;
     //ACK送信用の自己バッファが空くまで待つ
     while(inst->stx.h.is_lock){
-        inst->_ethif->processTx();
+        NyLPC_iEthernetDevice_processTx(inst->_ethif);
     }
     //送信する。
     s=NyLPC_htons(i_buf->data.ipv4.len16)+sizeof(struct NyLPC_TEthernetIIHeader);
@@ -557,7 +537,7 @@
 
     //ACK送信用の自己バッファが空くまで待つ
     while(inst->stx.h.is_lock){
-        inst->_ethif->processTx();
+        NyLPC_iEthernetDevice_processTx(inst->_ethif);
     }
     //64バイトを超えるとかありえない。
     if(i_len+sizeof(struct NyLPC_TEthernetIIHeader)>NyLPC_TcUipService_SIZE_OF_REPLY_BUF){
@@ -565,7 +545,7 @@
     }
     //送信する。
     memcpy(inst->stx.buf,i_buf,i_len);
-    inst->_ethif->sendTxEthFrame(&(inst->stx.h),i_len);
+    NyLPC_iEthernetDevice_sendTxEthFrame(inst->_ethif,&(inst->stx.h),i_len);
     return;
 }
 
@@ -619,7 +599,7 @@
     }
     //変換可能なら、イーサネットヘッダを更新して、送信処理へ。
     tx_len=NyLPC_TEthernetIIHeader_setIPv4Tx(&(ethbuf->header),&(inst->_ref_config->eth_mac),eth_dest);
-    inst->_ethif->sendTxEthFrame(i_eth_buf,tx_len);
+    NyLPC_iEthernetDevice_sendTxEthFrame(inst->_ethif,i_eth_buf,tx_len);
     return NyLPC_TBool_TRUE;
 }