Changeset 429 for EcnlProtoTool/trunk/asp3_dcre/tinet/netinet/udpn_input.c

Timestamp:

Jul 3, 2020, 7:19:17 PM (4 years ago)

Author:

coas-nagasima

Message:

ASP3, TINET, mbed を更新

File:

• EcnlProtoTool/trunk/asp3_dcre/tinet/netinet/udpn_input.c (modified) (5 diffs)

EcnlProtoTool/trunk/asp3_dcre/tinet/netinet/udpn_input.c

@@ -88 +88 @@
 {
         T_UDP_HDR       *udph;
-        uint_t          len;
+        T_UDP_RCV_DAT_PARA para;
 
         udph = (T_UDP_HDR *)(input->buf + off);
-        len  = (uint_t)(ntohs(udph->ulen) - UDP_HDR_SIZE);
+        para.len  = (uint_t)(ntohs(udph->ulen) - UDP_HDR_SIZE);
 
         if (cep->rcv_tskid != TA_NULL) {        /* 非ノンブロッキングコールでペンディング中 */
@@ -111 +111 @@
                 /* データをバッファに移す。*/
                 memcpy(cep->rcv_data, GET_UDP_SDU(input, off),
-                       (size_t)(len < cep->rcv_len ? len : cep->rcv_len));
+                       (size_t)(para.len < cep->rcv_len ? para.len : cep->rcv_len));
                 syscall(rel_net_buf(input));
 
@@ -117 +117 @@
 
 #ifdef TCP_CFG_NON_BLOCKING_COMPAT14
-                        (*cep->callback)(GET_UDP_CEPID(cep), TFN_UDP_RCV_DAT, (void*)(uint32_t)len);
+                        (*cep->callback)(GET_UDP_CEPID(cep), TFN_UDP_RCV_DAT, (void*)(uint32_t)para.len);
 #else
-                        (*cep->callback)(GET_UDP_CEPID(cep), TFN_UDP_RCV_DAT, (void*)&len);
+                        (*cep->callback)(GET_UDP_CEPID(cep), TFN_UDP_RCV_DAT, (void*)&para.len);
 #endif
                 else
@@ -134 +134 @@
 
 #ifdef TCP_CFG_NON_BLOCKING_COMPAT14
-                (*cep->callback)(GET_UDP_CEPID(cep), TEV_UDP_RCV_DAT, (void*)(uint32_t)len);
+                (*cep->callback)(GET_UDP_CEPID(cep), TEV_UDP_RCV_DAT, (void*)(uint32_t)para.len);
 #else
-                (*cep->callback)(GET_UDP_CEPID(cep), TEV_UDP_RCV_DAT, (void*)&len);
+                para.input = input;
+                para.off = off;
+#if API_PROTO == API_PROTO_IPV4
+                para.rep4.portno = ntohs(udph->sport);
+                IN_COPY_TO_HOST(&para.rep4.ipaddr, input);
+#else
+                para.rep6.portno = ntohs(udph->sport);
+                IN_COPY_TO_HOST(&para.rep6.ipaddr, input);
+#endif
+                (*cep->callback)(GET_UDP_CEPID(cep), TEV_UDP_RCV_DAT, (void*)&para.len);
 #endif
                 /*
@@ -143 +152 @@
                  *  データを読み出さなかったことになるので、捨てる。
                  */
-                if (cep->cb_netbuf != NULL)
-                        syscall(rel_net_buf(cep->cb_netbuf));
+                if (cep->cb_netbuf != NULL) {
+                        if ((input->flags & NB_FLG_NOREL_IFOUT) == 0)
+                                syscall(rel_net_buf(cep->cb_netbuf));
+                        cep->cb_netbuf = NULL;
+                        }
                 }
         else {