rarias/ovni
rarias/ovni
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Skip repeated hostnames in ovnisync

Browse Source
This commit is contained in:
Rodrigo Arias 2023-04-06 17:52:28 +02:00
parent 9e105413fd
commit 80b8b209fa
1 changed files with 14 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
src/emu/ovnisync.c
View File

@ -364,32 +364,25 @@ print_drift_row(FILE *out, struct offset_table *table)
static void static void
print_table_detailed(FILE *out, struct offset_table *table) print_table_detailed(FILE *out, struct offset_table *table)
{ {
int fail = 0;
/* Ensure each hostname is unique */
for (int i = 0; i < table->nprocs; i++) {
struct offset *a = table->offset[i];
for (int j = 0; j < i; j++) {
struct offset *b = table->offset[j];
if (strcmp(a->hostname, b->hostname) == 0) {
fprintf(stderr, "FATAL: ranks %d and %d run in same hostname %s\n",
j, i, a->hostname);
fail = 1;
}
}
}
if (fail) {
fprintf(stderr, "Please run %s with one rank per host\n", progname);
exit(EXIT_FAILURE);
}
fprintf(out, "%-10s %-20s %-20s %-20s %-20s\n", fprintf(out, "%-10s %-20s %-20s %-20s %-20s\n",
"rank", "hostname", "offset_median", "offset_mean", "offset_std"); "rank", "hostname", "offset_median", "offset_mean", "offset_std");
for (int i = 0; i < table->nprocs; i++) { for (int i = 0; i < table->nprocs; i++) {
struct offset *offset = table->offset[i]; struct offset *offset = table->offset[i];
/* Skip the entry if hostname was repeated */
int skip = 0;
for (int j = 0; j < i; j++) {
struct offset *b = table->offset[j];
if (strcmp(offset->hostname, b->hostname) == 0) {
skip = 1;
break;
}
}
if (skip)
continue;
fprintf(out, "%-10d %-20s %-20ld %-20f %-20f\n", fprintf(out, "%-10d %-20s %-20ld %-20f %-20f\n",
i, offset->hostname, offset->offset, i, offset->hostname, offset->offset,
offset->delta_mean, offset->delta_std); offset->delta_mean, offset->delta_std);