Mise à jour terminée. Pour connaître les apports de la version 13.8.4 par rapport à notre ancienne version vous pouvez lire les "Release Notes" suivantes :
https://about.gitlab.com/releases/2021/02/11/security-release-gitlab-13-8-4-released/
https://about.gitlab.com/releases/2021/02/05/gitlab-13-8-3-released/

Commit 194c2131 authored by Millian Poquet's avatar Millian Poquet

Output is now flushed when connection is broken.

parent 028b39c8
......@@ -224,6 +224,7 @@ int main(int argc, char * argv[])
BatsimContext context;
context.platform_filename = mainArgs.platformFilename;
context.workload_filename = mainArgs.workloadFilename;
context.export_prefix = mainArgs.exportPrefix;
context.energy_used = mainArgs.energy_used;
context.allow_space_sharing = mainArgs.allow_space_sharing;
context.trace_schedule = mainArgs.enable_schedule_tracing;
......@@ -294,6 +295,4 @@ int main(int argc, char * argv[])
return 0;
else
return 1;
return 0;
}
......@@ -25,4 +25,5 @@ struct BatsimContext
bool trace_schedule;
std::string platform_filename;
std::string workload_filename;
std::string export_prefix;
};
......@@ -292,6 +292,7 @@ void PajeTracer::finalize(BatsimContext * context, double time)
"%d %lf %s %s\n",
DESTROY_CONTAINER, time, root, rootType);
_wbuf->appendText(buf);
_wbuf->flushBuffer();
state = FINALIZED;
}
......
......@@ -146,9 +146,27 @@ int request_reply_scheduler_process(int argc, char *argv[])
context->socket.send(sendBuf);
auto start = chrono::steady_clock::now();
string message_received = context->socket.receive();
auto end = chrono::steady_clock::now();
string message_received;
try
{
message_received = context->socket.receive();
}
catch(const std::runtime_error & error)
{
XBT_INFO("Runtime error received: %s", error.what());
XBT_INFO("Flushing output files...");
if (context->trace_schedule)
context->paje_tracer.finalize(context, MSG_get_clock());
exportScheduleToCSV(context->export_prefix + "_schedule.csv", MSG_get_clock(), context);
exportJobsToCSV(context->export_prefix + "_jobs.csv", context);
XBT_INFO("Output files flushed. Aborting execution now.");
throw runtime_error("Execution aborted (connection broken)");
}
auto end = chrono::steady_clock::now();
long long elapsed_microseconds = chrono::duration <double, micro> (end - start).count();
context->microseconds_used_by_scheduler += elapsed_microseconds;
......
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