mirror of
https://github.com/cesanta/mongoose.git
synced 2026-10-19 11:09:42 +00:00
Fetch multiple frames from the queue
This commit is contained in:
1 parent
f40b377fff
commit
1cadd2b2aa
2 files changed
+4
-4
No files matched your search
+2
-2
@@ -6648,8 +6648,8 @@ static void mg_tcpip_poll(struct mg_tcpip_if *ifp, uint64_t now) {
|
||||
}
|
||||
} else { // Complex poll / Interrupt-based driver. Queues recvd frames
|
||||
char *buf;
|
||||
size_t len = mg_queue_next(&ifp->recv_queue, &buf);
|
||||
if (len > 0) {
|
||||
size_t len;
|
||||
while ((len = mg_queue_next(&ifp->recv_queue, &buf)) > 0) {
|
||||
mg_tcpip_rx(ifp, buf, len);
|
||||
mg_queue_del(&ifp->recv_queue, len);
|
||||
}
|
||||
|
||||
+2
-2
@@ -1827,8 +1827,8 @@ static void mg_tcpip_poll(struct mg_tcpip_if *ifp, uint64_t now) {
|
||||
}
|
||||
} else { // Complex poll / Interrupt-based driver. Queues recvd frames
|
||||
char *buf;
|
||||
size_t len = mg_queue_next(&ifp->recv_queue, &buf);
|
||||
if (len > 0) {
|
||||
size_t len;
|
||||
while ((len = mg_queue_next(&ifp->recv_queue, &buf)) > 0) {
|
||||
mg_tcpip_rx(ifp, buf, len);
|
||||
mg_queue_del(&ifp->recv_queue, len);
|
||||
}
|
||||
|
||||
Reference in new issue
Block a user