Commit 7340ee0f authored by Millian Poquet's avatar Millian Poquet

[code] notify EODS -> proper IPP message

parent b625c0a0
......@@ -115,6 +115,8 @@ std::string ip_message_type_to_string(IPMessageType type)
case IPMessageType::KILLING_DONE:
s = "KILLING_DONE";
break;
case IPMessageType::END_DYNAMIC_SUBMIT:
s = "END_DYNAMIC_SUBMIT";
}
return s;
......@@ -226,6 +228,9 @@ IPMessage::~IPMessage()
KillingDoneMessage * msg = (KillingDoneMessage *) data;
delete msg;
} break;
case IPMessageType::END_DYNAMIC_SUBMIT:
{
} break;
}
data = nullptr;
......
......@@ -70,6 +70,7 @@ enum class IPMessageType
,SUBMITTER_BYE //!< Submitter -> Server. The submitter tells it stops submitting to the server.
,SWITCHED_ON //!< SwitcherON -> Server. The switcherON process tells the server the machine pstate has been changed
,SWITCHED_OFF //!< SwitcherOFF -> Server. The switcherOFF process tells the server the machine pstate has been changed.
,END_DYNAMIC_SUBMIT //!< Scheduler -> Server. The scheduler tells the server that dynamic job submissions are finished.
};
/**
......
......@@ -746,10 +746,7 @@ void JsonProtocolReader::handle_notify(int event_number,
string notify_type = notify_type_value.GetString();
if (notify_type == "submission_finished")
{
context->submission_sched_finished = true;
XBT_INFO("Notification received: end of dynamic job submissions");
}
send_message(timestamp, "server", IPMessageType::END_DYNAMIC_SUBMIT);
else
xbt_assert(false, "Unknown NOTIFY type received ('%s').", notify_type.c_str());
......
......@@ -309,7 +309,6 @@ int server_process(int argc, char *argv[])
context->proto_writer->append_job_submitted(job->id, job_json_description,
profile_json_description,
MSG_get_clock());
}
} break; // end of case JOB_SUBMITTED_BY_DP
......@@ -662,6 +661,10 @@ int server_process(int argc, char *argv[])
context->proto_writer->append_simulation_ends(MSG_get_clock());
}
} break; // end of case KILLING_DONE
case IPMessageType::END_DYNAMIC_SUBMIT:
{
context->submission_sched_finished = true;
} // end of case END_DYNAMIC_SUBMIT
} // end of switch
delete task_data;
......
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