Skip to content

Commit

Permalink
debugging
Browse files Browse the repository at this point in the history
  • Loading branch information
henricasanova committed Dec 20, 2023
1 parent 4422ede commit cec3852
Show file tree
Hide file tree
Showing 4 changed files with 2 additions and 5 deletions.
1 change: 0 additions & 1 deletion src/wrench/action/FileWriteAction.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,6 @@ namespace wrench {
// Thread overhead
Simulation::sleep(action_executor->getThreadCreationOverhead());
// Fix location if scratch
WRENCH_INFO("FILE WRITE: %s", this->file_location->getFile()->getID().c_str());
if (this->file_location->isScratch()) {
auto cs = std::dynamic_pointer_cast<ComputeService>(action_executor->getActionExecutionService()->getParentService());
this->file_location = FileLocation::LOCATION(cs->getScratch(), cs->getScratch()->getBaseRootPath() + this->getJob()->getName(), this->file_location->getFile());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,6 @@ namespace wrench {
*/
void BareMetalComputeService::cleanup(bool has_returned_from_main, int return_value) {
// Do the default behavior (which will throw as this is not a fault-tolerant service)
std::cerr << "IN BARED METAL COMPUTE SERVICE CLEANUP\n";
Service::cleanup(has_returned_from_main, return_value);

this->action_execution_service = nullptr;// to avoid leak due to circular refs
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -116,7 +116,7 @@ namespace wrench {
WRENCH_INFO("Compacting schedule...");

#ifdef PRINT_SCHEDULE
WRENCH_INFO("BEFORE COMPACTING");
// WRENCH_INFO("BEFORE COMPACTING");
this->schedule->print();
#endif

Expand Down
3 changes: 1 addition & 2 deletions src/wrench/simgrid_S4U_util/S4U_CommPort.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ namespace wrench {
* @brief Reset all communication
*/
void S4U_CommPort::reset() {
std::cerr << "RESETTING COMMPORT " << this->name << "\n";
// std::cerr << "RESETTING COMMPORT " << this->name << "\n";
this->mq_comm = nullptr;
this->mq_comm_posted = false;
this->mb_comm = nullptr;
Expand Down Expand Up @@ -237,7 +237,6 @@ namespace wrench {
this->s4u_mq->put(msg);
} catch (simgrid::TimeoutException &e) {
// Can happen if the other side is doing a timeout.... I think
std::cerr << "THROWING HERE\n";
throw ExecutionException(std::make_shared<NetworkError>(
NetworkError::SENDING, NetworkError::TIMEOUT, this->s4u_mb->get_name(), msg->getName()));
} catch (simgrid::Exception &e) {
Expand Down

0 comments on commit cec3852

Please sign in to comment.