Ignore:
Timestamp:
May 22, 2019, 10:03:37 PM (5 years ago)
Author:
coas-nagasima
Message:

ビルドが通るよう更新

File:
1 edited

Legend:

Unmodified
Added
Removed
  • azure_iot_hub/trunk/asp3_dcre/tinet/netapp/tcp_echo_srv1_nblk.c

    • Property svn:keywords deleted
    • Property svn:mime-type changed from text/x-csrc to text/x-csrc;charset=UTF-8
    r388 r389  
    55 *                   Tomakomai National College of Technology, JAPAN
    66 *
    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プロジェクトを免責すること.
    3625 *
    37  *  本ソフトウェアは,無保証で提供されているものである.上記著作権è€
    38 ãŠ
    39  *  よびTOPPERSプロジェクトは,本ソフトウェアに関して,その適用可能性も
    40  *  含めて,いかなる保証も行わない.また,本ソフトウェアの利用により直
    41  *  接的または間接的に生じたいかなる損害に関しても,その責任を負わない.
     26 *  本ソフトウェアは,無保証で提供されているものである.上記著作権者お
     27 *  よびTOPPERSプロジェクトは,本ソフトウェアに関して,その適用可能性も
     28 *  含めて,いかなる保証も行わない.また,本ソフトウェアの利用により直
     29 *  接的または間接的に生じたいかなる損害に関しても,その責任を負わない.
    4230 *
    4331 *  @(#) $Id$
     
    4533
    4634/*
    47  *  TCP ECHO サーバ #1
     35 *  TCP ECHO サーバ #1
    4836 *
    49  *    ・送受信タスク同一型
    50  *    ・ノンブロッキングコール
    51  *    ・省コピー API
    52  *    ・IPv4/IPv6
    53  *    ・緊急データの受信
     37 *    ・送受信タスク同一型
     38 *    ・ノンブロッキングコール
     39 *    ・省コピー API
     40 *    IPv4/IPv6
     41 *    ・緊急データの受信
    5442 */
    5543
     
    8573
    8674/*
    87  *  表示
     75 *  表示
    8876 */
    8977
     
    9179
    9280/*
    93  *  コネクション切断方法の指定
     81 *  コネクション切断方法の指定
    9482 */
    9583
     
    9785
    9886/*
    99  *  タイムアウト
     87 *  タイムアウト
    10088 */
    10189
    10290#ifdef TOPPERS_S810_CLG3_85
    10391
    104 #define CLS_TMO         TMO_FEVR                /* Close Wait は標準で 60秒 */
     92#define CLS_TMO         TMO_FEVR                /* Close Wait は標準で 60秒 */
    10593//#define RCV_TMO               TMO_FEVR
    10694#define RCV_TMO         (30*SYSTIM_HZ)
     
    11098#else   /* of #ifdef TOPPERS_S810_CLG3_85 */
    11199
    112 //#define CLS_TMO               TMO_FEVR        /* Close Wait は標準で 60秒 */
     100//#define CLS_TMO               TMO_FEVR        /* Close Wait は標準で 60秒 */
    113101#define CLS_TMO         (70*SYSTIM_HZ+(netapp_rand()%SYSTIM_HZ)*10)
    114102//#define RCV_TMO               TMO_FEVR
     
    122110
    123111/*
    124  *  変数
     112 *  変数
    125113 */
    126114
     
    196184
    197185/*
    198  *  find_srv_info -- 接続相手のæƒ
    199 å ±æ§‹é€ ä½“を探索する。
     186 *  find_srv_info -- 接続相手の情報構造体を探索する。
    200187 */
    201188
     
    212199
    213200/*
    214  *  ノンブロッキングコールのコールバック関数
     201 *  ノンブロッキングコールのコールバック関数
    215202 */
    216203
     
    290277
    291278/*
    292  *  tcp_passive_open -- 受動オープンを実行する。
     279 *  tcp_passive_open -- 受動オープンを実行する。
    293280 *
    294281 *    USE_TCP_NON_BLOCKING      ON
     
    304291
    305292        if (apip == API_PROTO_IPV6) {
    306                 /* 受付口は IPv6 */
     293                /* 受付口は IPv6 */
    307294                if ((error = tcp6_acp_cep(info->cepid, info->repid, &info->dst, TMO_NBLK)) != E_WBLK)
    308295                        return error;
    309296
    310                 /* 相手から接続されるまでå¾
    311 ã¤ã€‚*/
     297                /* 相手から接続されるまで待つ。*/
    312298                syscall(wai_sem(info->semid));
    313299
     
    322308                }
    323309        else {
    324                 /* 受付口は IPv4 */
     310                /* 受付口は IPv4 */
    325311                if ((error = tcp_acp_cep(info->cepid, info->repid, &dst4, TMO_NBLK)) != E_WBLK)
    326312                        return error;
    327313
    328                 /* 相手から接続されるまでå¾
    329 ã¤ã€‚*/
     314                /* 相手から接続されるまで待つ。*/
    330315                syscall(wai_sem(info->semid));
    331316
     
    356341                return error;
    357342
    358         /* 相手から接続されるまでå¾
    359 ã¤ã€‚*/
     343        /* 相手から接続されるまで待つ。*/
    360344        syscall(wai_sem(info->semid));
    361345
     
    376360
    377361/*
    378  *  tcp_echo_srv -- TCP エコーサーバ
     362 *  tcp_echo_srv -- TCP エコーサーバ
    379363 *
    380364 *    USE_TCP_NON_BLOCKING      ON
     
    431415                        }
    432416
    433                 /* 受信するまでå¾
    434 ã¤ã€‚*/
     417                /* 受信するまで待つ。*/
    435418                syscall(wai_sem(tcp_echo_srv_info[six].semid));
    436419
    437                 if (tcp_echo_srv_info[six].rlen < 0) {  /* エラー */
     420                if (tcp_echo_srv_info[six].rlen < 0) {  /* エラー */
    438421                        syslog(LOG_NOTICE, "[TES%c:%02u RCV] error: %s",
    439422                                           apip, tcp_echo_srv_info[six].cepid, itron_strerror(tcp_echo_srv_info[six].rlen));
    440423                        break;
    441424                        }
    442                 else if (tcp_echo_srv_info[six].rlen == 0)      /* 受信終了 */
     425                else if (tcp_echo_srv_info[six].rlen == 0)      /* 受信終了 */
    443426                        break;
    444427
    445428                rblen = tcp_echo_srv_info[six].rlen;
    446429
    447                 /* バッファの残りにより、受信長を調整する。*/
     430                /* バッファの残りにより、受信長を調整する。*/
    448431                if (rblen > BUF_SIZE - rlen)
    449432                        rblen = BUF_SIZE - rlen;
     
    478461                                }
    479462
    480                         /* 送信バッファの獲得が完了するまでå¾
    481 ã¤ã€‚*/
     463                        /* 送信バッファの獲得が完了するまで待つ。*/
    482464                        syscall(wai_sem(tcp_echo_srv_info[six].semid));
    483465
     
    519501                                   apip, tcp_echo_srv_info[six].cepid, itron_strerror(error));
    520502
    521         /* 開放が完了するまでå¾
    522 ã¤ã€‚*/
     503        /* 開放が完了するまで待つ。*/
    523504        syscall(wai_sem(tcp_echo_srv_info[six].semid));
    524505
     
    533514
    534515/*
    535  *  tcp_echo_srv -- TCP エコーサーバ
     516 *  tcp_echo_srv -- TCP エコーサーバ
    536517 *
    537518 *    USE_TCP_NON_BLOCKING      ON
     
    574555                        }
    575556
    576                 /* 受信完了までå¾
    577 ã¤ã€‚*/
     557                /* 受信完了まで待つ。*/
    578558                syscall(wai_sem(tcp_echo_srv_info[six].semid));
    579559
     
    606586                                }
    607587
    608                         /* 送信完了までå¾
    609 ã¤ã€‚*/
     588                        /* 送信完了まで待つ。*/
    610589                        syscall(wai_sem(tcp_echo_srv_info[six].semid));
    611590
     
    639618                                   apip, tcp_echo_srv_info[six].cepid, itron_strerror(error));
    640619
    641         /* 開放が完了するまでå¾
    642 ã¤ã€‚*/
     620        /* 開放が完了するまで待つ。*/
    643621        syscall(wai_sem(tcp_echo_srv_info[six].semid));
    644622
Note: See TracChangeset for help on using the changeset viewer.