Fix minor bugs and directory paths

code/cache-ss.cc

@@ -152,7 +152,7 @@ Cache::load_dump_nopart(struct kv_analyze_all *kvs, long n, long prewarm_set_lim
                 {
                     vdisk = vtl[to_hm3val((&node->data))->extents[j].eid.vdisk];
                     prewarm_set_used_size[vdisk] += SIZE_HM3_OBJ;
-                    prewarm_set_used_objs[vdisk]++;
+                    // prewarm_set_used_objs[vdisk]++;
                 }
                 cursize += SIZE_HM3_OBJ;
             }
@@ -185,7 +185,7 @@ Cache::load_dump_nopart(struct kv_analyze_all *kvs, long n, long prewarm_set_lim
                 }
                 cursize += SIZE_HM1_OBJ;
                 prewarm_set_used_size[kvs[k].vdisk] += SIZE_HM1_OBJ;
-                prewarm_set_used_objs[kvs[k].vdisk]++;
+                // prewarm_set_used_objs[kvs[k].vdisk]++;
             }
             else
                 break;

code/exp1.cc

@@ -25,7 +25,7 @@ void exp1()
 
     pthread_t cache_thread;
 
-    Workload *wload = new Workload("test_iops100"); //<-----------
+    Workload *wload = new Workload("wss_iops100"); //<-----------
     Hashmap *hm1 = new Hashmap(&comp_hm1, &print_hm1, nullptr);
     Hashmap *hm3 = new Hashmap(&comp_hm3, &print_hm3, nullptr);
     Cache *cache = new Cache(CACHE_A, hm1, hm3, wload, 3000); //<-----------
@@ -251,7 +251,7 @@ void *run_exp1(void *data)
         mkdir(rp->base_filename, 0755);
 
     snprintf(all_stats_fname, MAX_FILENAME_LEN, "%s/ALL-STATS.txt", rp->base_filename);
-    snprintf(diff_fname, MAX_FILENAME_LEN, "/home/skrtbhtngr/CLionProjects/presto/results/exp1/%s/%d.diff",
+    snprintf(diff_fname, MAX_FILENAME_LEN, "/home/rahul/Rnd/presto/code/results/exp1/%s/%d.diff",
              cache->wload_name, snapshot_rate);
 
     res_hr = new double *[num_vdisks];

code/gen.py

@@ -200,7 +200,7 @@ def generate(conf):
                 sector_cluster_size = 0
                 continue
 
-            # file.write("%c,%d,%ld,%d,%.6f\n" % (rw, vdisk_id, sector, iosize, ts))
+            file.write("%c,%d,%ld,%d,%.6f\n" % (rw, vdisk_id, sector, iosize, ts))
 
             # if sector > hs[1] or sector < hs[0]:
             #     blocks_o_hr.append(sector)

code/gen_main.py

@@ -77,9 +77,9 @@ def main():
                 conf_template['hotspots'] = hotspot_list[hs]
                 print(csize[0], csize[1], cstride[0], cstride[1], "HS" + str(hs + 1), disk_used[hs])
                 generate(conf_template)
-                # file.write("%d,%d,%s/%s.csv\n" % (conf_template['vdisk']['id'],
-                #                                   get_size_gb(conf_template['vdisk']['size']),
-                #                                   conf_template['set'], conf_template['name']))
+                file.write("%d,%d,%s/%s.csv\n" % (conf_template['vdisk']['id'],
+                                                  get_size_gb(conf_template['vdisk']['size']),
+                                                  conf_template['set'], conf_template['name']))
                 i += 1
                 # sys.stdout.write(conf_template['name'] + ' done!')
 

code/main.cc

@@ -7,7 +7,7 @@
 
 int Snapshot::num_epochs;
 
-int experiment = 2;
+int experiment = 1;
 
 int main()
 {

code/merge.py

+import os
+
+if __name__ == "__main__":
+    wload="wss_iops100"
+    os.chdir("traces/" + wload)
+    os.system("cat syn*.csv > temp.csv")
+    os.system("sort --field-separator=',' -n -k 5,5 temp.csv > %sMerged.csv" % (wload))

code/util.h

@@ -83,7 +83,7 @@ using namespace std;
 #define HEURISTIC_RECN_MIN_VAL 100
 #define MAX_LAST_SS 200
 
-#define PRESTO_BASEPATH "/home/skrtbhtngr/CLionProjects/presto/"
+#define PRESTO_BASEPATH "/home/rahul/Rnd/presto/code/"
 
 #define LEN(x, y) ((signed) ((sizeof(x))/(sizeof(y))))