RTSS 2017 submissionwip-modechange

5 files changed, 96 insertions, 557 deletions

diff --git a/include/litmus/trace.h b/include/litmus/trace.h
index eb0a07f4ba04..4dbb39ea8a14 100644
--- a/include/litmus/trace.h
+++ b/include/litmus/trace.h
@@ -3,7 +3,6 @@
 
 #ifdef CONFIG_SCHED_OVERHEAD_TRACE
 
-
 #include <litmus/feather_trace.h>
 #include <litmus/feather_buffer.h>
 
diff --git a/litmus/bank_proc.c b/litmus/bank_proc.c
index 08b58f94c391..097cff177a2d 100644
--- a/litmus/bank_proc.c
+++ b/litmus/bank_proc.c
@@ -1,7 +1,7 @@
 /*
  * bank_proc.c -- Implementation of the page coloring for cache and bank partition. 
  *                The file will keep a pool of colored pages. Users can require pages with 
- *                specific color or bank number.
+ *                specific color or bank number.
  *                Part of the code is modified from Jonathan Herman's code  
  */
 #include <linux/init.h>
@@ -19,9 +19,6 @@
 #include <litmus/sched_trace.h>
 #include <litmus/litmus.h>
 
-//#define TRACE(fmt, args...) do {} while (false)
-//#define TRACE_TASK(fmt, args...) do {} while (false)
-
 #define LITMUS_LOCKDEP_NAME_MAX_LEN 50
 
 // This Address Decoding is used in imx6-sabredsd platform
@@ -86,7 +83,6 @@ int node_index[9] = {
 
 struct mutex void_lockdown_proc;
 
-
 /*
  * Every page list should contain a lock, a list, and a number recording how many pages it store
  */ 
@@ -105,7 +101,6 @@ static struct color_group *color_groups;
  */
 unsigned int counting_one_set(unsigned int v)
 {
-//    unsigned int v; // count the number of bits set in v
     unsigned int c; // c accumulates the total bits set in v
 
     for (c = 0; v; v >>= 1)
@@ -257,8 +252,6 @@ static inline unsigned int page_list_index(struct page *page)
 {
     unsigned int idx;  
     idx = (page_color(page) + page_bank(page)*(number_cachecolors));
-//    printk("address = %lx, ", page_to_phys(page));
-//    printk("color(%d), bank(%d), indx = %d\n", page_color(page), page_bank(page), idx);
 
     return idx; 
 }
@@ -289,10 +282,10 @@ static void show_nr_pages(void)
         printk("show nr pages***************************************\n");
         for (i = 0; i < NUM_PAGE_LIST; ++i) {
                 cgroup = &color_groups[i];
-                printk("(%03d) =  %03d, ", i, atomic_read(&cgroup->nr_pages));
-                if((i % 8) ==7){
+                printk("(%03ld) =  %03d, ", i, atomic_read(&cgroup->nr_pages));
+                if((i % 8) ==7) {
                     printk("\n");
-                }
+                }
         }
 }
 
@@ -316,6 +309,7 @@ void add_page_to_color_list(struct page *page)
  * Replenish the page pool. 
  * If the newly allocate page is what we want, it will be pushed to the correct page list
  * otherwise, it will be freed. 
+ * A user needs to invoke this function until the page pool has enough pages.
  */
 static int do_add_pages(void)
 {
@@ -329,8 +323,6 @@ static int do_add_pages(void)
         
         // until all the page lists contain enough pages 
         for (i=0; i< 1024*20;i++) {
-        //while (smallest_nr_pages() < PAGES_PER_COLOR) {
-       //         printk("smallest = %d\n", smallest_nr_pages());       
                 page = alloc_page(GFP_HIGHUSER_MOVABLE);
         
                 if (unlikely(!page)) {
@@ -340,55 +332,20 @@ static int do_add_pages(void)
                 }
                 color = page_list_index(page);
                 counter[color]++;
-        //      printk("page(%d) = color %x, bank %x, [color] =%d \n", color, page_color(page), page_bank(page), atomic_read(&color_groups[color].nr_pages));
-                //show_nr_pages();
-                //if (atomic_read(&color_groups[color].nr_pages) < PAGES_PER_COLOR && color>=16) {
-                if (atomic_read(&color_groups[color].nr_pages) < PAGES_PER_COLOR) {
-                //if ( PAGES_PER_COLOR && color>=16*2) {
+                if (atomic_read(&color_groups[color].nr_pages) < PAGES_PER_COLOR && color>=0) {
                         add_page_to_color_list(page);
-        //              printk("add page(%d) = color %x, bank %x\n", color, page_color(page), page_bank(page));
-                } else{
+                } else {
                         // Pages here will be freed later 
                         list_add_tail(&page->lru, &free_later);
                         free_counter++;
-                        //list_del(&page->lru);
-                //        __free_page(page);
-        //              printk("useless page(%d) = color %x, bank %x\n", color,  page_color(page), page_bank(page));
                 }
-               //show_nr_pages();
-                /*
-                if(free_counter >= PAGES_PER_COLOR)
-                {
-                    printk("free unwanted page list eariler");
-                    free_counter = 0;
-                    list_for_each_entry_safe(page, page_tmp, &free_later, lru) {
-                        list_del(&page->lru);
-                        __free_page(page);
-                    }
-
-                    show_nr_pages();
-                }
-                */
-        }
-/*        printk("page counter = \n");
-        for (i=0; i<128; i++)
-        {
-            printk("(%03d) = %4d, ", i , counter[i]);
-            if(i%8 == 7){
-                printk("\n");
-            }
+        }
 
-        }
-*/      
-        //printk("After refill : \n");
-        //show_nr_pages();
-#if 1
         // Free the unwanted pages
         list_for_each_entry_safe(page, page_tmp, &free_later, lru) {
                 list_del(&page->lru);
                 __free_page(page);
         }
-#endif
 out:
         return ret;
 }
@@ -407,7 +364,6 @@ static struct page *new_alloc_page_color( unsigned long color)
                 
         if( (color <0) || (color)>(number_cachecolors*number_banks -1)) {
                 TRACE_CUR("Wrong color %lu\n", color);  
-//              printk(KERN_WARNING "Wrong color %lu\n", color);
                 goto out;
         }
 
@@ -416,7 +372,6 @@ static struct page *new_alloc_page_color( unsigned long color)
         spin_lock(&cgroup->lock);
         if (unlikely(!atomic_read(&cgroup->nr_pages))) {
                 TRACE_CUR("No free %lu colored pages.\n", color);
-//              printk(KERN_WARNING "no free %lu colored pages.\n", color);
                 goto out_unlock;
         }
         rPage = list_first_entry(&cgroup->list, struct page, lru);