Skip to content

Commit

Permalink
small fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
rafaelfsilva committed May 11, 2017
1 parent 0e1ca91 commit 65b89f5
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 7 deletions.
2 changes: 1 addition & 1 deletion CMakeLists.txt
Expand Up @@ -83,7 +83,7 @@ set(TEST_FILES
test/main.cpp
test/workflow/WorkflowTaskTest.cpp
test/workflow/WorkflowTest.cpp
test/wms/optimizations/dynamic/FailureDynamicCLusteringTest.cpp)
test/wms/optimizations/dynamic/FailureDynamicClusteringTest.cpp)

set(INCLUDE_FILES include/wrench.h)
set(INCLUDE_DEV_FILES include/wrench-dev.h)
Expand Down
11 changes: 7 additions & 4 deletions src/wrench/main.cpp
Expand Up @@ -71,7 +71,8 @@ int main(int argc, char **argv) {

std::cerr << "Instantiating a MultiCore Job executor on " << exexutor_host << "..." << std::endl;
simulation.add(
std::unique_ptr<wrench::MulticoreJobExecutor>(new wrench::MulticoreJobExecutor(exexutor_host, true, false)));
std::unique_ptr<wrench::MulticoreJobExecutor>(
new wrench::MulticoreJobExecutor(exexutor_host, true, false)));

// std::cerr << "Instantiating a MultiCore Job executor on " << executor_host << "..." << std::endl;
// simulation.add(std::unique_ptr<wrench::MulticoreJobExecutor>(new wrench::MulticoreJobExecutor(executor_host, true, false, {{wrench::MulticoreJobExecutor::Property::STOP_DAEMON_MESSAGE_PAYLOAD, "666"}})));
Expand All @@ -93,8 +94,9 @@ int main(int argc, char **argv) {

std::cerr << "Instantiating a SimpleStorageService on " << storage_host << "..." << std::endl;

wrench::StorageService *storage_service =simulation.add(
std::unique_ptr<wrench::SimpleStorageService>(new wrench::SimpleStorageService(storage_host, 1000000000000.0)));
wrench::StorageService *storage_service = simulation.add(
std::unique_ptr<wrench::SimpleStorageService>(
new wrench::SimpleStorageService(storage_host, 1000000000000.0)));

std::string wms_host = hostname_list[0];

Expand All @@ -115,7 +117,8 @@ int main(int argc, char **argv) {
std::string file_registry_service_host = hostname_list[(hostname_list.size() > 2) ? 1 : 0];

std::cerr << "Instantiating a FileRegistryService on " << file_registry_service_host << "..." << std::endl;
std::unique_ptr<wrench::FileRegistryService> file_registry_service(new wrench::FileRegistryService(file_registry_service_host));
std::unique_ptr<wrench::FileRegistryService> file_registry_service(
new wrench::FileRegistryService(file_registry_service_host));
simulation.setFileRegistryService(std::move(file_registry_service));

std::cerr << "Staging input files..." << std::endl;
Expand Down
Expand Up @@ -36,10 +36,9 @@ namespace wrench {
}
}
}
unsigned long final_size = workflow->getReadyTasks().size();

if (count > 0) {
WRENCH_INFO("Ungrouped %d tasks", count);
}
}
}
}

0 comments on commit 65b89f5

Please sign in to comment.