Changeset 148 for uKadecot/trunk/uip/task

Timestamp:

Jan 8, 2016, 2:35:52 PM (8 years ago)

Author:

coas-nagasima

Message:

メッセージバッファ領域がなくなったときにWebSocketパケットを誤って処理してしまうのを修正。
Ethernet送信バッファが取れないときにパケットが送信できなかったのを修正。
その他、処理の安定性の向上。

File:

• uKadecot/trunk/uip/task/uip_task.c (modified) (10 diffs)

uKadecot/trunk/uip/task/uip_task.c

@@ -98 +98 @@
         T_IF_SOFTC      *ic = IF_ETHER_NIC_GET_SOFTC();
         int ret;
+        bool_t tx;
 
         PT_BEGIN(&uiptsk->pt);
@@ -124 +125 @@
 
                 PT_WAIT_UNTIL(&uiptsk->pt, (ret = ic->link_pre != ic->link_now ? 1 :
-                        (ic->rxb_read != ic->rxb_write ? 2 :
                         (uip_out_buf[uip_out_rpos].len > 0 ? 3 :
                         (ws_out_req != ws_out_res ? 4 :
-                        (timer_expired(&uiptsk->periodic_timer) ? 5 : 0))))) != 0);
+                        (timer_expired(&uiptsk->periodic_timer) ? 5 :
+                        (ic->rxb_read != ic->rxb_write ? 2 : 0))))) != 0);
 
                 if(ret == 1){
@@ -146 +147 @@
                                                 if (uip_len > 0) {
                                                         uip_arp_out();
-                                                        IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                                        for (;;) {
+                                                                tx = IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                                                if (tx)
+                                                                        break;
+                                                                PT_YIELD(&uiptsk->pt);
+                                                        }
                                                 }
                                         }
@@ -174 +180 @@
                                         if (uip_len > 0) {
                                                 uip_arp_out();
-                                                IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                                for (;;) {
+                                                        tx = IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                                        if (tx)
+                                                                break;
+                                                        PT_YIELD(&uiptsk->pt);
+                                                }
                                                 PT_YIELD(&uiptsk->pt);
                                                 continue;
@@ -185 +196 @@
                                            uip_len is set to a value > 0. */
                                         if (uip_len > 0) {
-                                                IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                                for (;;) {
+                                                        tx = IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                                        if (tx)
+                                                                break;
+                                                        PT_YIELD(&uiptsk->pt);
+                                                }
                                                 PT_YIELD(&uiptsk->pt);
                                                 continue;
@@ -204 +220 @@
                         uip_udp_send(buf->len);
 
-                        buf->len = 0;
-                        uip_out_rpos++;
-                        if (uip_out_rpos >= UIP_BUF_COUNT)
-                                uip_out_rpos = 0;
-
                         uip_udp_conn = cepid;
                         uip_process(UIP_UDP_SEND_CONN);
@@ -214 +225 @@
                         cepid->rport = 0;
                         uip_arp_out();
-                        IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                        for (;;) {
+                                tx = IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                if (tx)
+                                        break;
+                                PT_YIELD(&uiptsk->pt);
+                        }
+
+                        buf = &uip_out_buf[uip_out_rpos];
+                        uip_out_rpos++;
+                        if (uip_out_rpos >= UIP_BUF_COUNT)
+                                uip_out_rpos = 0;
+                        buf->len = 0;
+
                         PT_YIELD(&uiptsk->pt);
                         continue;
@@ -231 +254 @@
                                 if (uip_len > 0) {
                                         uip_arp_out();
-                                        IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                        for (;;) {
+                                                tx = IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                                if (tx)
+                                                        break;
+                                                PT_YIELD(&uiptsk->pt);
+                                        }
                                         PT_YIELD(&uiptsk->pt);
                                 }
@@ -247 +275 @@
                                 if (uip_len > 0) {
                                         uip_arp_out();
-                                        IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                        for (;;) {
+                                                tx = IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                                if (tx)
+                                                        break;
+                                                PT_YIELD(&uiptsk->pt);
+                                        }
                                         PT_YIELD(&uiptsk->pt);
                                 }
@@ -261 +294 @@
                                 if (uip_len > 0) {
                                         uip_arp_out();
-                                        IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                        for (;;) {
+                                                tx = IF_ETHER_NIC_START(ic, uip_buf, uip_len);
+                                                if (tx)
+                                                        break;
+                                                PT_YIELD(&uiptsk->pt);
+                                        }
                                         PT_YIELD(&uiptsk->pt);
                                 }