diff options
Diffstat (limited to 'bbot/agent.cxx')
| -rw-r--r-- | bbot/agent.cxx | 48 |
1 files changed, 27 insertions, 21 deletions
diff --git a/bbot/agent.cxx b/bbot/agent.cxx index ac4905d..234763f 100644 --- a/bbot/agent.cxx +++ b/bbot/agent.cxx @@ -8,7 +8,7 @@ #include <limits.h> // PATH_MAX #include <signal.h> // signal() #include <stdlib.h> // rand_r() -#include <unistd.h> // sleep(), realink(), getuid() +#include <unistd.h> // sleep(), realink(), getuid(), fsync() #include <net/if.h> // ifreq #include <netinet/in.h> // sockaddr_in @@ -53,6 +53,14 @@ namespace bbot string uname; } +static void +file_sync (const path& f) +{ + auto_fd fd (fdopen (f, fdopen_mode::in)); + if (fsync (fd.get ()) != 0) + throw_system_error (errno); +} + // The btrfs tool likes to print informational messages, like "Created // snapshot such and such". Luckily, it writes them to stdout while proper // diagnostics to stderr. @@ -211,20 +219,21 @@ bootstrap_machine (const dir_path& md, // our side we serve TFTP requests while periodically checking for the // manifest file. // - for (to = bootstrap_to; - to != 0 && (!file_exists (mf) || file_empty (mf)); - tftpd.serve (to)) ; + for (to = bootstrap_to; to != 0; tftpd.serve (to)) + { + if (file_exists (mf)) + { + file_sync (mf); + if (!file_empty (mf)) + break; + } + } if (to == 0) return soft_fail ("bootstrap timeout"); l3 ([&]{trace << "completed bootstrap in " << bootstrap_to - to << "s";}); - // The file may have been created but not yet (completely) uploaded. - // So we wait for a one second window without any TFTP activity. - // - while (tftpd.serve ((to = 1))) ; - // Shut the machine down cleanly. // if (!m->shutdown ((to = shutdown_to))) @@ -693,24 +702,21 @@ try // So on our side we serve TFTP requests while checking for the // manifest file. // - // There are seem to be some "anomalies" in the Windows network stack - // in that we get an empty file and then the upload process gets stuck - // for no apparent reason. - // - for (to = build_to; - to != 0 && (!file_exists (rf) || file_empty (rf)); - tftpd.serve (to)) ; + for (to = build_to; to != 0; tftpd.serve (to)) + { + if (file_exists (rf)) + { + file_sync (rf); + if (!file_empty (rf)) + break; + } + } if (to == 0) return soft_fail ("build timeout"); l3 ([&]{trace << "completed build in " << build_to - to << "s";}); - // The file may have been created but not yet (completely) uploaded. - // So we wait for a one second window without any TFTP activity. - // - while (tftpd.serve ((to = 1))) ; - // Parse the result manifest. // try |