summaryrefslogtreecommitdiffstats
path: root/04_exercise/slotmap/slotmap.c
diff options
context:
space:
mode:
authorStefan Zabka <zabkaste@hu-berlin.de>2020-06-18 15:04:54 +0200
committerStefan Zabka <zabkaste@hu-berlin.de>2020-06-18 15:05:14 +0200
commit021afcb8e4aa4fbc7905f527089c415108c86c75 (patch)
tree3fd53ab9a1ccdb8b807bb973a4e19da077b871ea /04_exercise/slotmap/slotmap.c
parent190c347866ebd0c703407285646c6ce3e94f19a4 (diff)
downloadbetriebssysteme-021afcb8e4aa4fbc7905f527089c415108c86c75.tar.gz
betriebssysteme-021afcb8e4aa4fbc7905f527089c415108c86c75.zip
Switched to slotmap
Diffstat (limited to '04_exercise/slotmap/slotmap.c')
-rw-r--r--04_exercise/slotmap/slotmap.c48
1 files changed, 48 insertions, 0 deletions
diff --git a/04_exercise/slotmap/slotmap.c b/04_exercise/slotmap/slotmap.c
new file mode 100644
index 0000000..57c4ef5
--- /dev/null
+++ b/04_exercise/slotmap/slotmap.c
@@ -0,0 +1,48 @@
+//
+// Created by stefan on 18.06.20.
+//
+
+#include "slotmap.h"
+#include <stdio.h>
+smHeader smInit(smEntry * slab, size_t size) {
+ for (int i = 0; i < size; ++i) {
+ slab[i].value = (intptr_t)NULL;
+ }
+ return (smHeader){.slab = slab, .size=size};
+}
+int smInsert(smHeader const * header, void * value) {
+ for (size_t i = 0; i< header->size; ++i ) {
+ intptr_t ptr = atomic_load(&header->slab[i].value);
+ if((void *)ptr == NULL) {
+ intptr_t expected = (intptr_t) NULL;
+ if(atomic_compare_exchange_strong(&header->slab[i].value, &expected, (intptr_t) value)){
+ return 0;
+ }
+ }
+ }
+ return -1;
+}
+void smDelete(smEntry * node) {
+ intptr_t oldval = atomic_exchange(&node->value, (intptr_t)(NULL));
+ if((void *) oldval == NULL) {
+ fprintf(stderr, "A Node has been double deleted");
+ }
+}
+void smDeleteValue(smHeader const * header, void * value){
+ for (size_t i = 0; i< header->size; ++i ) {
+ intptr_t ptr = atomic_load(&header->slab[i].value);
+ if((void *)ptr == value) {
+ smDelete(&header->slab[i]);
+ }
+ }
+}
+smEntry *smFindEntry(smHeader const * header, SearchFunction func){
+ for (size_t i = 0; i< header->size; ++i ) {
+ void * value = (void *) atomic_load(&header->slab[i].value);
+
+ if(value != NULL && func(value)) {
+ return &header->slab[i];
+ }
+ }
+ return NULL;
+}