![(please configure the [header_logo] section in trac.ini)](/trac_user/contrib/chrome/site/your_project_logo.png){kind=logo}
- Timestamp:
- Aug 23, 2017, 9:27:43 AM (7 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
EcnlProtoTool/trunk/asp3_dcre/tinet/netapp/tcp_echo_srv2.c
- Property svn:keywords deleted
-
Property svn:mime-type
changed from
text/x-csrctotext/x-csrc;charset=UTF-8
r270 r321 5 5 * Tomakomai National College of Technology, JAPAN 6 6 * 7 * ä¸è¨èä½æ¨©è 8 ã¯ï¼ä»¥ä¸ã® (1)ï½(4) ã®æ¡ä»¶ãï¼Free Software Foundation 9 * ã«ãã£ã¦å 10 ¬è¡¨ããã¦ãã GNU General Public License ã® Version 2 ã«è¨ 11 * è¿°ããã¦ããæ¡ä»¶ãæºããå ´åã«éãï¼æ¬ã½ããã¦ã§ã¢ï¼æ¬ã½ããã¦ã§ã¢ 12 * ãæ¹å¤ãããã®ãå«ãï¼ä»¥ä¸åãï¼ã使ç¨ã»è¤è£½ã»æ¹å¤ã»åé 13 å¸ï¼ä»¥ä¸ï¼ 14 * å©ç¨ã¨å¼ã¶ï¼ãããã¨ãç¡åã§è¨±è«¾ããï¼ 15 * (1) æ¬ã½ããã¦ã§ã¢ãã½ã¼ã¹ã³ã¼ãã®å½¢ã§å©ç¨ããå ´åã«ã¯ï¼ä¸è¨ã®èä½ 16 * 権表示ï¼ãã®å©ç¨æ¡ä»¶ããã³ä¸è¨ã®ç¡ä¿è¨¼è¦å®ãï¼ãã®ã¾ã¾ã®å½¢ã§ã½ã¼ 17 * ã¹ã³ã¼ãä¸ã«å«ã¾ãã¦ãããã¨ï¼ 18 * (2) æ¬ã½ããã¦ã§ã¢ãï¼ã©ã¤ãã©ãªå½¢å¼ãªã©ï¼ä»ã®ã½ããã¦ã§ã¢éçºã«ä½¿ 19 * ç¨ã§ããå½¢ã§åé 20 å¸ããå ´åã«ã¯ï¼åé 21 å¸ã«ä¼´ãããã¥ã¡ã³ãï¼å©ç¨ 22 * è 23 ããã¥ã¢ã«ãªã©ï¼ã«ï¼ä¸è¨ã®èä½æ¨©è¡¨ç¤ºï¼ãã®å©ç¨æ¡ä»¶ããã³ä¸è¨ 24 * ã®ç¡ä¿è¨¼è¦å®ãæ²è¼ãããã¨ï¼ 25 * (3) æ¬ã½ããã¦ã§ã¢ãï¼æ©å¨ã«çµã¿è¾¼ããªã©ï¼ä»ã®ã½ããã¦ã§ã¢éçºã«ä½¿ 26 * ç¨ã§ããªãå½¢ã§åé 27 å¸ããå ´åã«ã¯ï¼æ¬¡ã®æ¡ä»¶ãæºãããã¨ï¼ 28 * (a) åé 29 å¸ã«ä¼´ãããã¥ã¡ã³ãï¼å©ç¨è 30 ããã¥ã¢ã«ãªã©ï¼ã«ï¼ä¸è¨ã®è 31 * ä½æ¨©è¡¨ç¤ºï¼ãã®å©ç¨æ¡ä»¶ããã³ä¸è¨ã®ç¡ä¿è¨¼è¦å®ãæ²è¼ãããã¨ï¼ 32 * (4) æ¬ã½ããã¦ã§ã¢ã®å©ç¨ã«ããç´æ¥çã¾ãã¯éæ¥çã«çãããããªãæ 33 * 害ãããï¼ä¸è¨èä½æ¨©è 34 ããã³TOPPERSããã¸ã§ã¯ããå 35 責ãããã¨ï¼ 7 * 上記著作権者は，以下の (1)～(4) の条件か，Free Software Foundation 8 * によって公表されている GNU General Public License の Version 2 に記 9 * 述されている条件を満たす場合に限り，本ソフトウェア（本ソフトウェア 10 * を改変したものを含む．以下同じ）を使用・複製・改変・再配布（以下， 11 * 利用と呼ぶ）することを無償で許諾する． 12 * (1) 本ソフトウェアをソースコードの形で利用する場合には，上記の著作 13 * 権表示，この利用条件および下記の無保証規定が，そのままの形でソー 14 * スコード中に含まれていること． 15 * (2) 本ソフトウェアを，ライブラリ形式など，他のソフトウェア開発に使 16 * 用できる形で再配布する場合には，再配布に伴うドキュメント（利用 17 * 者マニュアルなど）に，上記の著作権表示，この利用条件および下記 18 * の無保証規定を掲載すること． 19 * (3) 本ソフトウェアを，機器に組み込むなど，他のソフトウェア開発に使 20 * 用できない形で再配布する場合には，次の条件を満たすこと． 21 * (a) 再配布に伴うドキュメント（利用者マニュアルなど）に，上記の著 22 * 作権表示，この利用条件および下記の無保証規定を掲載すること． 23 * (4) 本ソフトウェアの利用により直接的または間接的に生じるいかなる損 24 * 害からも，上記著作権者およびTOPPERSプロジェクトを免責すること． 36 25 * 37 * æ¬ã½ããã¦ã§ã¢ã¯ï¼ç¡ä¿è¨¼ã§æä¾ããã¦ãããã®ã§ããï¼ä¸è¨èä½æ¨©è 38 ã 39 * ãã³TOPPERSããã¸ã§ã¯ãã¯ï¼æ¬ã½ããã¦ã§ã¢ã«é¢ãã¦ï¼ãã®é©ç¨å¯è½æ§ã 40 * å«ãã¦ï¼ãããªãä¿è¨¼ãè¡ããªãï¼ã¾ãï¼æ¬ã½ããã¦ã§ã¢ã®å©ç¨ã«ããç´ 41 * æ¥çã¾ãã¯éæ¥çã«çãããããªãæ害ã«é¢ãã¦ãï¼ãã®è²¬ä»»ãè² ããªãï¼ 26 * 本ソフトウェアは，無保証で提供されているものである．上記著作権者お 27 * よびTOPPERSプロジェクトは，本ソフトウェアに関して，その適用可能性も 28 * 含めて，いかなる保証も行わない．また，本ソフトウェアの利用により直 29 * 接的または間接的に生じたいかなる損害に関しても，その責任を負わない． 42 30 * 43 31 * @(#) $Id$ … … 45 33 46 34 /* 47 * TCP ECHO ãµã¼ã#235 * TCP ECHO サーバ #2 48 36 * 49 * ã»éåä¿¡ã¿ã¹ã¯åé¢å50 * ã»ãã³ããããã³ã°ã³ã¼ã«51 * ã»IPv4/IPv637 * ・送受信タスク分離型 38 * ・ノンブロッキングコール 39 * ・IPv4/IPv6 52 40 */ 53 41 … … 92 80 93 81 /* 94 * 表示82 * 表示 95 83 */ 96 84 … … 98 86 99 87 /* 100 * ã³ãã¯ã·ã§ã³åææ¹æ³ã®æå®88 * コネクション切断方法の指定 101 89 */ 102 90 … … 104 92 105 93 /* 106 * å 107 ¨åå¤æ° 108 */ 109 110 /* TCP éåä¿¡ã¦ã£ã³ããããã¡ */ 94 * 全域変数 95 */ 96 97 /* TCP 送受信ウィンドバッファ */ 111 98 112 99 #ifndef TCP_CFG_SWBUF_CSAVE … … 119 106 120 107 /* 121 * å¤æ°122 */ 123 124 /* 125 * 注æ:108 * 変数 109 */ 110 111 /* 112 * 注意: 126 113 * 127 * BUF_SIZE 㯠TCP ã®128 * éä¿¡ã¦ã¤ã³ãã¦ãããã¡ãµã¤ãº + åä¿¡ã¦ã¤ã³ãã¦ãããã¡ãµã¤ãºã®129 * 3/2 å以ä¸ã®å¤§ããããªããã°ããããããã¯ããå¯è½æ§ãããã114 * BUF_SIZE は TCP の 115 * 送信ウインドウバッファサイズ + 受信ウインドウバッファサイズの 116 * 3/2 倍以上の大きさがなければ、デッドロックする可能性がある。 130 117 */ 131 118 … … 133 120 TCP_ECHO_SRV_RWBUF_SIZE) * 3 / 2) 134 121 135 static char buffer[BUF_SIZE]; /* ãããã¡ */ 136 137 static T_IPEP dst; /* æ¥ç¶ç¸æ */ 138 static bool_t ena_rcv; /* åä¿¡å¯è½ãã©ã° */ 139 static char *rptr = buffer; /* åä¿¡ãã¤ã³ã¿ */ 140 static char *sptr = buffer; /* éä¿¡ãã¤ã³ã¿ */ 141 static uint32_t rcv_total; /* åä¿¡æåæ° */ 142 static uint32_t snd_total; /* éä¿¡æåæ° */ 143 static uint16_t chars; /* ãããã¡å 144 ã®æåæ° */ 145 static uint16_t rcv_count; /* åä¿¡åæ° */ 146 static uint16_t snd_count; /* éä¿¡åæ° */ 122 static char buffer[BUF_SIZE]; /* バッファ */ 123 124 static T_IPEP dst; /* 接続相手 */ 125 static bool_t ena_rcv; /* 受信可能フラグ */ 126 static char *rptr = buffer; /* 受信ポインタ */ 127 static char *sptr = buffer; /* 送信ポインタ */ 128 static uint32_t rcv_total; /* 受信文字数 */ 129 static uint32_t snd_total; /* 送信文字数 */ 130 static uint16_t chars; /* バッファ内の文字数 */ 131 static uint16_t rcv_count; /* 受信回数 */ 132 static uint16_t snd_count; /* 送信回数 */ 147 133 148 134 #ifdef USE_TCP_NON_BLOCKING 149 135 150 static ER rcv_error = E_OK; /* åä¿¡ããã³ããããã³ã°ã³ã¼ã«ã¨ã©ã¼*/151 static ER snd_error = 1; /* éä¿¡ããã³ããããã³ã°ã³ã¼ã«ã¨ã©ã¼*/152 153 /* 154 * ãã³ããããã³ã°ã³ã¼ã«ã®ã³ã¼ã«ããã¯é¢æ°136 static ER rcv_error = E_OK; /* 受信、ノンブロッキングコールエラー */ 137 static ER snd_error = 1; /* 送信、ノンブロッキングコールエラー */ 138 139 /* 140 * ノンブロッキングコールのコールバック関数 155 141 */ 156 142 … … 198 184 syscall(wai_sem(SEM_TCP_ECHO_SRV_LOCK)); 199 185 200 /* éä¿¡ãã¤ã³ã¿ãé²ããã*/186 /* 送信ポインタを進める。*/ 201 187 if (sptr - buffer + slen >= sizeof(buffer)) 202 188 sptr -= sizeof(buffer) - slen; … … 204 190 sptr += slen; 205 191 206 /* ãããã¡å 207 ã®æåæ°ãæ¸ããã*/ 192 /* バッファ内の文字数を減らす。*/ 208 193 last = chars; 209 194 chars -= slen; 210 195 211 /* ãããã¡å 212 ã«æåãããã°ãéä¿¡ã¿ã¹ã¯ãèµ·åºããã*/ 196 /* バッファ内に文字があれば、送信タスクを起床する。*/ 213 197 if (chars > 0 || (!ena_rcv && chars == 0)) 214 198 sig_sem(SEM_TCP_ECHO_SRV_SND_READY); 215 199 216 /* åä¿¡å¯è½ã§ããããã¡å 217 ã«ç©ºããã§ããã°ãåä¿¡ã¿ã¹ã¯ãèµ·åºããã*/ 200 /* 受信可能で、バッファ内に空きができれば、受信タスクを起床する。*/ 218 201 if (ena_rcv && last == sizeof(buffer) && sizeof(buffer) - chars > 0) 219 202 syscall(sig_sem(SEM_TCP_ECHO_SRV_RCV_READY)); … … 241 224 syscall(wai_sem(SEM_TCP_ECHO_SRV_LOCK)); 242 225 243 /* åä¿¡ãã¤ã³ã¿ãé²ããã*/226 /* 受信ポインタを進める。*/ 244 227 if (rptr - buffer + rlen >= sizeof(buffer)) 245 228 rptr -= sizeof(buffer) - rlen; … … 247 230 rptr += rlen; 248 231 249 /* ãããã¡å 250 ã®æåæ°ãå¢ããã*/ 232 /* バッファ内の文字数を増やす。*/ 251 233 last = chars; 252 234 chars += rlen; 253 235 254 /* ãããã¡å 255 ã«æåãå 256 ¥ãã°ãéä¿¡ã¿ã¹ã¯ãèµ·åºããã*/ 236 /* バッファ内に文字が入れば、送信タスクを起床する。*/ 257 237 if (last == 0 && chars > 0) 258 238 sig_sem(SEM_TCP_ECHO_SRV_SND_READY); 259 239 260 /* ãããã¡å 261 ã«ç©ºããããã°ãåä¿¡ã¿ã¹ã¯ãèµ·åºããã*/ 240 /* バッファ内に空きがあれば、受信タスクを起床する。*/ 262 241 if (sizeof(buffer) - chars > 0) 263 242 sig_sem(SEM_TCP_ECHO_SRV_RCV_READY); … … 294 273 295 274 /* 296 * TCP ECHO ãµã¼ãåä¿¡ã«ã¼ãã³ (ãã³ããããã³ã°ã³ã¼ã«ä½¿ç¨)275 * TCP ECHO サーバ受信ルーチン (ノンブロッキングコール使用) 297 276 */ 298 277 … … 313 292 } 314 293 315 /* ã³ãã¯ã·ã§ã³éè¨å®äºã¾ã§å¾ 316 ã¤ã*/ 294 /* コネクション開設完了まで待つ。*/ 317 295 syscall(wai_sem(SEM_TCP_ECHO_SRV_RCV_READY)); 318 296 319 /* å¾ 320 ã£ã¦ããéã«ã¨ã©ã¼ã«ãªã£ãããã³ãã¯ã·ã§ã³ã®éè¨å¾ 321 ã¡ã«æ»ãã*/ 297 /* 待っている間にエラーになったら、コネクションの開設待ちに戻る。*/ 322 298 if (rcv_error != E_OK) 323 299 return rcv_error; … … 332 308 while (true) { 333 309 334 /* åä¿¡ãµã¤ãºãè¨ç®ããã*/310 /* 受信サイズを計算する。*/ 335 311 syscall(wai_sem(SEM_TCP_ECHO_SRV_LOCK)); 336 312 if (sptr > rptr) … … 340 316 syscall(sig_sem(SEM_TCP_ECHO_SRV_LOCK)); 341 317 342 /* åä¿¡ããã*/318 /* 受信する。*/ 343 319 if ((error = tcp_rcv_dat(cepid, rptr, blen, TMO_NBLK)) != E_WBLK) { 344 320 syslog(LOG_NOTICE, "[TES:%02d RCV] recv error = %s", cepid, itron_strerror(error)); … … 346 322 } 347 323 348 /* åä¿¡ãããã¡ã«ç©ºãã§ããã¾ã§å¾ 349 ã¤ã*/ 324 /* 受信バッファに空ができるまで待つ。*/ 350 325 syscall(wai_sem(SEM_TCP_ECHO_SRV_RCV_READY)); 351 326 352 /* å¾ 353 ã£ã¦ããéã«ãåä¿¡æåæ°ã 0 ã«ãªãããã¨ã©ã¼ã«ãªã£ããçµäºããã*/ 327 /* 待っている間に、受信文字数が 0 になるか、エラーになったら終了する。*/ 354 328 if (rcv_error <= 0) 355 329 break; … … 357 331 } 358 332 359 /* åä¿¡å®äº*/333 /* 受信完了 */ 360 334 ena_rcv = false; 361 335 362 /* åä¿¡ãããã¡ã«æåãå 363 ¥ãã®ãå¾ 364 ã£ã¦ããéä¿¡ã¿ã¹ã¯ãèµ·åºããã*/ 336 /* 受信バッファに文字が入るのを待っている送信タスクを起床する。*/ 365 337 if (chars == 0) 366 338 sig_sem(SEM_TCP_ECHO_SRV_SND_READY); 367 339 368 /* ã³ãã¯ã·ã§ã³åæå®äºã¾ã§å¾ 369 ã¤ã*/ 340 /* コネクション切断完了まで待つ。*/ 370 341 syscall(wai_sem(SEM_TCP_ECHO_SRV_CLS_READY)); 371 342 … … 374 345 375 346 /* 376 * TCP ECHO ãµã¼ãéä¿¡ã¿ã¹ã¯ (ãã³ããããã³ã°ã³ã¼ã«ä½¿ç¨)347 * TCP ECHO サーバ送信タスク (ノンブロッキングコール使用) 377 348 */ 378 349 … … 395 366 while (true) { 396 367 397 /* ãããã¡ã«æåãå 398 ¥ãã¾ã§å¾ 399 ã¤ã*/ 368 /* バッファに文字が入るまで待つ。*/ 400 369 syscall(wai_sem(SEM_TCP_ECHO_SRV_SND_READY)); 401 370 402 /* å¾ 403 ã£ã¦ããéã«ã¨ã©ã¼ã«ãªã£ããçµäºããã*/ 371 /* 待っている間にエラーになったら終了する。*/ 404 372 if (snd_error <= 0) 405 373 break; 406 374 407 /* åä¿¡å®äºã§ããããã¡ã«æåããªããã°çµäºããã*/375 /* 受信完了で、バッファに文字がなければ終了する。*/ 408 376 if (!ena_rcv && chars == 0) 409 377 break; 410 378 411 /* éä¿¡ãµã¤ãºãè¨ç®ããã*/379 /* 送信サイズを計算する。*/ 412 380 syscall(wai_sem(SEM_TCP_ECHO_SRV_LOCK)); 413 381 if (rptr > sptr) … … 417 385 syscall(sig_sem(SEM_TCP_ECHO_SRV_LOCK)); 418 386 419 /* éä¿¡ããã*/387 /* 送信する。*/ 420 388 if ((error = tcp_snd_dat(cepid, sptr, blen, TMO_NBLK)) != E_WBLK) { 421 389 syslog(LOG_NOTICE, "[TES:%02d SND] send error = %s", cepid, itron_strerror(error)); … … 424 392 } 425 393 426 /* åä¿¡ãããã¡ã«ç©ºãã§ãããå¾ 427 ã£ã¦ããåä¿¡ã¿ã¹ã¯ãèµ·åºããã*/ 394 /* 受信バッファに空ができるを待っている受信タスクを起床する。*/ 428 395 if (chars == sizeof(buffer)) 429 396 sig_sem(SEM_TCP_ECHO_SRV_SND_READY); … … 446 413 447 414 /* 448 * TCP ECHO ãµã¼ãåä¿¡ã«ã¼ãã³415 * TCP ECHO サーバ受信ルーチン 449 416 */ 450 417 … … 483 450 while (true) { 484 451 485 /* åä¿¡ãµã¤ãºãè¨ç®ããã*/452 /* 受信サイズを計算する。*/ 486 453 syscall(wai_sem(SEM_TCP_ECHO_SRV_LOCK)); 487 454 if (sptr > rptr) … … 491 458 syscall(sig_sem(SEM_TCP_ECHO_SRV_LOCK)); 492 459 493 /* åä¿¡ããã*/460 /* 受信する。*/ 494 461 if ((rlen = tcp_rcv_dat(cepid, rptr, blen, TMO_FEVR)) <= 0) { 495 462 if (rlen < 0) … … 509 476 syscall(wai_sem(SEM_TCP_ECHO_SRV_LOCK)); 510 477 511 /* åä¿¡ãã¤ã³ã¿ãé²ããã*/478 /* 受信ポインタを進める。*/ 512 479 if (rptr - buffer + rlen >= sizeof(buffer)) 513 480 rptr -= sizeof(buffer) - rlen; … … 515 482 rptr += rlen; 516 483 517 /* ãããã¡å 518 ã®æåæ°ãå¢ããã*/ 484 /* バッファ内の文字数を増やす。*/ 519 485 last = chars; 520 486 chars += (uint16_t)rlen; 521 487 522 /* ãããã¡å 523 ã«æåãå 524 ¥ãã°ãéä¿¡ã¿ã¹ã¯ãèµ·åºããã*/ 488 /* バッファ内に文字が入れば、送信タスクを起床する。*/ 525 489 if (last == 0 && chars > 0) 526 490 sig_sem(SEM_TCP_ECHO_SRV_SND_READY); 527 491 528 /* ãããã¡å 529 ã«ç©ºããããã°ãåä¿¡ã¿ã¹ã¯ãèµ·åºããã*/ 492 /* バッファ内に空きがあれば、受信タスクを起床する。*/ 530 493 if (sizeof(buffer) - chars > 0) 531 494 sig_sem(SEM_TCP_ECHO_SRV_RCV_READY); … … 533 496 syscall(sig_sem(SEM_TCP_ECHO_SRV_LOCK)); 534 497 535 /* ãããã¡ã«ç©ºããã§ããã¾ã§å¾ 536 ã¤ã*/ 498 /* バッファに空きができるまで待つ。*/ 537 499 syscall(wai_sem(SEM_TCP_ECHO_SRV_RCV_READY)); 538 500 } 539 501 540 /* åä¿¡å®äº*/502 /* 受信完了 */ 541 503 ena_rcv = false; 542 504 543 /* åä¿¡ãããã¡ã«æåãå 544 ¥ãã®ãå¾ 545 ã£ã¦ããéä¿¡ã¿ã¹ã¯ãèµ·åºããã*/ 505 /* 受信バッファに文字が入るのを待っている送信タスクを起床する。*/ 546 506 if (chars == 0) 547 507 sig_sem(SEM_TCP_ECHO_SRV_SND_READY); 548 508 549 /* ã³ãã¯ã·ã§ã³ã®åæãå®äºããã¾ã§å¾ 550 ã¤ã*/ 509 /* コネクションの切断が完了するまで待つ。*/ 551 510 syscall(wai_sem(SEM_TCP_ECHO_SRV_CLS_READY)); 552 511 … … 555 514 556 515 /* 557 * TCP ECHO ãµã¼ãéä¿¡ã¿ã¹ã¯516 * TCP ECHO サーバ送信タスク 558 517 */ 559 518 … … 579 538 while (true) { 580 539 581 /* ãããã¡ã«æåãå 582 ¥ãã¾ã§å¾ 583 ã¤ã*/ 540 /* バッファに文字が入るまで待つ。*/ 584 541 syscall(wai_sem(SEM_TCP_ECHO_SRV_SND_READY)); 585 542 586 /* åä¿¡å®äºã§ããããã¡ã«æåããªããã°çµäºããã*/543 /* 受信完了で、バッファに文字がなければ終了する。*/ 587 544 if (!ena_rcv && chars == 0) 588 545 break; 589 546 590 /* éä¿¡ãµã¤ãºãè¨ç®ããã*/547 /* 送信サイズを計算する。*/ 591 548 syscall(wai_sem(SEM_TCP_ECHO_SRV_LOCK)); 592 549 if (rptr > sptr) … … 612 569 syscall(wai_sem(SEM_TCP_ECHO_SRV_LOCK)); 613 570 614 /* éä¿¡ãã¤ã³ã¿ãé²ããã*/571 /* 送信ポインタを進める。*/ 615 572 if (sptr - buffer + slen >= sizeof(buffer)) 616 573 sptr -= sizeof(buffer) - slen; … … 618 575 sptr += slen; 619 576 620 /* ãããã¡å 621 ã®æåæ°ãæ¸ããã*/ 577 /* バッファ内の文字数を減らす。*/ 622 578 last = chars; 623 579 chars -= (uint16_t)slen; 624 580 625 /* åä¿¡å®äºã§ããããã¡ã«æåããªããã°çµäºããã*/581 /* 受信完了で、バッファに文字がなければ終了する。*/ 626 582 if (!ena_rcv && chars == 0) { 627 583 syscall(sig_sem(SEM_TCP_ECHO_SRV_LOCK)); … … 629 585 } 630 586 631 /* ãããã¡å 632 ã«æåãããã°ãéä¿¡ã¿ã¹ã¯ãèµ·åºããã*/ 587 /* バッファ内に文字があれば、送信タスクを起床する。*/ 633 588 if (chars > 0) 634 589 sig_sem(SEM_TCP_ECHO_SRV_SND_READY); 635 590 636 /* åä¿¡å¯è½ã§ããããã¡å 637 ã«ç©ºããã§ããã°ãåä¿¡ã¿ã¹ã¯ãèµ·åºããã*/ 591 /* 受信可能で、バッファ内に空きができれば、受信タスクを起床する。*/ 638 592 if (ena_rcv && last == sizeof(buffer) && sizeof(buffer) - chars > 0) 639 593 sig_sem(SEM_TCP_ECHO_SRV_RCV_READY); … … 642 596 } 643 597 644 /* åä¿¡ãããã¡ã«ç©ºãã§ãããå¾ 645 ã£ã¦ããåä¿¡ã¿ã¹ã¯ãèµ·åºããã*/ 598 /* 受信バッファに空ができるを待っている受信タスクを起床する。*/ 646 599 if (chars == sizeof(buffer)) 647 600 sig_sem(SEM_TCP_ECHO_SRV_SND_READY); … … 671 624 672 625 /* 673 * get_tcp_rep -- TCP åä»å£ãç²å¾ããã626 * get_tcp_rep -- TCP 受付口を獲得する。 674 627 */ 675 628 … … 697 650 698 651 /* 699 * get_tcp_cep -- TCP é信端ç¹ãç²å¾ããã652 * get_tcp_cep -- TCP 通信端点を獲得する。 700 653 */ 701 654 … … 732 685 733 686 /* 734 * TCP ECHO ãµã¼ãåä¿¡ã¿ã¹ã¯687 * TCP ECHO サーバ受信タスク 735 688 */ 736 689
Note:
See TracChangeset
for help on using the changeset viewer.
