Changeset 514d561 in mainline for uspace/lib/c/include/fibril.h

Timestamp:

2018-07-20T16:27:20Z (6 years ago)

Author:

Jiří Zárevúcky <jiri.zarevucky@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

05208d9

Parents:

7137f74c

git-author:

Jiří Zárevúcky <jiri.zarevucky@…> (2018-07-19 21:52:47)

git-committer:

Jiří Zárevúcky <jiri.zarevucky@…> (2018-07-20 16:27:20)

Message:

Fibril/async implementation overhaul.

This commit marks the move towards treating the fibril library as a mere
implementation of a generic threading interface. Understood as a layer that
wraps the kernel threads, we not only have to wrap threading itself, but also
every syscall that blocks the kernel thread (by blocking, we mean thread not
doing useful work until an external event happens — e.g. locking a kernel
mutex or thread sleep is understood as blocking, but an as_area_create() is not,
despite potentially taking a long time to complete).

Consequently, we implement fibril_ipc_wait() as a fibril-native wrapper for
kernel's ipc_wait(), and also implement timer functionality like timeouts
as part of the fibril library. This removes the interdependency between fibril
implementation and the async framework — in theory, the fibril API could be
reimplemented as a simple 1:1 shim, and the async framework would continue
working normally (note that the current implementation of loader complicates
this).

To better isolate the fibril internals from the implementation of high-level
synchronization, a fibril_event_t is added. This object conceptually acts
like a single slot wait queue. All other synchronization is implemented in
terms of this primitive.

File:

• uspace/lib/c/include/fibril.h (modified) (4 diffs)

uspace/lib/c/include/fibril.h

@@ -38 +38 @@
 #include <types/common.h>
 #include <time.h>
+#include <_bits/__noreturn.h>
+#include <ipc/common.h>
 
 typedef struct fibril fibril_t;
@@ -45 +47 @@
 } fibril_owner_info_t;
 
-typedef sysarg_t fid_t;
+typedef fibril_t *fid_t;
+
+typedef struct {
+        fibril_t *fibril;
+} fibril_event_t;
+
+#define FIBRIL_EVENT_INIT ((fibril_event_t) {0})
 
 /** Fibril-local variable specifier */
@@ -52 +60 @@
 #define FIBRIL_DFLT_STK_SIZE    0
 
-extern fid_t fibril_create_generic(errno_t (*func)(void *), void *arg, size_t);
-extern void fibril_destroy(fid_t fid);
-extern void fibril_add_ready(fid_t fid);
+extern fid_t fibril_create_generic(errno_t (*)(void *), void *, size_t);
+extern void fibril_destroy(fid_t);
+extern void fibril_add_ready(fid_t);
 extern fid_t fibril_get_id(void);
 extern void fibril_yield(void);
@@ -71 +79 @@
 }
 
+extern void fibril_start(fid_t);
+extern __noreturn void fibril_exit(long);
+
+extern void fibril_wait_for(fibril_event_t *);
+extern errno_t fibril_wait_timeout(fibril_event_t *, const struct timeval *);
+extern void fibril_notify(fibril_event_t *);
+
+extern errno_t fibril_ipc_wait(ipc_call_t *, const struct timeval *);
+extern void fibril_ipc_poke(void);
+
 #endif