Changeset 364 for asp3_tinet_ecnl_arm/trunk/asp3_dcre/tinet/net/net_buf.c

Timestamp:

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

Author:

coas-nagasima

Message:

TINETとSocket APIなどを更新

File:

• asp3_tinet_ecnl_arm/trunk/asp3_dcre/tinet/net/net_buf.c (modified) (10 diffs)

asp3_tinet_ecnl_arm/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;
@@ -320 +340 @@
                         return error;
                         }
-                else if (ix == 0 || net_buf_table[ix].size > maxlen)
+                ix --;
+                if (ix < 0 || net_buf_table[ix].size > maxlen)
                         break;
-                ix --;
                 }
 
@@ -351 +371 @@
 
         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;
@@ -359 +379 @@
                         (*buf)->conn_pos = 0;
 #endif
+
 #if NET_COUNT_ENABLE & PROTO_FLG_NET_BUF
                         NET_COUNT_NET_BUF(net_buf_table[ix].allocs, 1);
@@ -454 +475 @@
                 /* 固定メモリプールに返す。*/
 
-#if NET_COUNT_ENABLE & PROTO_FLG_NET_BUF
-                net_buf_table[buf->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);
+                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[idix].index, buf)) != E_OK) {
+                        syslog(LOG_WARNING, "[NET BUF] %s, ID=%d.", itron_strerror(error), idix);
                         }
                 }
@@ -509 +531 @@
         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;
+#ifdef IF_ETHER_MULTI_NIC
+        (*buf)->conn_pos = 0;
+#endif
+
+        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