Ignore:
Timestamp:
Jan 21, 2018, 12:10:09 AM (6 years ago)
Author:
coas-nagasima
Message:

prototoolに関連するプロジェクトをnewlibからmuslを使うよう変更・更新
ntshellをnewlibの下位の実装から、muslのsyscallの実装に変更・更新
以下のOSSをアップデート
・mruby-1.3.0
・musl-1.1.18
・onigmo-6.1.3
・tcc-0.9.27
以下のOSSを追加
・openssl-1.1.0e
・curl-7.57.0
・zlib-1.2.11
以下のmrbgemsを追加
・iij/mruby-digest
・iij/mruby-env
・iij/mruby-errno
・iij/mruby-iijson
・iij/mruby-ipaddr
・iij/mruby-mock
・iij/mruby-require
・iij/mruby-tls-openssl

File:
1 edited

Legend:

Unmodified
Added
Removed

  • EcnlProtoTool/trunk/asp3_dcre/tinet/netapp/tcp_discard_srv.c

    r321 r331  
    22 *  TINET (TCP/IP Protocol Stack)
    33 *
    4  *  Copyright (C) 2001-2009 by Dep. of Computer Science and Engineering
     4 *  Copyright (C) 2001-2017 by Dep. of Computer Science and Engineering
    55 *                   Tomakomai National College of Technology, JAPAN
    66 *
    … …  
    5858#endif  /* of #ifdef TARGET_KERNEL_JSP */
    5959
    60 #include <tinet_defs.h>
    61 #include <tinet_config.h>
    62 
    63 #include <net/if.h>
    64 #include <net/if_ppp.h>
    65 #include <net/if_loop.h>
    66 #include <net/ethernet.h>
    67 #include <net/net.h>
    68 #include <net/net_timer.h>
    69 
    7060#include <netinet/in.h>
    7161#include <netinet/in_itron.h>
    72 #include <netinet/ip.h>
    73 #include <netinet/ip6.h>
    74 #include <netinet/tcp.h>
    7562
    7663#include <netapp/netapp.h>
    7764#include <netapp/netapp_var.h>
    78 #include <netapp/discard.h>
     65#include <netapp/tcp_discard_srv.h>
    7966
    8067#ifdef USE_TCP_DISCARD_SRV
    … …  
    121108
    122109        if ((error = TCP_ACP_CEP(cepid, repid, &dst, TMO_FEVR)) != E_OK) {
    123                 syslog(LOG_NOTICE, "[TDS:%02d ACP] accept error: %s", cepid, itron_strerror(error));
     110                syslog(LOG_NOTICE, "[TDSn:%02u ACP] accept error: %s", cepid, itron_strerror(error));
    124111                return error;
    125112                }
    126113
    127114#ifdef USE_TCP_EXTENTIONS
    128         if ((error = free_tcp_rep(repid, true)) != E_OK) {
    129                 syslog(LOG_NOTICE, "[TDS:%02d DEL] REP delete error: %s", cepid, itron_strerror(error));
     115        if ((error = FREE_TCP_REP(repid, true)) != E_OK) {
     116                syslog(LOG_NOTICE, "[TDSn:%02u DEL] REP delete error: %s", cepid, itron_strerror(error));
    130117                return error;
    131118                }
    … …  
    134121        count = total = 0;
    135122        get_tim(&time);
    136         syslog(LOG_NOTICE, "[TDS:%02d RCV] connected:  %6ld, from: %s.%d",
     123        syslog(LOG_NOTICE, "[TDSn:%02u RCV] conct: %7lu, from: %s.%d",
    137124                           cepid, time / SYSTIM_HZ, IP2STR(NULL, &dst.ipaddr), dst.portno);
    138125        while ((rlen = tcp_rcv_buf(cepid, (void*)&buf, TMO_FEVR)) > 0) {
    … …  
    140127
    141128#ifdef SHOW_RCV_RANGE
    142                 syslog(LOG_NOTICE, "[TDS:%02d RCV] count: %4d, len: %4d, data: %02x -> %02x",
     129                syslog(LOG_NOTICE, "[TDSn:%02u RCV] count: %6lu, len: %4u, data: %02x -> %02x",
    143130                       cepid, count, (uint16_t)rlen, *buf, *(buf + rlen - 1));
    144131#endif  /* of #ifdef SHOW_RCV_RANGE */
    … …  
    150137
    151138                if ((error = tcp_rel_buf(cepid, rlen)) != E_OK) {
    152                         syslog(LOG_NOTICE, "[TDS:%02d RCV] rel buf error: %s",
     139                        syslog(LOG_NOTICE, "[TDSn:%02u RCV] rel buf error: %s",
    153140                                            cepid, itron_strerror(error));
    154141                        rlen = 0;
    … …  
    159146
    160147        if (rlen != 0)
    161                 syslog(LOG_NOTICE, "[TDS:%02d RCV] recv buf error: %s", cepid, itron_strerror(rlen));
     148                syslog(LOG_NOTICE, "[TDSn:%02u RCV] recv buf error: %s", cepid, itron_strerror(rlen));
    162149
    163150        if ((error = tcp_sht_cep(cepid)) != E_OK)
    164                 syslog(LOG_NOTICE, "[TDS:%02d RCV] shutdown error: %s", cepid, itron_strerror(error));
     151                syslog(LOG_NOTICE, "[TDSn:%02u RCV] shutdown error: %s", cepid, itron_strerror(error));
    165152
    166153        if ((error = tcp_cls_cep(cepid, TMO_FEVR)) != E_OK)
    167                 syslog(LOG_NOTICE, "[TDS:%02d RCV] close error: %s", cepid, itron_strerror(error));
     154                syslog(LOG_NOTICE, "[TDSn:%02u RCV] close error: %s", cepid, itron_strerror(error));
    168155
    169156        get_tim(&time);
    170         syslog(LOG_NOTICE, "[TDS:%02d RCV] finished:   %6ld,            rcv: %4d, len: %ld",
     157        syslog(LOG_NOTICE, "[TDSn:%02u RCV] finsh: %7lu, ttl: %lu",
    171158                           cepid, time / SYSTIM_HZ, count, total);
    172159
    … …  
    190177
    191178        if ((error = TCP_ACP_CEP(cepid, repid, &dst, TMO_FEVR)) != E_OK) {
    192                 syslog(LOG_NOTICE, "[TDS:%02d RCV] accept error: %s", cepid, itron_strerror(error));
     179                syslog(LOG_NOTICE, "[TDSn:%02u RCV] accept error: %s", cepid, itron_strerror(error));
    193180                return error;
    194181                }
    195182
    196183#ifdef USE_TCP_EXTENTIONS
    197         if ((error = free_tcp_rep(repid, true)) != E_OK) {
    198                 syslog(LOG_NOTICE, "[TDS:%02d DEL] REP delete error: %s", cepid, itron_strerror(error));
     184        if ((error = FREE_TCP_REP(repid, true)) != E_OK) {
     185                syslog(LOG_NOTICE, "[TDSn:%02u DEL] REP delete error: %s", cepid, itron_strerror(error));
    199186                return error;
    200187                }
    … …  
    203190        count = total = 0;
    204191        get_tim(&time);
    205         syslog(LOG_NOTICE, "[TDS:%02d RCV] connected:  %6ld, from: %s.%d",
     192        syslog(LOG_NOTICE, "[TDSn:%02u RCV] conct: %7lu, from: %s.%d",
    206193                           cepid, time / SYSTIM_HZ, IP2STR(NULL, &dst.ipaddr), dst.portno);
    207194        while ((rlen = tcp_rcv_dat(cepid, buf, BUF_SIZE - 1, TMO_FEVR)) > 0) {
    … …  
    209196
    210197#ifdef SHOW_RCV_RANGE
    211                 syslog(LOG_NOTICE, "[TDS:%02d RCV] count: %4d, len: %4d, data: %02x -> %02x",
     198                syslog(LOG_NOTICE, "[TDSn:%02u RCV] count: %6lu, len: %4u, data: %02x -> %02x",
    212199                       cepid, count, (uint16_t)rlen, *buf, *(buf + rlen - 1));
    213200#endif  /* of #ifdef SHOW_RCV_RANGE */
    … …  
    216203                }
    217204        if (rlen != 0)
    218                 syslog(LOG_NOTICE, "[TDS:%02d RCV] recv error: %s", cepid, itron_strerror(rlen));
     205                syslog(LOG_NOTICE, "[TDSn:%02u RCV] recv error: %s", cepid, itron_strerror(rlen));
    219206
    220207        if ((error = tcp_sht_cep(cepid)) != E_OK)
    221                 syslog(LOG_NOTICE, "[TDS:%02d RCV] shutdown error: %s", cepid, itron_strerror(error));
     208                syslog(LOG_NOTICE, "[TDSn:%02u RCV] shutdown error: %s", cepid, itron_strerror(error));
    222209
    223210        if ((error = tcp_cls_cep(cepid, TMO_FEVR)) != E_OK)
    224                 syslog(LOG_NOTICE, "[TDS:%02d RCV] close error: %s", cepid, itron_strerror(error));
     211                syslog(LOG_NOTICE, "[TDSn:%02u RCV] close error: %s", cepid, itron_strerror(error));
    225212
    226213        get_tim(&time);
    227         syslog(LOG_NOTICE, "[TDS:%02d RCV] finished:   %6ld,            rcv: %4d, len: %ld",
     214        syslog(LOG_NOTICE, "[TDSn:%02u RCV] finsh: %7lu, ttl: %lu",
    228215                           cepid, time / SYSTIM_HZ, count, total);
    229216
    … …  
    243230{
    244231        ID              tskid;
    245         T_TCP_CREP      crep;
     232        T_TCPN_CREP     crep;
    246233
    247234        get_tid(&tskid);
    … …  
    250237        crep.myaddr.portno = UINT_C(9);
    251238
     239#if defined(SUPPORT_INET6)
     240
     241        memcpy(&crep.myaddr.ipaddr, &ipv6_addrany, sizeof(T_IN6_ADDR));
     242
     243#else   /* #if defined(SUPPORT_INET6) */
     244
    252245#if defined(SUPPORT_INET4)
    253246        crep.myaddr.ipaddr = IPV4_ADDRANY;
    254247#endif
    255248
    256 #if defined(SUPPORT_INET6)
    257         memcpy(&crep.myaddr.ipaddr, &ipv6_addrany, sizeof(T_IN6_ADDR));
    258 #endif
    259 
    260         return alloc_tcp_rep(repid, tskid, &crep);
     249#endif  /* #if defined(SUPPORT_INET6) */
     250
     251        return ALLOC_TCP_REP(repid, tskid, &crep);
    261252        }
    262253
    … …  
    285276#endif
    286277
    287         return alloc_tcp_cep(cepid, tskid, &ccep);
     278        return ALLOC_TCP_CEP(cepid, tskid, &ccep);
    288279        }
    289280
    … …  
    299290
    300291        syscall(get_tid(&tskid));
    301         syslog(LOG_NOTICE, "[TCP ECHO SRV:%d] started.", tskid);
     292
     293#if defined(SUPPORT_INET6)
     294#if defined(SUPPORT_INET4)
     295        syslog(LOG_NOTICE, "[TCPn DISCARD SRV:%d] started.", tskid);
     296#else
     297        syslog(LOG_NOTICE, "[TCP6 DISCARD SRV:%d] started.", tskid);
     298#endif
     299#else
     300        syslog(LOG_NOTICE, "[TCP4 DISCARD SRV:%d] started.", tskid);
     301#endif
     302
    302303        while (true) {
    303304
    304305                syscall(slp_tsk());
    305306                if ((error = get_tcp_cep (&cepid)) != E_OK) {
    306                         syslog(LOG_NOTICE, "[TDS:00 EXT] CEP create error: %s", itron_strerror(error));
     307                        syslog(LOG_NOTICE, "[TDSn:00 EXT] CEP create error: %s", itron_strerror(error));
    307308                        continue;
    308309                        }
    … …  
    311312
    312313                        if ((error = get_tcp_rep (&repid)) != E_OK) {
    313                                 syslog(LOG_NOTICE, "[TDS:00 EXT] REP create error: %s", itron_strerror(error));
     314                                syslog(LOG_NOTICE, "[TDSn:00 EXT] REP create error: %s", itron_strerror(error));
    314315                                break;
    315316                                }
    316317                        else if ((error = tcp_discard_srv(cepid, repid)) != E_OK) {
    317                                 error = free_tcp_rep(repid, error != E_DLT);
     318                                error = FREE_TCP_REP(repid, error != E_DLT);
    318319                                break;
    319320                                }
    320321                        }
    321322
    322                 if ((error = free_tcp_cep(cepid)) != E_OK)
    323                         syslog(LOG_NOTICE, "[TDS:%02d EXT] CEP delete error: %s", cepid, itron_strerror(error));
     323                if ((error = FREE_TCP_CEP(cepid)) != E_OK)
     324                        syslog(LOG_NOTICE, "[TDSn:%02u EXT] CEP delete error: %s", cepid, itron_strerror(error));
    324325
    325326                }
    … …  
    334335
    335336        get_tid(&tskid);
    336         syslog(LOG_NOTICE, "[TCP DISCARD SRV:%d,%d] started.", tskid, (ID)exinf);
     337
     338#if defined(SUPPORT_INET6)
     339#if defined(SUPPORT_INET4)
     340        syslog(LOG_NOTICE, "[TCPn DISCARD SRV:%d,%d] started.", tskid, (ID)exinf);
     341#else
     342        syslog(LOG_NOTICE, "[TCP6 DISCARD SRV:%d,%d] started.", tskid, (ID)exinf);
     343#endif
     344#else
     345        syslog(LOG_NOTICE, "[TCP4 DISCARD SRV:%d,%d] started.", tskid, (ID)exinf);
     346#endif
     347
    337348        while (true) {
    338349                while (tcp_discard_srv((ID)exinf, TCP_DISCARD_SRV_REPID) == E_OK)
Note: See TracChangeset for help on using the changeset viewer.