Commit aaae8628 authored by Sonja Happ's avatar Sonja Happ

set iothread to world_size to scale cassandra io threads with number of processes and agents

parent 8c4056a0
Subproject commit 1c87a59c6696e6a8f29cff9f0bc72bcad9d09368 Subproject commit ced46f578938bba24b10a87e2eda3ce5197bfce2
...@@ -155,7 +155,7 @@ void ModelIO::init_db() { ...@@ -155,7 +155,7 @@ void ModelIO::init_db() {
MPI_Bcast(&simId, 1, MPI_INT, 0, MPI_COMM_WORLD); MPI_Bcast(&simId, 1, MPI_INT, 0, MPI_COMM_WORLD);
d_props.result.dbconn->setSimId(simId); d_props.result.dbconn->setSimId(simId);
d_props.result.dbconn->setCassandraConfig(props->getProperty("cassandra.hosts"),"swarmgrid"); d_props.result.dbconn->setCassandraConfig(props->getProperty("cassandra.hosts"),"swarmgrid", world_size);
d_props.result.dbconn->createCassandraSession(); d_props.result.dbconn->createCassandraSession();
if(rank == 0){ if(rank == 0){
......
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