Important changes to repositories hosted on mbed.com
Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.
To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.
It is also possible to export all your personal repositories from the account settings page.
Dependents: MbedFileServer_1768MiniDK2 RedWireBridge IssueDebug_gcc MiMicRemoteMCU-for-Mbed ... more
core/uip/NyLPC_cUipService.c@20:3b0b444b4deb, 2013-04-28 (annotated)
- Committer:
- nyatla
- Date:
- Sun Apr 28 08:54:44 2013 +0000
- Revision:
- 20:3b0b444b4deb
- Parent:
- 12:efe841863fc8
- Child:
- 21:f2a70f15301f
update MiMic core; (Fixed TCP stack bug)
Who changed what in which revision?
| User | Revision | Line number | New contents of line |
|---|---|---|---|
| nyatla | 0:142ee8b12fef | 1 | /********************************************************************************* |
| nyatla | 0:142ee8b12fef | 2 | * PROJECT: MiMic |
| nyatla | 0:142ee8b12fef | 3 | * -------------------------------------------------------------------------------- |
| nyatla | 0:142ee8b12fef | 4 | * |
| nyatla | 0:142ee8b12fef | 5 | * This file is part of MiMic |
| nyatla | 0:142ee8b12fef | 6 | * Copyright (C)2011 Ryo Iizuka |
| nyatla | 0:142ee8b12fef | 7 | * |
| nyatla | 0:142ee8b12fef | 8 | * MiMic is free software: you can redistribute it and/or modify |
| nyatla | 0:142ee8b12fef | 9 | * it under the terms of the GNU Lesser General Public License as published |
| nyatla | 0:142ee8b12fef | 10 | * by the Free Software Foundation, either version 3 of the License, or |
| nyatla | 0:142ee8b12fef | 11 | * (at your option) any later version. |
| nyatla | 0:142ee8b12fef | 12 | * |
| nyatla | 0:142ee8b12fef | 13 | * This program is distributed in the hope that it will be useful, |
| nyatla | 0:142ee8b12fef | 14 | * but WITHOUT ANY WARRANTY; without even the implied warranty of |
| nyatla | 0:142ee8b12fef | 15 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| nyatla | 0:142ee8b12fef | 16 | * GNU General Public License for more details. |
| nyatla | 0:142ee8b12fef | 17 | * |
| nyatla | 0:142ee8b12fef | 18 | * You should have received a copy of the GNU Lesser General Public License |
| nyatla | 0:142ee8b12fef | 19 | * along with this program. If not, see <http://www.gnu.org/licenses/>. |
| nyatla | 0:142ee8b12fef | 20 | * |
| nyatla | 0:142ee8b12fef | 21 | * For further information please contact. |
| nyatla | 0:142ee8b12fef | 22 | * http://nyatla.jp/ |
| nyatla | 0:142ee8b12fef | 23 | * <airmail(at)ebony.plala.or.jp> or <nyatla(at)nyatla.jp> |
| nyatla | 0:142ee8b12fef | 24 | * |
| nyatla | 0:142ee8b12fef | 25 | * |
| nyatla | 0:142ee8b12fef | 26 | * Parts of this file were leveraged from uIP: |
| nyatla | 0:142ee8b12fef | 27 | * |
| nyatla | 0:142ee8b12fef | 28 | * Copyright (c) 2001-2003, Adam Dunkels. |
| nyatla | 0:142ee8b12fef | 29 | * All rights reserved. |
| nyatla | 0:142ee8b12fef | 30 | * |
| nyatla | 0:142ee8b12fef | 31 | * Redistribution and use in source and binary forms, with or without |
| nyatla | 0:142ee8b12fef | 32 | * modification, are permitted provided that the following conditions |
| nyatla | 0:142ee8b12fef | 33 | * are met: |
| nyatla | 0:142ee8b12fef | 34 | * 1. Redistributions of source code must retain the above copyright |
| nyatla | 0:142ee8b12fef | 35 | * notice, this list of conditions and the following disclaimer. |
| nyatla | 0:142ee8b12fef | 36 | * 2. Redistributions in binary form must reproduce the above copyright |
| nyatla | 0:142ee8b12fef | 37 | * notice, this list of conditions and the following disclaimer in the |
| nyatla | 0:142ee8b12fef | 38 | * documentation and/or other materials provided with the distribution. |
| nyatla | 0:142ee8b12fef | 39 | * 3. The name of the author may not be used to endorse or promote |
| nyatla | 0:142ee8b12fef | 40 | * products derived from this software without specific prior |
| nyatla | 0:142ee8b12fef | 41 | * written permission. |
| nyatla | 0:142ee8b12fef | 42 | * |
| nyatla | 0:142ee8b12fef | 43 | * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS |
| nyatla | 0:142ee8b12fef | 44 | * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED |
| nyatla | 0:142ee8b12fef | 45 | * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE |
| nyatla | 0:142ee8b12fef | 46 | * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY |
| nyatla | 0:142ee8b12fef | 47 | * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL |
| nyatla | 0:142ee8b12fef | 48 | * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE |
| nyatla | 0:142ee8b12fef | 49 | * GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS |
| nyatla | 0:142ee8b12fef | 50 | * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, |
| nyatla | 0:142ee8b12fef | 51 | * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING |
| nyatla | 0:142ee8b12fef | 52 | * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
| nyatla | 0:142ee8b12fef | 53 | * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| nyatla | 0:142ee8b12fef | 54 | */ |
| nyatla | 2:b96c1e90d120 | 55 | #include "NyLPC_cIPv4IComp_protected.h" |
| nyatla | 0:142ee8b12fef | 56 | #include "NyLPC_cTcpListener_protected.h" |
| nyatla | 0:142ee8b12fef | 57 | #include "NyLPC_stdlib.h" |
| nyatla | 0:142ee8b12fef | 58 | #include "NyLPC_uip.h" |
| nyatla | 0:142ee8b12fef | 59 | |
| nyatla | 2:b96c1e90d120 | 60 | |
| nyatla | 2:b96c1e90d120 | 61 | |
| nyatla | 2:b96c1e90d120 | 62 | |
| nyatla | 0:142ee8b12fef | 63 | |
| nyatla | 0:142ee8b12fef | 64 | /**************************************************** |
| nyatla | 0:142ee8b12fef | 65 | * UipServiceに関する宣言:タスクメッセージ |
| nyatla | 0:142ee8b12fef | 66 | ***************************************************/ |
| nyatla | 0:142ee8b12fef | 67 | |
| nyatla | 0:142ee8b12fef | 68 | #define TTaskMsg_NOP 0 |
| nyatla | 0:142ee8b12fef | 69 | #define TTaskMsg_START 1 |
| nyatla | 0:142ee8b12fef | 70 | #define TTaskMsg_STOP 2 |
| nyatla | 0:142ee8b12fef | 71 | |
| nyatla | 0:142ee8b12fef | 72 | /** |
| nyatla | 0:142ee8b12fef | 73 | * サービスの起動メッセージです。 |
| nyatla | 0:142ee8b12fef | 74 | */ |
| nyatla | 0:142ee8b12fef | 75 | struct TTaskMsg{ |
| nyatla | 0:142ee8b12fef | 76 | NyLPC_TUInt16 msg; |
| nyatla | 0:142ee8b12fef | 77 | union{ |
| nyatla | 0:142ee8b12fef | 78 | struct{ |
| nyatla | 0:142ee8b12fef | 79 | const NyLPC_TcIPv4Config_t* ref_config; |
| nyatla | 0:142ee8b12fef | 80 | }start; |
| nyatla | 0:142ee8b12fef | 81 | }; |
| nyatla | 0:142ee8b12fef | 82 | }; |
| nyatla | 0:142ee8b12fef | 83 | |
| nyatla | 0:142ee8b12fef | 84 | /**************************************************** |
| nyatla | 0:142ee8b12fef | 85 | * UipServiceに関する宣言:その他 |
| nyatla | 0:142ee8b12fef | 86 | ***************************************************/ |
| nyatla | 0:142ee8b12fef | 87 | /** |
| nyatla | 0:142ee8b12fef | 88 | * イーサネットフレームの読み出し構造体 |
| nyatla | 0:142ee8b12fef | 89 | */ |
| nyatla | 0:142ee8b12fef | 90 | struct TEthPacket |
| nyatla | 0:142ee8b12fef | 91 | { |
| nyatla | 0:142ee8b12fef | 92 | struct NyLPC_TEthernetIIHeader header; |
| nyatla | 0:142ee8b12fef | 93 | union{ |
| nyatla | 0:142ee8b12fef | 94 | struct NyLPC_TArpHeader arp; |
| nyatla | 0:142ee8b12fef | 95 | struct NyLPC_TIPv4Header ipv4; |
| nyatla | 0:142ee8b12fef | 96 | }data; |
| nyatla | 0:142ee8b12fef | 97 | }; |
| nyatla | 0:142ee8b12fef | 98 | |
| nyatla | 0:142ee8b12fef | 99 | |
| nyatla | 0:142ee8b12fef | 100 | |
| nyatla | 0:142ee8b12fef | 101 | /** |
| nyatla | 0:142ee8b12fef | 102 | * サービスインスタンスのポインタ。サービスが稼働中はインスタンスのポインタが有効です。 |
| nyatla | 0:142ee8b12fef | 103 | */ |
| nyatla | 0:142ee8b12fef | 104 | NyLPC_TcUipService_t* _NyLPC_TcUipService_inst=NULL; |
| nyatla | 0:142ee8b12fef | 105 | |
| nyatla | 0:142ee8b12fef | 106 | /** |
| nyatla | 0:142ee8b12fef | 107 | * 唯一のインスタンス |
| nyatla | 0:142ee8b12fef | 108 | */ |
| nyatla | 0:142ee8b12fef | 109 | static NyLPC_TcUipService_t _service_instance; |
| nyatla | 0:142ee8b12fef | 110 | |
| nyatla | 0:142ee8b12fef | 111 | |
| nyatla | 0:142ee8b12fef | 112 | |
| nyatla | 0:142ee8b12fef | 113 | |
| nyatla | 0:142ee8b12fef | 114 | /** |
| nyatla | 0:142ee8b12fef | 115 | * uipタスク |
| nyatla | 0:142ee8b12fef | 116 | */ |
| nyatla | 0:142ee8b12fef | 117 | static int uipTask(void *pvParameters); |
| nyatla | 0:142ee8b12fef | 118 | |
| nyatla | 0:142ee8b12fef | 119 | //-------------------------------------------------------------- |
| nyatla | 0:142ee8b12fef | 120 | |
| nyatla | 0:142ee8b12fef | 121 | |
| nyatla | 0:142ee8b12fef | 122 | static NyLPC_TBool sendIPv4Tx(struct NyLPC_TTxBufferHeader* i_eth_buf); |
| nyatla | 0:142ee8b12fef | 123 | static void copyAndSendIPv4Tx(const struct TEthPacket* i_buf); |
| nyatla | 0:142ee8b12fef | 124 | static void sendArpReqest(const struct TEthPacket* i_eth_packet); |
| nyatla | 0:142ee8b12fef | 125 | static void sendRawEthFrame(void* i_buf,NyLPC_TUInt16 i_len); |
| nyatla | 0:142ee8b12fef | 126 | static void emacIsrHandler(unsigned long i_status); |
| nyatla | 0:142ee8b12fef | 127 | |
| nyatla | 0:142ee8b12fef | 128 | /**メッセージなし*/ |
| nyatla | 0:142ee8b12fef | 129 | #define TTaskMessage_MSG_NULL 0x0000 |
| nyatla | 0:142ee8b12fef | 130 | /**uipコアタスクに、開始要求する*/ |
| nyatla | 0:142ee8b12fef | 131 | #define TTaskMessage_MSG_RUN 0x0001 |
| nyatla | 0:142ee8b12fef | 132 | /**uipコアタスクに、停止要求する*/ |
| nyatla | 0:142ee8b12fef | 133 | #define TTaskMessage_MSG_STOP 0x0002 |
| nyatla | 0:142ee8b12fef | 134 | |
| nyatla | 0:142ee8b12fef | 135 | |
| nyatla | 0:142ee8b12fef | 136 | NyLPC_TcThread_t th; |
| nyatla | 0:142ee8b12fef | 137 | |
| nyatla | 0:142ee8b12fef | 138 | NyLPC_TBool NyLPC_cUipService_initialize(void) |
| nyatla | 0:142ee8b12fef | 139 | { |
| nyatla | 2:b96c1e90d120 | 140 | |
| nyatla | 0:142ee8b12fef | 141 | NyLPC_TcUipService_t* inst=&_service_instance; |
| nyatla | 0:142ee8b12fef | 142 | //サービスは停止している事。 - Service must be uninitialized. |
| nyatla | 0:142ee8b12fef | 143 | NyLPC_Assert(!NyLPC_TcUipService_isInitService()); |
| nyatla | 0:142ee8b12fef | 144 | //IP処理部分の初期化 |
| nyatla | 0:142ee8b12fef | 145 | NyLPC_cIPv4_initialize(&(inst->_tcpv4)); |
| nyatla | 0:142ee8b12fef | 146 | //EMACからの割込処理 |
| nyatla | 1:9f6a78395432 | 147 | NyLPC_cIsr_setEnetISR(emacIsrHandler); |
| nyatla | 0:142ee8b12fef | 148 | //EMAC割込セマフォ |
| nyatla | 0:142ee8b12fef | 149 | NyLPC_cSemaphore_initialize(&inst->_emac_semapho); |
| nyatla | 0:142ee8b12fef | 150 | |
| nyatla | 0:142ee8b12fef | 151 | inst->_task_cmd=NULL; |
| nyatla | 0:142ee8b12fef | 152 | inst->_status=NyLPC_TcUipService_STATUS_STOP; |
| nyatla | 0:142ee8b12fef | 153 | NyLPC_cStopwatch_initialize(&(inst->_arp_sw)); |
| nyatla | 0:142ee8b12fef | 154 | NyLPC_cStopwatch_initialize(&(inst->_periodic_sw)); |
| nyatla | 0:142ee8b12fef | 155 | NyLPC_cIPv4_initialize(&(inst->_tcpv4)); |
| nyatla | 0:142ee8b12fef | 156 | NyLPC_AbortIfNot(NyLPC_cMutex_initialize(&(inst->_mutex))); |
| nyatla | 0:142ee8b12fef | 157 | |
| nyatla | 0:142ee8b12fef | 158 | _NyLPC_TcUipService_inst=inst; |
| nyatla | 0:142ee8b12fef | 159 | inst->stx.h.is_lock=NyLPC_TUInt8_FALSE; |
| nyatla | 0:142ee8b12fef | 160 | inst->stx.h.ref=0; |
| nyatla | 0:142ee8b12fef | 161 | //タスク起動 |
| nyatla | 0:142ee8b12fef | 162 | NyLPC_cThread_initialize(&th,NyLPC_TcUipService_config_STACK_SIZE,NyLPC_TcThread_PRIORITY_SERVICE); |
| nyatla | 0:142ee8b12fef | 163 | NyLPC_cThread_start(&th,uipTask,NULL); |
| nyatla | 0:142ee8b12fef | 164 | // NyLPC_AbortIfNot(pdPASS==xTaskCreate( |
| nyatla | 0:142ee8b12fef | 165 | // uipTask, |
| nyatla | 0:142ee8b12fef | 166 | // (signed char*)NyLPC_TcUipService_config_TASK_NAME, |
| nyatla | 0:142ee8b12fef | 167 | // NyLPC_TcUipService_config_STACK_SIZE, |
| nyatla | 0:142ee8b12fef | 168 | // ( void * ) NULL, |
| nyatla | 0:142ee8b12fef | 169 | // NyLPC_TcUipService_config_TASK_PRIORITY, |
| nyatla | 0:142ee8b12fef | 170 | // (void*)_NyLPC_TcUipService_inst)); |
| nyatla | 0:142ee8b12fef | 171 | return NyLPC_TBool_TRUE; |
| nyatla | 0:142ee8b12fef | 172 | } |
| nyatla | 0:142ee8b12fef | 173 | |
| nyatla | 0:142ee8b12fef | 174 | |
| nyatla | 0:142ee8b12fef | 175 | |
| nyatla | 0:142ee8b12fef | 176 | |
| nyatla | 0:142ee8b12fef | 177 | |
| nyatla | 0:142ee8b12fef | 178 | |
| nyatla | 0:142ee8b12fef | 179 | |
| nyatla | 0:142ee8b12fef | 180 | /** |
| nyatla | 0:142ee8b12fef | 181 | * UIP処理を開始します。 |
| nyatla | 0:142ee8b12fef | 182 | * この関数はリエントラントではありません。複数のタスクから共有するときには、排他ロックを掛けてください。 |
| nyatla | 0:142ee8b12fef | 183 | * @param i_ref_config |
| nyatla | 0:142ee8b12fef | 184 | * このコンフィギュレーションは、stopを実行するまでの間、インスタンスから参照します。外部で保持してください。 |
| nyatla | 0:142ee8b12fef | 185 | */ |
| nyatla | 0:142ee8b12fef | 186 | void NyLPC_cUipService_start(const NyLPC_TcIPv4Config_t* i_ref_config) |
| nyatla | 0:142ee8b12fef | 187 | { |
| nyatla | 0:142ee8b12fef | 188 | NyLPC_TcUipService_t* inst=&_service_instance; |
| nyatla | 0:142ee8b12fef | 189 | struct TTaskMsg msg; |
| nyatla | 0:142ee8b12fef | 190 | NyLPC_Assert(NyLPC_TcUipService_isInitService()); |
| nyatla | 0:142ee8b12fef | 191 | if(!NyLPC_cUipService_isRun()) |
| nyatla | 0:142ee8b12fef | 192 | { |
| nyatla | 0:142ee8b12fef | 193 | //はじめて起動するときに1度だけデバイス取得(タスクスイッチが動いてないと動かないからここで。) |
| nyatla | 0:142ee8b12fef | 194 | if(inst->_ethif==NULL){ |
| nyatla | 0:142ee8b12fef | 195 | inst->_ethif=getEthernetDevicePnP(); |
| nyatla | 0:142ee8b12fef | 196 | } |
| nyatla | 0:142ee8b12fef | 197 | //コマンドセット |
| nyatla | 0:142ee8b12fef | 198 | msg.msg=TTaskMsg_START; |
| nyatla | 0:142ee8b12fef | 199 | msg.start.ref_config=i_ref_config; |
| nyatla | 0:142ee8b12fef | 200 | _NyLPC_TcUipService_inst->_task_cmd=&msg; |
| nyatla | 0:142ee8b12fef | 201 | //状態が変わるまでループ |
| nyatla | 0:142ee8b12fef | 202 | while(!NyLPC_cUipService_isRun()){ |
| nyatla | 0:142ee8b12fef | 203 | NyLPC_cThread_sleep(10); |
| nyatla | 0:142ee8b12fef | 204 | } |
| nyatla | 0:142ee8b12fef | 205 | } |
| nyatla | 0:142ee8b12fef | 206 | //コマンドクリア |
| nyatla | 0:142ee8b12fef | 207 | _NyLPC_TcUipService_inst->_task_cmd=NULL; |
| nyatla | 0:142ee8b12fef | 208 | return; |
| nyatla | 0:142ee8b12fef | 209 | } |
| nyatla | 0:142ee8b12fef | 210 | /** |
| nyatla | 0:142ee8b12fef | 211 | * UIP処理を停止します。 |
| nyatla | 0:142ee8b12fef | 212 | * この関数はリエントラントではありません。複数のタスクから共有するときには、排他ロックを掛けてください。 |
| nyatla | 0:142ee8b12fef | 213 | * いまのところ、ストップシーケンスの実装は良くありません。 |
| nyatla | 0:142ee8b12fef | 214 | * 再設計が必要。 |
| nyatla | 0:142ee8b12fef | 215 | */ |
| nyatla | 0:142ee8b12fef | 216 | void NyLPC_cUipService_stop(void) |
| nyatla | 0:142ee8b12fef | 217 | { |
| nyatla | 0:142ee8b12fef | 218 | struct TTaskMsg msg; |
| nyatla | 0:142ee8b12fef | 219 | NyLPC_TcUipService_t* inst=&_service_instance; |
| nyatla | 0:142ee8b12fef | 220 | NyLPC_Assert(NyLPC_TcUipService_isInitService()); |
| nyatla | 0:142ee8b12fef | 221 | if(NyLPC_cUipService_isRun()) |
| nyatla | 0:142ee8b12fef | 222 | { |
| nyatla | 0:142ee8b12fef | 223 | //コマンドセット |
| nyatla | 0:142ee8b12fef | 224 | msg.msg=TTaskMsg_STOP; |
| nyatla | 0:142ee8b12fef | 225 | _NyLPC_TcUipService_inst->_task_cmd=&msg; |
| nyatla | 0:142ee8b12fef | 226 | //状態が変わるまでループ |
| nyatla | 0:142ee8b12fef | 227 | while(NyLPC_cUipService_isRun()){ |
| nyatla | 0:142ee8b12fef | 228 | NyLPC_cThread_sleep(10); |
| nyatla | 0:142ee8b12fef | 229 | } |
| nyatla | 0:142ee8b12fef | 230 | NyLPC_cIPv4_stop(&(inst->_tcpv4)); |
| nyatla | 0:142ee8b12fef | 231 | |
| nyatla | 0:142ee8b12fef | 232 | } |
| nyatla | 0:142ee8b12fef | 233 | //コマンドクリア |
| nyatla | 0:142ee8b12fef | 234 | _NyLPC_TcUipService_inst->_task_cmd=NULL; |
| nyatla | 0:142ee8b12fef | 235 | return; |
| nyatla | 0:142ee8b12fef | 236 | } |
| nyatla | 0:142ee8b12fef | 237 | |
| nyatla | 0:142ee8b12fef | 238 | |
| nyatla | 0:142ee8b12fef | 239 | const char* NyLPC_cUipService_refDeviceName(void) |
| nyatla | 0:142ee8b12fef | 240 | { |
| nyatla | 0:142ee8b12fef | 241 | NyLPC_TcUipService_t* inst=&_service_instance; |
| nyatla | 0:142ee8b12fef | 242 | return NyLPC_cUipService_isRun()?inst->_ethif->device_name:NULL; |
| nyatla | 0:142ee8b12fef | 243 | } |
| nyatla | 0:142ee8b12fef | 244 | |
| nyatla | 0:142ee8b12fef | 245 | /********************************************************************** |
| nyatla | 0:142ee8b12fef | 246 | * |
| nyatla | 0:142ee8b12fef | 247 | * </HWコールバックに関わる宣言> |
| nyatla | 0:142ee8b12fef | 248 | * |
| nyatla | 0:142ee8b12fef | 249 | *********************************************************************/ |
| nyatla | 0:142ee8b12fef | 250 | |
| nyatla | 0:142ee8b12fef | 251 | /** |
| nyatla | 0:142ee8b12fef | 252 | * EMACからのハンドラ |
| nyatla | 0:142ee8b12fef | 253 | */ |
| nyatla | 0:142ee8b12fef | 254 | static void emacIsrHandler(unsigned long i_status) |
| nyatla | 0:142ee8b12fef | 255 | { |
| nyatla | 0:142ee8b12fef | 256 | NyLPC_TcUipService_t* inst=&_service_instance; |
| nyatla | 0:142ee8b12fef | 257 | |
| nyatla | 0:142ee8b12fef | 258 | if( i_status & INT_RX_DONE ) |
| nyatla | 0:142ee8b12fef | 259 | { |
| nyatla | 0:142ee8b12fef | 260 | //受信系のセマフォブロックの解除 |
| nyatla | 0:142ee8b12fef | 261 | NyLPC_cSemaphore_giveFromISR(&inst->_emac_semapho); |
| nyatla | 0:142ee8b12fef | 262 | } |
| nyatla | 0:142ee8b12fef | 263 | if( i_status & INT_TX_DONE ) |
| nyatla | 0:142ee8b12fef | 264 | { |
| nyatla | 0:142ee8b12fef | 265 | } |
| nyatla | 0:142ee8b12fef | 266 | } |
| nyatla | 0:142ee8b12fef | 267 | |
| nyatla | 0:142ee8b12fef | 268 | |
| nyatla | 0:142ee8b12fef | 269 | //PERIODIC rate |
| nyatla | 0:142ee8b12fef | 270 | #define PERIODIC_TIMER (1*200) |
| nyatla | 0:142ee8b12fef | 271 | #define ARP_TIMER (60*1000*10) |
| nyatla | 0:142ee8b12fef | 272 | |
| nyatla | 0:142ee8b12fef | 273 | /** |
| nyatla | 0:142ee8b12fef | 274 | * 操作キューを確認して、タスクのステータスをアップデートします。 |
| nyatla | 0:142ee8b12fef | 275 | * 高速化のため、Proc-Callerを使用していません。複雑なタスク操作をするときには、書き換えてください。 |
| nyatla | 0:142ee8b12fef | 276 | */ |
| nyatla | 0:142ee8b12fef | 277 | static void updateTaskStatus() |
| nyatla | 0:142ee8b12fef | 278 | { |
| nyatla | 0:142ee8b12fef | 279 | NyLPC_TcUipService_t* inst=_NyLPC_TcUipService_inst; |
| nyatla | 0:142ee8b12fef | 280 | |
| nyatla | 0:142ee8b12fef | 281 | struct TTaskMsg* msg=(struct TTaskMsg*)(inst->_task_cmd); |
| nyatla | 0:142ee8b12fef | 282 | |
| nyatla | 0:142ee8b12fef | 283 | //コマンドが設定されていない時は、何もしない。 |
| nyatla | 0:142ee8b12fef | 284 | if(msg==NULL){ |
| nyatla | 0:142ee8b12fef | 285 | return; |
| nyatla | 0:142ee8b12fef | 286 | } |
| nyatla | 0:142ee8b12fef | 287 | switch(msg->msg) |
| nyatla | 0:142ee8b12fef | 288 | { |
| nyatla | 0:142ee8b12fef | 289 | //何もしない。 |
| nyatla | 0:142ee8b12fef | 290 | case TTaskMsg_NOP: |
| nyatla | 0:142ee8b12fef | 291 | break; |
| nyatla | 0:142ee8b12fef | 292 | //開始操作 |
| nyatla | 0:142ee8b12fef | 293 | case TTaskMsg_START: |
| nyatla | 0:142ee8b12fef | 294 | //状態チェック |
| nyatla | 0:142ee8b12fef | 295 | if(NyLPC_cUipService_isRun()){ |
| nyatla | 0:142ee8b12fef | 296 | break; |
| nyatla | 0:142ee8b12fef | 297 | } |
| nyatla | 0:142ee8b12fef | 298 | inst->_ref_config=msg->start.ref_config; |
| nyatla | 0:142ee8b12fef | 299 | //TCP,ICOMPの初期化 |
| nyatla | 0:142ee8b12fef | 300 | NyLPC_cIPv4_start(&(inst->_tcpv4),inst->_ref_config); |
| nyatla | 0:142ee8b12fef | 301 | NyLPC_cIPv4IComp_initialize(&(inst->_icomp),inst->_ref_config); |
| nyatla | 0:142ee8b12fef | 302 | //uip_arp_init(msg->start.ref_config); |
| nyatla | 0:142ee8b12fef | 303 | NyLPC_cIPv4Arp_initialize(&(inst->_arp),inst->_ref_config); |
| nyatla | 0:142ee8b12fef | 304 | NyLPC_cStopwatch_startExpire(&(inst->_arp_sw),1);//1度ARPを起動するため。 |
| nyatla | 0:142ee8b12fef | 305 | NyLPC_cStopwatch_startExpire(&(inst->_periodic_sw),PERIODIC_TIMER); |
| nyatla | 0:142ee8b12fef | 306 | while(!inst->_ethif->start(&(inst->_ref_config->eth_mac))); |
| nyatla | 0:142ee8b12fef | 307 | inst->_status=NyLPC_TcUipService_STATUS_RUN; |
| nyatla | 0:142ee8b12fef | 308 | break; |
| nyatla | 0:142ee8b12fef | 309 | //終了操作 |
| nyatla | 0:142ee8b12fef | 310 | case TTaskMsg_STOP: |
| nyatla | 0:142ee8b12fef | 311 | //状態チェック |
| nyatla | 0:142ee8b12fef | 312 | if(!NyLPC_cUipService_isRun()){ |
| nyatla | 0:142ee8b12fef | 313 | break; |
| nyatla | 0:142ee8b12fef | 314 | } |
| nyatla | 0:142ee8b12fef | 315 | //停止操作 |
| nyatla | 0:142ee8b12fef | 316 | inst->_ethif->stop(); |
| nyatla | 0:142ee8b12fef | 317 | NyLPC_cIPv4_stop(&(inst->_tcpv4)); |
| nyatla | 0:142ee8b12fef | 318 | NyLPC_cIPv4IComp_finalize(&(inst->_icomp)); |
| nyatla | 0:142ee8b12fef | 319 | inst->_status=NyLPC_TcUipService_STATUS_STOP; |
| nyatla | 0:142ee8b12fef | 320 | break; |
| nyatla | 0:142ee8b12fef | 321 | default: |
| nyatla | 0:142ee8b12fef | 322 | //実行してはいけない。 |
| nyatla | 0:142ee8b12fef | 323 | NyLPC_Abort(); |
| nyatla | 0:142ee8b12fef | 324 | } |
| nyatla | 0:142ee8b12fef | 325 | //コマンドを無効化 |
| nyatla | 0:142ee8b12fef | 326 | inst->_task_cmd=TTaskMsg_NOP; |
| nyatla | 0:142ee8b12fef | 327 | return; |
| nyatla | 0:142ee8b12fef | 328 | } |
| nyatla | 0:142ee8b12fef | 329 | |
| nyatla | 0:142ee8b12fef | 330 | /** |
| nyatla | 0:142ee8b12fef | 331 | * uipタスクのメインループ |
| nyatla | 0:142ee8b12fef | 332 | */ |
| nyatla | 0:142ee8b12fef | 333 | static int uipTask(void *pvParameters) |
| nyatla | 0:142ee8b12fef | 334 | { |
| nyatla | 0:142ee8b12fef | 335 | NyLPC_TUInt16 rx_len,tx_len; |
| nyatla | 0:142ee8b12fef | 336 | struct TEthPacket* ethbuf; |
| nyatla | 0:142ee8b12fef | 337 | NyLPC_TcUipService_t* inst=_NyLPC_TcUipService_inst; |
| nyatla | 0:142ee8b12fef | 338 | NyLPC_TBool r; |
| nyatla | 0:142ee8b12fef | 339 | (void)pvParameters; |
| nyatla | 0:142ee8b12fef | 340 | for( ;; ) |
| nyatla | 0:142ee8b12fef | 341 | { |
| nyatla | 0:142ee8b12fef | 342 | //タスク状態の更新 |
| nyatla | 0:142ee8b12fef | 343 | updateTaskStatus(); |
| nyatla | 0:142ee8b12fef | 344 | if(inst->_status!=NyLPC_TcUipService_STATUS_RUN) |
| nyatla | 0:142ee8b12fef | 345 | { |
| nyatla | 0:142ee8b12fef | 346 | //RUNステータス以外の時は、ここで終了する。 |
| nyatla | 0:142ee8b12fef | 347 | NyLPC_cThread_sleep(50); |
| nyatla | 0:142ee8b12fef | 348 | continue; |
| nyatla | 0:142ee8b12fef | 349 | } |
| nyatla | 0:142ee8b12fef | 350 | //イーサネットフレームの取得 |
| nyatla | 0:142ee8b12fef | 351 | //Ethernet Device Lock(ARPを含む) |
| nyatla | 2:b96c1e90d120 | 352 | NyLPC_cMutex_lock(&(inst->_mutex)); |
| nyatla | 0:142ee8b12fef | 353 | ethbuf= (struct TEthPacket*)inst->_ethif->getRxEthFrame(&rx_len); |
| nyatla | 0:142ee8b12fef | 354 | tx_len=0; |
| nyatla | 0:142ee8b12fef | 355 | while(ethbuf != NULL){ |
| nyatla | 0:142ee8b12fef | 356 | if(rx_len>0) |
| nyatla | 0:142ee8b12fef | 357 | { |
| nyatla | 0:142ee8b12fef | 358 | //ペイロードサイズを計算 |
| nyatla | 0:142ee8b12fef | 359 | rx_len-=sizeof(struct NyLPC_TEthernetIIHeader); |
| nyatla | 0:142ee8b12fef | 360 | switch(ethbuf->header.type) |
| nyatla | 0:142ee8b12fef | 361 | { |
| nyatla | 0:142ee8b12fef | 362 | case NyLPC_HTONS(NyLPC_TEthernetIIHeader_TYPE_IP): |
| nyatla | 0:142ee8b12fef | 363 | //ARPテーブルの更新 |
| nyatla | 0:142ee8b12fef | 364 | //uip_arp_ipin(&(ethbuf->header),ethbuf->data.ipv4.srcipaddr); |
| nyatla | 0:142ee8b12fef | 365 | NyLPC_cIPv4Arp_incomingIp(&inst->_arp,&(ethbuf->header),ethbuf->data.ipv4.srcipaddr); |
| nyatla | 0:142ee8b12fef | 366 | //Ethernet Device UnLock(パケット解析の為に一時的な解除) |
| nyatla | 0:142ee8b12fef | 367 | NyLPC_cMutex_unlock(&(inst->_mutex)); |
| nyatla | 0:142ee8b12fef | 368 | //IPパケットの処理 |
| nyatla | 0:142ee8b12fef | 369 | r=NyLPC_cIPv4_rx(&(inst->_tcpv4),&(ethbuf->data.ipv4),rx_len); |
| nyatla | 0:142ee8b12fef | 370 | //ロックの復帰 |
| nyatla | 0:142ee8b12fef | 371 | NyLPC_cMutex_lock(&(inst->_mutex)); |
| nyatla | 0:142ee8b12fef | 372 | if(!r){ |
| nyatla | 0:142ee8b12fef | 373 | //応答データは存在しない。 |
| nyatla | 0:142ee8b12fef | 374 | break; |
| nyatla | 0:142ee8b12fef | 375 | } |
| nyatla | 0:142ee8b12fef | 376 | //IPパケットをTxバッファに転写して送信 |
| nyatla | 0:142ee8b12fef | 377 | copyAndSendIPv4Tx(ethbuf); |
| nyatla | 0:142ee8b12fef | 378 | ethbuf=NULL; |
| nyatla | 0:142ee8b12fef | 379 | break; |
| nyatla | 0:142ee8b12fef | 380 | case NyLPC_HTONS(NyLPC_TEthernetIIHeader_TYPE_ARP): |
| nyatla | 0:142ee8b12fef | 381 | //if(uip_arp_arpin(&(ethbuf->data.arp),rx_len)){ |
| nyatla | 0:142ee8b12fef | 382 | if(NyLPC_cIPv4Arp_incomingArp(&inst->_arp,&(ethbuf->data.arp),rx_len)){ |
| nyatla | 0:142ee8b12fef | 383 | tx_len=NyLPC_TEthernetIIHeader_setArpTx(&(ethbuf->header),&(inst->_ref_config->eth_mac)); |
| nyatla | 0:142ee8b12fef | 384 | } |
| nyatla | 0:142ee8b12fef | 385 | if(tx_len>0){ |
| nyatla | 0:142ee8b12fef | 386 | sendRawEthFrame(ethbuf,tx_len); |
| nyatla | 0:142ee8b12fef | 387 | } |
| nyatla | 0:142ee8b12fef | 388 | break; |
| nyatla | 0:142ee8b12fef | 389 | case NyLPC_HTONS(NyLPC_TEthernetIIHeader_TYPE_IPV6): |
| nyatla | 0:142ee8b12fef | 390 | //uip_process_ipv6(); |
| nyatla | 0:142ee8b12fef | 391 | break; |
| nyatla | 0:142ee8b12fef | 392 | default: |
| nyatla | 0:142ee8b12fef | 393 | break; |
| nyatla | 0:142ee8b12fef | 394 | } |
| nyatla | 0:142ee8b12fef | 395 | } |
| nyatla | 2:b96c1e90d120 | 396 | //受信キューを進行。 |
| nyatla | 0:142ee8b12fef | 397 | inst->_ethif->nextRxEthFrame(); |
| nyatla | 0:142ee8b12fef | 398 | //受信処理 |
| nyatla | 0:142ee8b12fef | 399 | ethbuf= (struct TEthPacket*)inst->_ethif->getRxEthFrame(&rx_len); |
| nyatla | 0:142ee8b12fef | 400 | } |
| nyatla | 0:142ee8b12fef | 401 | //データが無い。 |
| nyatla | 0:142ee8b12fef | 402 | if(NyLPC_cStopwatch_isExpired(&(inst->_arp_sw))){ |
| nyatla | 0:142ee8b12fef | 403 | //uip_arp_timer(); |
| nyatla | 0:142ee8b12fef | 404 | NyLPC_cIPv4Arp_periodic(&inst->_arp); |
| nyatla | 0:142ee8b12fef | 405 | NyLPC_cStopwatch_startExpire(&(inst->_arp_sw),ARP_TIMER); |
| nyatla | 2:b96c1e90d120 | 406 | } |
| nyatla | 0:142ee8b12fef | 407 | if(NyLPC_cStopwatch_isExpired(&(inst->_periodic_sw))){ |
| nyatla | 0:142ee8b12fef | 408 | NyLPC_cIPv4_periodec(&(inst->_tcpv4)); |
| nyatla | 0:142ee8b12fef | 409 | NyLPC_cStopwatch_startExpire(&(inst->_periodic_sw),PERIODIC_TIMER); |
| nyatla | 0:142ee8b12fef | 410 | } |
| nyatla | 0:142ee8b12fef | 411 | //リソースロックの解除 |
| nyatla | 0:142ee8b12fef | 412 | NyLPC_cMutex_unlock(&(inst->_mutex)); |
| nyatla | 0:142ee8b12fef | 413 | //割込によるセマフォの解除か、タイムアウトで再開する。(タイムアウト値は周期関数の実行レート以下にすること。) |
| nyatla | 0:142ee8b12fef | 414 | NyLPC_cSemaphore_take(&(_NyLPC_TcUipService_inst->_emac_semapho),PERIODIC_TIMER); |
| nyatla | 0:142ee8b12fef | 415 | } |
| nyatla | 0:142ee8b12fef | 416 | return 0; |
| nyatla | 0:142ee8b12fef | 417 | } |
| nyatla | 0:142ee8b12fef | 418 | |
| nyatla | 0:142ee8b12fef | 419 | |
| nyatla | 0:142ee8b12fef | 420 | |
| nyatla | 0:142ee8b12fef | 421 | |
| nyatla | 0:142ee8b12fef | 422 | /** |
| nyatla | 0:142ee8b12fef | 423 | * allocTxBufで取得したメモリを"IPパケットとして"送信します。 |
| nyatla | 0:142ee8b12fef | 424 | * @param i_eth_payload |
| nyatla | 0:142ee8b12fef | 425 | * [NyLPC_TTxBufferHeader][NyLPC_TEthernetIIHeader][payload]メモリの、[payload]のアドレスを指定します。 |
| nyatla | 0:142ee8b12fef | 426 | * 通常は、NyLPC_cUipService_allocTxBufの返却したメモリを指定します。 |
| nyatla | 0:142ee8b12fef | 427 | */ |
| nyatla | 0:142ee8b12fef | 428 | |
| nyatla | 0:142ee8b12fef | 429 | void NyLPC_cUipService_sendIPv4Tx(void* i_eth_payload) |
| nyatla | 0:142ee8b12fef | 430 | { |
| nyatla | 0:142ee8b12fef | 431 | NyLPC_TcUipService_t* inst=_NyLPC_TcUipService_inst; |
| nyatla | 0:142ee8b12fef | 432 | NyLPC_cMutex_lock(&(inst->_mutex)); |
| nyatla | 0:142ee8b12fef | 433 | //IPパケットの送信を試行 |
| nyatla | 0:142ee8b12fef | 434 | if(!sendIPv4Tx(((struct NyLPC_TTxBufferHeader*)(((struct NyLPC_TEthernetIIHeader*)i_eth_payload)-1))-1)){ |
| nyatla | 0:142ee8b12fef | 435 | //ARPリクエストを代わりに送信 |
| nyatla | 0:142ee8b12fef | 436 | sendArpReqest(((struct TEthPacket*)i_eth_payload)-1); |
| nyatla | 0:142ee8b12fef | 437 | } |
| nyatla | 0:142ee8b12fef | 438 | NyLPC_cMutex_unlock(&(inst->_mutex)); |
| nyatla | 0:142ee8b12fef | 439 | return; |
| nyatla | 0:142ee8b12fef | 440 | } |
| nyatla | 0:142ee8b12fef | 441 | |
| nyatla | 0:142ee8b12fef | 442 | |
| nyatla | 0:142ee8b12fef | 443 | |
| nyatla | 0:142ee8b12fef | 444 | |
| nyatla | 0:142ee8b12fef | 445 | /** |
| nyatla | 0:142ee8b12fef | 446 | * 送信ペイロードメモリを返します。 |
| nyatla | 0:142ee8b12fef | 447 | * この関数は、リエントラントを許容します。 |
| nyatla | 0:142ee8b12fef | 448 | * @param i_hint |
| nyatla | 0:142ee8b12fef | 449 | * 取得したいメモリサイズを指定します。(このサイズは、イーサネットヘッダのサイズを含みません。) |
| nyatla | 0:142ee8b12fef | 450 | * このサイズよりも小さなサイズが割り当てられることがあります。 |
| nyatla | 0:142ee8b12fef | 451 | * @return |
| nyatla | 20:3b0b444b4deb | 452 | * 成功:IPペイロードのためのメモリブロックを返します。/失敗:NULL |
| nyatla | 0:142ee8b12fef | 453 | */ |
| nyatla | 0:142ee8b12fef | 454 | void* NyLPC_cUipService_allocTxBuf(NyLPC_TUInt16 i_hint,NyLPC_TUInt16* o_size) |
| nyatla | 0:142ee8b12fef | 455 | { |
| nyatla | 0:142ee8b12fef | 456 | //排他処理をして、メモリを取得する。 |
| nyatla | 0:142ee8b12fef | 457 | NyLPC_TcUipService_t* inst=_NyLPC_TcUipService_inst; |
| nyatla | 0:142ee8b12fef | 458 | struct NyLPC_TTxBufferHeader* ethbuf; |
| nyatla | 0:142ee8b12fef | 459 | NyLPC_cMutex_lock(&(inst->_mutex)); |
| nyatla | 0:142ee8b12fef | 460 | ethbuf=(struct NyLPC_TTxBufferHeader*)inst->_ethif->allocTxBuf(i_hint+sizeof(struct NyLPC_TEthernetIIHeader),o_size); |
| nyatla | 0:142ee8b12fef | 461 | NyLPC_cMutex_unlock(&(inst->_mutex)); |
| nyatla | 20:3b0b444b4deb | 462 | if(ethbuf==NULL){ |
| nyatla | 20:3b0b444b4deb | 463 | return NULL; |
| nyatla | 0:142ee8b12fef | 464 | } |
| nyatla | 20:3b0b444b4deb | 465 | //イーサネットバッファのサイズを計算 |
| nyatla | 20:3b0b444b4deb | 466 | *o_size-=sizeof(struct NyLPC_TEthernetIIHeader); |
| nyatla | 20:3b0b444b4deb | 467 | //イーサネットバッファのアドレスを計算 |
| nyatla | 20:3b0b444b4deb | 468 | return &(((struct TEthPacket*)(ethbuf+1))->data); |
| nyatla | 0:142ee8b12fef | 469 | } |
| nyatla | 0:142ee8b12fef | 470 | |
| nyatla | 0:142ee8b12fef | 471 | |
| nyatla | 0:142ee8b12fef | 472 | void* NyLPC_cUipService_releaseTxBuf(void* i_buf) |
| nyatla | 0:142ee8b12fef | 473 | { |
| nyatla | 0:142ee8b12fef | 474 | //排他処理をして、メモリを開放する。 |
| nyatla | 0:142ee8b12fef | 475 | NyLPC_TcUipService_t* inst=_NyLPC_TcUipService_inst; |
| nyatla | 0:142ee8b12fef | 476 | NyLPC_cMutex_lock(&(inst->_mutex)); |
| nyatla | 0:142ee8b12fef | 477 | //ペイロードの位置から、メモリブロックを再生。 |
| nyatla | 0:142ee8b12fef | 478 | inst->_ethif->releaseTxBuf(((struct NyLPC_TTxBufferHeader*)(((struct NyLPC_TEthernetIIHeader*)i_buf)-1))-1); |
| nyatla | 0:142ee8b12fef | 479 | NyLPC_cMutex_unlock(&(inst->_mutex)); |
| nyatla | 0:142ee8b12fef | 480 | return NULL; |
| nyatla | 0:142ee8b12fef | 481 | } |
| nyatla | 0:142ee8b12fef | 482 | |
| nyatla | 0:142ee8b12fef | 483 | |
| nyatla | 0:142ee8b12fef | 484 | |
| nyatla | 0:142ee8b12fef | 485 | |
| nyatla | 0:142ee8b12fef | 486 | |
| nyatla | 0:142ee8b12fef | 487 | |
| nyatla | 0:142ee8b12fef | 488 | |
| nyatla | 0:142ee8b12fef | 489 | |
| nyatla | 0:142ee8b12fef | 490 | /********** |
| nyatla | 0:142ee8b12fef | 491 | * イーサネットHWのコントロール関数 |
| nyatla | 0:142ee8b12fef | 492 | */ |
| nyatla | 0:142ee8b12fef | 493 | |
| nyatla | 0:142ee8b12fef | 494 | /** |
| nyatla | 0:142ee8b12fef | 495 | * 新たにメモリを確保して、"IPv4パケットを格納した"イーサフレームを送信します。 |
| nyatla | 0:142ee8b12fef | 496 | * コール前に、必ずロックしてから呼び出してください。 |
| nyatla | 0:142ee8b12fef | 497 | */ |
| nyatla | 0:142ee8b12fef | 498 | static void copyAndSendIPv4Tx(const struct TEthPacket* i_buf) |
| nyatla | 0:142ee8b12fef | 499 | { |
| nyatla | 0:142ee8b12fef | 500 | NyLPC_TcUipService_t* inst=_NyLPC_TcUipService_inst; |
| nyatla | 0:142ee8b12fef | 501 | NyLPC_TUInt16 s; |
| nyatla | 0:142ee8b12fef | 502 | //ACK送信用の自己バッファが空くまで待つ |
| nyatla | 0:142ee8b12fef | 503 | while(inst->stx.h.is_lock){ |
| nyatla | 0:142ee8b12fef | 504 | inst->_ethif->processTx(); |
| nyatla | 0:142ee8b12fef | 505 | } |
| nyatla | 0:142ee8b12fef | 506 | //送信する。 |
| nyatla | 0:142ee8b12fef | 507 | s=NyLPC_htons(i_buf->data.ipv4.len16)+sizeof(struct NyLPC_TEthernetIIHeader); |
| nyatla | 0:142ee8b12fef | 508 | memcpy(inst->stx.buf,i_buf,s); |
| nyatla | 0:142ee8b12fef | 509 | if(!sendIPv4Tx(&(inst->stx.h))){ |
| nyatla | 0:142ee8b12fef | 510 | //失敗した場合はARPリクエストに変換して再送 |
| nyatla | 0:142ee8b12fef | 511 | sendArpReqest(i_buf); |
| nyatla | 0:142ee8b12fef | 512 | } |
| nyatla | 0:142ee8b12fef | 513 | return; |
| nyatla | 0:142ee8b12fef | 514 | } |
| nyatla | 0:142ee8b12fef | 515 | /** |
| nyatla | 0:142ee8b12fef | 516 | * IPv4パケットのpeerIPを問い合わせるARPパケットを送信します。 |
| nyatla | 0:142ee8b12fef | 517 | */ |
| nyatla | 0:142ee8b12fef | 518 | static void sendArpReqest(const struct TEthPacket* i_eth_packet) |
| nyatla | 0:142ee8b12fef | 519 | { |
| nyatla | 0:142ee8b12fef | 520 | NyLPC_TcUipService_t* inst=_NyLPC_TcUipService_inst; |
| nyatla | 0:142ee8b12fef | 521 | NyLPC_TUInt16 tx_len; |
| nyatla | 0:142ee8b12fef | 522 | struct TEthPacket* ethbuf; |
| nyatla | 0:142ee8b12fef | 523 | //ACK送信用の自己バッファが空くまで待つ |
| nyatla | 0:142ee8b12fef | 524 | while(inst->stx.h.is_lock){ |
| nyatla | 0:142ee8b12fef | 525 | inst->_ethif->processTx(); |
| nyatla | 0:142ee8b12fef | 526 | } |
| nyatla | 0:142ee8b12fef | 527 | //ARPパケットを作る。 |
| nyatla | 0:142ee8b12fef | 528 | ethbuf=(struct TEthPacket*)(inst->stx.buf); |
| nyatla | 0:142ee8b12fef | 529 | NyLPC_TArpHeader_setArpRequest(&(ethbuf->data.arp),inst->_ref_config->ip_addr,&(inst->_ref_config->eth_mac),i_eth_packet->data.ipv4.destipaddr); |
| nyatla | 0:142ee8b12fef | 530 | tx_len=NyLPC_TEthernetIIHeader_setArpTx(&(ethbuf->header),&(inst->_ref_config->eth_mac)); |
| nyatla | 0:142ee8b12fef | 531 | //送信 |
| nyatla | 0:142ee8b12fef | 532 | inst->_ethif->sendTxEthFrame(&(inst->stx.h),tx_len); |
| nyatla | 0:142ee8b12fef | 533 | } |
| nyatla | 0:142ee8b12fef | 534 | |
| nyatla | 0:142ee8b12fef | 535 | /** |
| nyatla | 0:142ee8b12fef | 536 | * uipタスクが所有するTXバッファを使用してデータを送信します。 |
| nyatla | 0:142ee8b12fef | 537 | * この関数は、i_bufをコピーします。 |
| nyatla | 0:142ee8b12fef | 538 | * @i_buf |
| nyatla | 0:142ee8b12fef | 539 | * イーサネットフレームを格納したメモリです。 |
| nyatla | 0:142ee8b12fef | 540 | * @i_len |
| nyatla | 0:142ee8b12fef | 541 | * イーサネットペイロードのサイズです。 |
| nyatla | 0:142ee8b12fef | 542 | */ |
| nyatla | 0:142ee8b12fef | 543 | static void sendRawEthFrame(void* i_buf,NyLPC_TUInt16 i_len) |
| nyatla | 0:142ee8b12fef | 544 | { |
| nyatla | 0:142ee8b12fef | 545 | NyLPC_TcUipService_t* inst=_NyLPC_TcUipService_inst; |
| nyatla | 0:142ee8b12fef | 546 | |
| nyatla | 0:142ee8b12fef | 547 | //ACK送信用の自己バッファが空くまで待つ |
| nyatla | 0:142ee8b12fef | 548 | while(inst->stx.h.is_lock){ |
| nyatla | 0:142ee8b12fef | 549 | inst->_ethif->processTx(); |
| nyatla | 0:142ee8b12fef | 550 | } |
| nyatla | 0:142ee8b12fef | 551 | //64バイトを超えるとかありえない。 |
| nyatla | 0:142ee8b12fef | 552 | if(i_len+sizeof(struct NyLPC_TEthernetIIHeader)>NyLPC_TcUipService_SIZE_OF_REPLY_BUF){ |
| nyatla | 0:142ee8b12fef | 553 | return; |
| nyatla | 0:142ee8b12fef | 554 | } |
| nyatla | 0:142ee8b12fef | 555 | //送信する。 |
| nyatla | 0:142ee8b12fef | 556 | memcpy(inst->stx.buf,i_buf,i_len); |
| nyatla | 0:142ee8b12fef | 557 | inst->_ethif->sendTxEthFrame(&(inst->stx.h),i_len); |
| nyatla | 0:142ee8b12fef | 558 | return; |
| nyatla | 0:142ee8b12fef | 559 | } |
| nyatla | 0:142ee8b12fef | 560 | |
| nyatla | 0:142ee8b12fef | 561 | |
| nyatla | 0:142ee8b12fef | 562 | /** |
| nyatla | 0:142ee8b12fef | 563 | * ペイロードをIPパケットとしてネットワークへ送出します。 |
| nyatla | 0:142ee8b12fef | 564 | * コール前に、必ずロックしてから呼び出してください。 |
| nyatla | 0:142ee8b12fef | 565 | * @param i_eth_payload |
| nyatla | 0:142ee8b12fef | 566 | * allocTxBufで確保したメモリを指定してください。 |
| nyatla | 0:142ee8b12fef | 567 | * ペイロードには、TCP/IPパケットを格納します。 |
| nyatla | 0:142ee8b12fef | 568 | */ |
| nyatla | 0:142ee8b12fef | 569 | static NyLPC_TBool sendIPv4Tx(struct NyLPC_TTxBufferHeader* i_eth_buf) |
| nyatla | 0:142ee8b12fef | 570 | { |
| nyatla | 0:142ee8b12fef | 571 | NyLPC_TcUipService_t* inst=_NyLPC_TcUipService_inst; |
| nyatla | 0:142ee8b12fef | 572 | NyLPC_TUInt16 tx_len; |
| nyatla | 0:142ee8b12fef | 573 | struct TEthPacket* ethbuf=(struct TEthPacket*)(i_eth_buf+1); |
| nyatla | 0:142ee8b12fef | 574 | NyLPC_Trace(); |
| nyatla | 0:142ee8b12fef | 575 | //ペイロードのアドレスから、イーサネットフレームバッファのアドレスを復元 |
| nyatla | 0:142ee8b12fef | 576 | //const struct NyLPC_TEthAddr* eth_dest=uip_arp_IPv4toEthAddr(ethbuf->data.ipv4.destipaddr); |
| nyatla | 0:142ee8b12fef | 577 | const struct NyLPC_TEthAddr* eth_dest=NyLPC_cIPv4Arp_IPv4toEthAddr(&inst->_arp,ethbuf->data.ipv4.destipaddr); |
| nyatla | 0:142ee8b12fef | 578 | //IP->MAC変換をテスト。 |
| nyatla | 0:142ee8b12fef | 579 | if(eth_dest==NULL){ |
| nyatla | 0:142ee8b12fef | 580 | //失敗 |
| nyatla | 0:142ee8b12fef | 581 | NyLPC_Trace(); |
| nyatla | 0:142ee8b12fef | 582 | return NyLPC_TBool_FALSE; |
| nyatla | 0:142ee8b12fef | 583 | } |
| nyatla | 0:142ee8b12fef | 584 | NyLPC_Trace(); |
| nyatla | 0:142ee8b12fef | 585 | //変換可能なら、イーサネットヘッダを更新して、送信処理へ。 |
| nyatla | 0:142ee8b12fef | 586 | tx_len=NyLPC_TEthernetIIHeader_setIPv4Tx(&(ethbuf->header),&(inst->_ref_config->eth_mac),eth_dest); |
| nyatla | 0:142ee8b12fef | 587 | inst->_ethif->sendTxEthFrame(i_eth_buf,tx_len); |
| nyatla | 0:142ee8b12fef | 588 | NyLPC_Trace(); |
| nyatla | 0:142ee8b12fef | 589 | return NyLPC_TBool_TRUE; |
| nyatla | 0:142ee8b12fef | 590 | } |
| nyatla | 0:142ee8b12fef | 591 | |
| nyatla | 0:142ee8b12fef | 592 | |
| nyatla | 0:142ee8b12fef | 593 | |
| nyatla | 0:142ee8b12fef | 594 | //static void startEther() |
| nyatla | 0:142ee8b12fef | 595 | //{ |
| nyatla | 0:142ee8b12fef | 596 | // NyLPC_TcUipService_t* inst=_NyLPC_TcUipService_inst; |
| nyatla | 0:142ee8b12fef | 597 | // |
| nyatla | 0:142ee8b12fef | 598 | // //Ethernetの起動待ち |
| nyatla | 0:142ee8b12fef | 599 | // while(lEMACInit(_NyLPC_TcUipService_inst->_emac_semapho,&(inst->_ref_config->eth_mac))!= pdPASS ) |
| nyatla | 0:142ee8b12fef | 600 | // { |
| nyatla | 0:142ee8b12fef | 601 | // vTaskDelay( 100 / portTICK_RATE_MS ); |
| nyatla | 0:142ee8b12fef | 602 | // } |
| nyatla | 0:142ee8b12fef | 603 | // //Ethernetの割込み開始設定 |
| nyatla | 0:142ee8b12fef | 604 | // portENTER_CRITICAL(); |
| nyatla | 0:142ee8b12fef | 605 | // { |
| nyatla | 0:142ee8b12fef | 606 | // LPC_EMAC->IntEnable = ( INT_RX_DONE | INT_TX_DONE ); |
| nyatla | 0:142ee8b12fef | 607 | // /* Set the interrupt priority to the max permissible to cause some |
| nyatla | 0:142ee8b12fef | 608 | // interrupt nesting. */ |
| nyatla | 0:142ee8b12fef | 609 | // NVIC_SetPriority( ENET_IRQn, configEMAC_INTERRUPT_PRIORITY ); |
| nyatla | 0:142ee8b12fef | 610 | // |
| nyatla | 0:142ee8b12fef | 611 | // /* Enable the interrupt. */ |
| nyatla | 0:142ee8b12fef | 612 | // NVIC_EnableIRQ( ENET_IRQn ); |
| nyatla | 0:142ee8b12fef | 613 | // } |
| nyatla | 0:142ee8b12fef | 614 | // portEXIT_CRITICAL(); |
| nyatla | 0:142ee8b12fef | 615 | //} |
| nyatla | 0:142ee8b12fef | 616 | // |
| nyatla | 0:142ee8b12fef | 617 | //static void stopEther() |
| nyatla | 0:142ee8b12fef | 618 | //{ |
| nyatla | 0:142ee8b12fef | 619 | // portENTER_CRITICAL(); |
| nyatla | 0:142ee8b12fef | 620 | // { |
| nyatla | 0:142ee8b12fef | 621 | // LPC_EMAC->IntEnable = (~(INT_RX_DONE|INT_TX_DONE))&LPC_EMAC->IntEnable; |
| nyatla | 0:142ee8b12fef | 622 | // NVIC_DisableIRQ( ENET_IRQn ); |
| nyatla | 0:142ee8b12fef | 623 | // } |
| nyatla | 0:142ee8b12fef | 624 | // portEXIT_CRITICAL(); |
| nyatla | 20:3b0b444b4deb | 625 | //} |
| nyatla | 20:3b0b444b4deb | 626 |
MiMic Webservice library