Skip to content

Commit

Permalink
minor fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
henricasanova committed Nov 21, 2023
1 parent d686bd7 commit 4d5f0c8
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions include/wrench/simgrid_S4U_util/S4U_CommPort.h
Original file line number Diff line number Diff line change
Expand Up @@ -63,14 +63,14 @@ namespace wrench {
std::unique_ptr<TMessageType> getMessage(const std::string &error_prefix = "") {
auto id = ++messageCounter;
#ifndef NDEBUG
auto tn = this->templateWaitingLog(get_type_name<TMessageType>(), id);
this->templateWaitingLog(get_type_name<TMessageType>(), id);
#endif

auto message = this->getMessage(false);

if (auto msg = dynamic_cast<TMessageType *>(message.get())) {
#ifndef NDEBUG
this->templateWaitingLogUpdate(tn, id);
this->templateWaitingLogUpdate(get_type_name<TMessageType>(), id);
#endif
message.release();
return std::unique_ptr<TMessageType>(msg);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -846,7 +846,7 @@ namespace wrench {

auto recv = 0;
while (recv < request_count) {
// Wait for answer to current reqeust
// Wait for answer to current request
auto msg = recv_commport->getMessage<StorageServiceFileWriteAnswerMessage>(this->network_timeout, "CSS::writeFile(): ");
if (not msg->success)
throw ExecutionException(msg->failure_cause);
Expand Down Expand Up @@ -880,7 +880,7 @@ namespace wrench {
}

WRENCH_INFO("CSS::writeFile(): Waiting for final acks");
for (const auto &mailbx_msg: messages) {
for (const auto &mailbox_msg: messages) {
recv_commport->getMessage<StorageServiceAckMessage>("CSS::writeFile(): ");
}
S4U_CommPort::retireTemporaryCommPort(recv_commport);
Expand Down

0 comments on commit 4d5f0c8

Please sign in to comment.