Changeset 364 for asp3_tinet_ecnl_rx/trunk/asp3_dcre/tinet/net

Timestamp:

Feb 1, 2019, 9:57:09 PM (5 years ago)

Author:

coas-nagasima

Message:

TINETとSocket APIなどを更新

Location:

asp3_tinet_ecnl_rx/trunk/asp3_dcre/tinet/net

Files:

• ethernet.h (modified) (3 diffs)
• net_asp.cfg (modified) (2 diffs)
• net_buf.c (modified) (9 diffs)
• net_rename.h (modified) (1 diff)

asp3_tinet_ecnl_rx/trunk/asp3_dcre/tinet/net/ethernet.h

@@ -98 +98 @@
 #endif  /* of #ifndef IF_ETHER_NIC_HDR_ALIGN */
 
-#if defined(__RX) || defined(_MSC_VER)
 #if defined(__RX)
 #pragma pack
-#else
+#elif defined(_MSC_VER)
 #pragma pack(push, 1)
 #endif
+
+#if defined(__RX) || defined(_MSC_VER)
+
 typedef struct t_ether_header {
 
@@ -116 +118 @@
         uint16_t        type;
         } T_ETHER_HDR;
-#if defined(__RX)
-#pragma packoption
-#else
-#pragma pack(pop)
-#endif
 
 #elif defined(TOPPERS_S810_CLG3_85)     /* of #if defined(__RX) */
@@ -166 +163 @@
         uint8_t         lladdr[ETHER_ADDR_LEN];
         } __attribute__((packed, aligned(2))) T_ETHER_ADDR;
+
+#if defined(__RX)
+#pragma packoption
+#elif defined(_MSC_VER)
+#pragma pack(pop)
+#endif
 
 /*

asp3_tinet_ecnl_rx/trunk/asp3_dcre/tinet/net/net_asp.cfg

@@ -41 +41 @@
 
 INCLUDE("net/net.cfg");
+
+#ifndef NOUSE_MPF_NET_BUF
 
 /*
@@ -169 +171 @@
                 });
 #endif  /* of #if defined(NUM_MPF_NET_BUF6_65536) && NUM_MPF_NET_BUF6_65536 > 0 */
+
+#endif

asp3_tinet_ecnl_rx/trunk/asp3_dcre/tinet/net/net_buf.c

@@ -68 +68 @@
 #include <netinet/tcp_var.h>
 
+#ifndef NOUSE_MPF_NET_BUF
+
 /*
  *  関数
@@ -226 +228 @@
 #endif  /* of #if defined(NUM_MPF_NET_BUF_128) && NUM_MPF_NET_BUF_128 > 0 */
 
-#if defined(_IP4_CFG)
+#if defined(_IP6_CFG)
+
+#if defined(NUM_MPF_NET_BUF_CSEG) && NUM_MPF_NET_BUF_CSEG > 0
+        {
+                MPF_NET_BUF_CSEG,
+                IF_HDR_SIZE + IP_HDR_SIZE + TCP_HDR_SIZE,
+
+#if NET_COUNT_ENABLE & PROTO_FLG_NET_BUF
+
+                NUM_MPF_NET_BUF_CSEG,
+
+#endif  /* of #if NET_COUNT_ENABLE & PROTO_FLG_NET_BUF */
+
+                },
+#endif  /* of #if defined(NUM_MPF_NET_BUF_CSEG) && NUM_MPF_NET_BUF_CSEG > 0 */
+
+#endif  /* of #if defined(_IP6_CFG) */
 
 #if defined(NUM_MPF_NET_BUF_64) && NUM_MPF_NET_BUF_64 > 0
@@ -242 +260 @@
 #endif  /* of #if defined(NUM_MPF_NET_BUF_64) && NUM_MPF_NET_BUF_64 > 0 */
 
-#endif  /* of #if defined(_IP4_CFG) */
+#if defined(_IP4_CFG) && !defined(_IP6_CFG)
 
 #if defined(NUM_MPF_NET_BUF_CSEG) && NUM_MPF_NET_BUF_CSEG > 0
@@ -257 +275 @@
                 },
 #endif  /* of #if defined(NUM_MPF_NET_BUF_CSEG) && NUM_MPF_NET_BUF_CSEG > 0 */
+
+#endif  /* of #if defined(_IP4_CFG) && !defined(_IP6_CFG) */
 
         };
