Kernel: Add support for recv() with MSG_DONTWAIT.

Passing this flag to recv() temporarily puts the file descriptor into
non-blocking mode.

Also implement LocalSocket::recv() as a simple forwarding to read().

1 files changed, 7 insertions, 3 deletions

diff --git a/Kernel/Scheduler.cpp b/Kernel/Scheduler.cpp
index 4f6b55e048..98c357e6b1 100644
--- a/Kernel/Scheduler.cpp
+++ b/Kernel/Scheduler.cpp
@@ -223,10 +223,14 @@ bool Scheduler::pick_next()
     });
 
 #ifdef SCHEDULER_DEBUG
-    dbgprintf("Scheduler choices: (runnable threads: %p)\n", g_runnable_threads);
+    dbgprintf("Non-runnables:\n");
+    for (auto* thread = g_nonrunnable_threads->head(); thread; thread = thread->next()) {
+        auto* process = &thread->process();
+        dbgprintf("[K%x] % 12s %s(%u:%u) @ %w:%x\n", process, to_string(thread->state()), process->name().characters(), process->pid(), thread->tid(), thread->tss().cs, thread->tss().eip);
+    }
+
+    dbgprintf("Runnables:\n");
     for (auto* thread = g_runnable_threads->head(); thread; thread = thread->next()) {
-        //if (process->state() == Thread::BlockedWait || process->state() == Thread::BlockedSleep)
-//            continue;
         auto* process = &thread->process();
         dbgprintf("[K%x] % 12s %s(%u:%u) @ %w:%x\n", process, to_string(thread->state()), process->name().characters(), process->pid(), thread->tid(), thread->tss().cs, thread->tss().eip);
     }