summaryrefslogtreecommitdiff
path: root/kernel/sched
diff options
context:
space:
mode:
authorAnton Kling <anton@kling.gg>2024-02-21 19:41:51 +0100
committerAnton Kling <anton@kling.gg>2024-02-21 19:41:51 +0100
commit6c9cb0bd8ceb039ce387c850e25adc6f99cfcd6f (patch)
tree41ceaa1c30b1f93adf4469064eb5e5f3bb18661c /kernel/sched
parent8ff63b062d724826d8017504063df9b92f8e6703 (diff)
Kerenel: Cleanup halt checking code
Diffstat (limited to 'kernel/sched')
-rw-r--r--kernel/sched/scheduler.c42
-rw-r--r--kernel/sched/scheduler.h1
2 files changed, 42 insertions, 1 deletions
diff --git a/kernel/sched/scheduler.c b/kernel/sched/scheduler.c
index 1aae1ce..614f621 100644
--- a/kernel/sched/scheduler.c
+++ b/kernel/sched/scheduler.c
@@ -324,6 +324,48 @@ int fork(void) {
return new_task->pid;
}
+int isset_fdhalt(process_t *p) {
+ if(NULL == p) {
+ p = get_current_task();
+ }
+ int blocked = 0;
+ struct list *read_list = &p->read_list;
+ struct list *write_list = &p->write_list;
+ struct list *disconnect_list = &p->disconnect_list;
+
+ for (int i = 0;; i++) {
+ vfs_inode_t *inode;
+ if (!list_get(read_list, i, (void **)&inode)) {
+ break;
+ }
+ if (inode->has_data) {
+ return 0;
+ }
+ blocked = 1;
+ }
+ for (int i = 0;; i++) {
+ vfs_inode_t *inode;
+ if (!list_get(write_list, i, (void **)&inode)) {
+ break;
+ }
+ if (inode->can_write) {
+ return 0;
+ }
+ blocked = 1;
+ }
+ for (int i = 0;; i++) {
+ vfs_inode_t *inode;
+ if (!list_get(disconnect_list, i, (void **)&inode)) {
+ break;
+ }
+ if (inode->is_open) {
+ return 0;
+ }
+ blocked = 1;
+ }
+ return blocked;
+}
+
int is_halted(process_t *process) {
for (int i = 0; i < 2; i++) {
if (process->halts[i]) {
diff --git a/kernel/sched/scheduler.h b/kernel/sched/scheduler.h
index 596bedb..ff38034 100644
--- a/kernel/sched/scheduler.h
+++ b/kernel/sched/scheduler.h
@@ -3,7 +3,6 @@ typedef struct Process process_t;
#define SCHEDULER_H
#include <fs/ext2.h>
#include <fs/vfs.h>
-#include <halts.h>
#include <ipc.h>
#include <lib/list.h>
#include <lib/stack.h>