@@ -307 +327 @@
 
         while (1) {
-                if ((error = tget_mpf((ID)net_buf_table[ix].index, (void*)buf, ix == 0 ? tmout : TMO_POL)) == E_OK) {
+                if ((error = tget_mpf((ID)net_buf_table[ix].index, (void **)buf, ix == 0 ? tmout : TMO_POL)) == E_OK) {
                         (*buf)->idix  = (uint8_t)ix;
                         (*buf)->len   = (uint16_t)minlen;
@@ -318 +338 @@
                         return error;
                         }
-                else if (ix == 0 || net_buf_table[ix].size > maxlen)
+                ix --;
+                if (ix < 0 || net_buf_table[ix].size > maxlen)
                         break;
-                ix --;
                 }
 
@@ -349 +369 @@
 
         while (1) {
-                if ((error = tget_mpf((ID)net_buf_table[ix].index, (void*)buf,
+                if ((error = tget_mpf((ID)net_buf_table[ix].index, (void **)buf,
                                       ix == sizeof(net_buf_table) / sizeof(T_NET_BUF_ENTRY) - 1 ? tmout : TMO_POL)) == E_OK) {
                         (*buf)->idix  = (uint8_t)ix;
                         (*buf)->len   = net_buf_table[ix].size;
                         (*buf)->flags = 0;
+#ifdef IF_ETHER_MULTI_NIC
+                        (*buf)->conn_pos = 0;
+#endif
 
 #if NET_COUNT_ENABLE & PROTO_FLG_NET_BUF
@@ -450 +473 @@
                 /* 固定メモリプールに返す。*/
 
-#if NET_COUNT_ENABLE & PROTO_FLG_NET_BUF
-                net_buf_table[buf->idix].busies --;
+                int idix = buf->idix;
+#if NET_COUNT_ENABLE & PROTO_FLG_NET_BUF
+                net_buf_table[idix].busies --;
 #endif
-                if ((error = rel_mpf((ID)net_buf_table[buf->idix].index, buf)) != E_OK) {
-                        syslog(LOG_WARNING, "[NET BUF] %s, ID=%d.", itron_strerror(error), buf->idix);
+                if ((error = rel_mpf((ID)net_buf_table[idix].index, buf)) != E_OK) {
+                        syslog(LOG_WARNING, "[NET BUF] %s, ID=%d.", itron_strerror(error), idix);
                         }
                 }
@@ -505 +529 @@
         return (uint_t)net_buf_table[0].size;
         }
+
+#else
+#include <stdlib.h>
+
+/*
+ *  tget_net_buf_ex -- ネットワークバッファを獲得する（拡張機能）。
+ */
+
+ER
+tget_net_buf_ex (T_NET_BUF **buf, uint_t minlen, uint_t maxlen, ATR nbatr, TMO tmout)
+{
+        uint_t len = (minlen > maxlen) ? minlen : maxlen;
+        *buf = (T_NET_BUF *)malloc(sizeof(T_NET_BUF) - sizeof(((T_NET_BUF *)0)->buf) + len);
+        if (*buf == NULL)
+                return E_NOMEM;
+
+        (*buf)->idix = 0;
+        (*buf)->len = (uint16_t)len;
+        (*buf)->flags = 0;
+
+        return E_OK;
+        }
+
+/*
+ *  tget_net_buf -- ネットワークバッファを獲得する（互換）。
+ */
+
+ER
+tget_net_buf (T_NET_BUF **buf, uint_t len, TMO tmout)
+{
+        return tget_net_buf_ex(buf, len, len, NBA_SEARCH_ASCENT, tmout);
+        }
+
+
+/*
+ * rel_net_buf -- ネットワークバッファを返却する。
+ */
+
+ER
+rel_net_buf (T_NET_BUF *buf)
+{
+        free(buf);
+
+        return E_OK;
+        }
+
+
+/*
+ * net_buf_max_siz -- ネットワークバッファの最大サイズを返す。
+ */
+
+uint_t
+net_buf_max_siz (void)
+{
+        return (uint_t)IF_PDU_SIZE;
+        }
+
+#endif

asp3_tinet_ecnl_rx/trunk/asp3_dcre/tinet/net/net_rename.h

@@ -71 +71 @@
 #define tget_net_buf_ex         _tinet_tget_net_buf_ex
 #define tget_net_buf            _tinet_tget_net_buf
-#define rel_net_buf             _tinet_rel_net_buf
-#define rus_net_buf             _tinet_rus_net_buf
-#define net_buf_siz             _tinet_net_buf_siz
+#define rel_net_buf                     _tinet_rel_net_buf
+#define rus_net_buf                     _tinet_rus_net_buf
+#define net_buf_siz                     _tinet_net_buf_siz
 #define net_buf_max_siz         _tinet_net_buf_max_siz
 #define nbuf_get_tbl            _tinet_nbuf_get_tbl