Commit c1e1e761 authored by Misbah Mubarak's avatar Misbah Mubarak

Enabling compute times with lammps and nekbone

parent 127b92ae
...@@ -2780,6 +2780,7 @@ int modelnet_mpi_replay(MPI_Comm comm, int* argc, char*** argv ) ...@@ -2780,6 +2780,7 @@ int modelnet_mpi_replay(MPI_Comm comm, int* argc, char*** argv )
} }
i++; i++;
} }
printf("\n num_net_traces %d ", num_net_traces);
fclose(name_file); fclose(name_file);
assert(strlen(alloc_file) != 0); assert(strlen(alloc_file) != 0);
alloc_spec = 1; alloc_spec = 1;
......
...@@ -25,7 +25,7 @@ ...@@ -25,7 +25,7 @@
#include <cortex/topology.h> #include <cortex/topology.h>
#endif #endif
#define DUMP_CONNECTIONS 1 #define DUMP_CONNECTIONS 0
#define CREDIT_SIZE 8 #define CREDIT_SIZE 8
#define DFLY_HASH_TABLE_SIZE 4999 #define DFLY_HASH_TABLE_SIZE 4999
// debugging parameters // debugging parameters
......
...@@ -324,14 +324,14 @@ void SWM_Irecv(SWM_PEER peer, ...@@ -324,14 +324,14 @@ void SWM_Irecv(SWM_PEER peer,
void SWM_Compute(long cycle_count) void SWM_Compute(long cycle_count)
{ {
if(!cpu_freq) if(!cpu_freq)
cpu_freq = 4.0e9; cpu_freq = 2.0;
/* Add an event in the shared queue and then yield */ /* Add an event in the shared queue and then yield */
struct codes_workload_op wrkld_per_rank; struct codes_workload_op wrkld_per_rank;
wrkld_per_rank.op_type = CODES_WK_DELAY; wrkld_per_rank.op_type = CODES_WK_DELAY;
/* TODO: Check how to convert cycle count into delay? */ /* TODO: Check how to convert cycle count into delay? */
wrkld_per_rank.u.delay.nsecs = (cycle_count/cpu_freq); wrkld_per_rank.u.delay.nsecs = cycle_count;
wrkld_per_rank.u.delay.seconds = (cycle_count / cpu_freq) / (1000.0 * 1000.0 * 1000.0); wrkld_per_rank.u.delay.seconds = (cycle_count) / (1000.0 * 1000.0 * 1000.0);
#ifdef DBG_COMM #ifdef DBG_COMM
printf("\n compute op delay: %ld ", cycle_count); printf("\n compute op delay: %ld ", cycle_count);
#endif #endif
...@@ -815,7 +815,7 @@ static int comm_online_workload_load(const char * params, int app_id, int rank) ...@@ -815,7 +815,7 @@ static int comm_online_workload_load(const char * params, int app_id, int rank)
std::ifstream jsonFile(path.c_str()); std::ifstream jsonFile(path.c_str());
boost::property_tree::json_parser::read_json(jsonFile, root); boost::property_tree::json_parser::read_json(jsonFile, root);
uint32_t process_cnt = root.get<uint32_t>("jobs.size", 1); uint32_t process_cnt = root.get<uint32_t>("jobs.size", 1);
cpu_freq = root.get<double>("jobs.cfg.cpu_freq"); cpu_freq = root.get<double>("jobs.cfg.cpu_freq") / 1e9;
} }
catch(std::exception & e) catch(std::exception & e)
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment