Implement k-FMLP.

Implemented a k-FMLP protocol which load balances requests
across k FIFO queues.

2 files changed, 5 insertions, 2 deletions

diff --git a/include/litmus/fdso.h b/include/litmus/fdso.h
index caf2a1e6918c..c740e8fc3e88 100644
--- a/include/litmus/fdso.h
+++ b/include/litmus/fdso.h
@@ -18,9 +18,10 @@ typedef enum  {
         MIN_OBJ_TYPE    = 0,
 
         FMLP_SEM        = 0,
-        SRP_SEM         = 1,
+        KFMLP_SEM       = 1,
+        SRP_SEM         = 2,
 
-        MAX_OBJ_TYPE    = 1
+        MAX_OBJ_TYPE    = SRP_SEM
 } obj_type_t;
 
 struct inode_obj_id {
@@ -64,6 +65,7 @@ static inline void* od_lookup(int od, obj_type_t type)
 }
 
 #define lookup_fmlp_sem(od)((struct pi_semaphore*)  od_lookup(od, FMLP_SEM))
+#define lookup_kfmlp_sem(od)((struct pi_semaphore*)  od_lookup(od, KFMLP_SEM))
 #define lookup_srp_sem(od) ((struct srp_semaphore*) od_lookup(od, SRP_SEM))
 #define lookup_ics(od)     ((struct ics*)           od_lookup(od, ICS_ID))
 
diff --git a/include/litmus/litmus.h b/include/litmus/litmus.h
index 94086e2b38db..befdf6381693 100644
--- a/include/litmus/litmus.h
+++ b/include/litmus/litmus.h
@@ -27,6 +27,7 @@ static inline int in_list(struct list_head* list)
 }
 
 struct task_struct* waitqueue_first(wait_queue_head_t *wq);
+struct task_struct* waitqueue_first_and_remove(wait_queue_head_t *wq);
 
 #define NO_CPU                  0xffffffff