diff options
Diffstat (limited to 'mod/mod-ci-github.cxx')
| -rw-r--r-- | mod/mod-ci-github.cxx | 45 |
1 files changed, 31 insertions, 14 deletions
diff --git a/mod/mod-ci-github.cxx b/mod/mod-ci-github.cxx index e04570e..64ab9c5 100644 --- a/mod/mod-ci-github.cxx +++ b/mod/mod-ci-github.cxx @@ -1302,7 +1302,7 @@ namespace brep function<optional<string> (const string& tenant_id, const tenant_service&)> ci_github:: - build_unloaded (const string& /*tenant_id*/, + build_unloaded (const string& ti, tenant_service&& ts, const diag_epilogue& log_writer) const noexcept { @@ -1322,8 +1322,8 @@ namespace brep } return sd.pre_check - ? build_unloaded_pre_check (move (ts), move (sd), log_writer) - : build_unloaded_load (move (ts), move (sd), log_writer); + ? build_unloaded_pre_check (move (ts), move (sd), log_writer) + : build_unloaded_load (ti, move (ts), move (sd), log_writer); } function<optional<string> (const string& tenant_id, @@ -1529,7 +1529,8 @@ namespace brep function<optional<string> (const string& tenant_id, const tenant_service&)> ci_github:: - build_unloaded_load (tenant_service&& ts, + build_unloaded_load (const string& ti, + tenant_service&& ts, service_data&& sd, const diag_epilogue& log_writer) const noexcept try @@ -1731,15 +1732,19 @@ namespace brep return nullptr; // Nothing to save (but potentially retry on next call). return [&error, + ti, iat = move (new_iat), cni = move (conclusion_node_id)] - (const string& /*tenant_id*/, + (const string& tenant_id, const tenant_service& ts) -> optional<string> { // NOTE: this lambda may be called repeatedly (e.g., due to // transaction being aborted) and so should not move out of its // captures. + if (tenant_id != ti) + return nullopt; // Do nothing if the tenant has been replaced. + service_data sd; try { @@ -1873,7 +1878,7 @@ namespace brep // function<optional<string> (const string& tenant_id, const tenant_service&)> ci_github:: - build_queued (const string& /*tenant_id*/, + build_queued (const string& ti, const tenant_service& ts, const vector<build>& builds, optional<build_state> istate, @@ -1999,16 +2004,20 @@ namespace brep } } - return [bs = move (bs), + return [ti, + bs = move (bs), iat = move (new_iat), crs = move (crs), error = move (error), - warn = move (warn)] (const string& /*tenant_id*/, + warn = move (warn)] (const string& tenant_id, const tenant_service& ts) -> optional<string> { // NOTE: this lambda may be called repeatedly (e.g., due to transaction // being aborted) and so should not move out of its captures. + if (tenant_id != ti) + return nullopt; // Do nothing if the tenant has been replaced. + service_data sd; try { @@ -2059,7 +2068,7 @@ namespace brep function<optional<string> (const string& tenant_id, const tenant_service&)> ci_github:: - build_building (const string& /*tenant_id*/, + build_building (const string& ti, const tenant_service& ts, const build& b, const diag_epilogue& log_writer) const noexcept @@ -2167,15 +2176,19 @@ namespace brep } } - return [iat = move (new_iat), + return [ti, + iat = move (new_iat), cr = move (*cr), error = move (error), - warn = move (warn)] (const string& /*tenant_id*/, + warn = move (warn)] (const string& tenant_id, const tenant_service& ts) -> optional<string> { // NOTE: this lambda may be called repeatedly (e.g., due to transaction // being aborted) and so should not move out of its captures. + if (tenant_id != ti) + return nullopt; // Do nothing if the tenant has been replaced. + service_data sd; try { @@ -2223,7 +2236,7 @@ namespace brep function<optional<string> (const string& tenant_id, const tenant_service&)> ci_github:: - build_built (const string& /*tenant_id*/, + build_built (const string& ti, const tenant_service& ts, const build& b, const diag_epilogue& log_writer) const noexcept @@ -2548,16 +2561,20 @@ namespace brep } } - return [iat = move (new_iat), + return [ti, + iat = move (new_iat), cr = move (cr), completed = completed, error = move (error), - warn = move (warn)] (const string& /*tenant_id*/, + warn = move (warn)] (const string& tenant_id, const tenant_service& ts) -> optional<string> { // NOTE: this lambda may be called repeatedly (e.g., due to transaction // being aborted) and so should not move out of its captures. + if (tenant_id != ti) + return nullopt; // Do nothing if the tenant has been replaced. + service_data sd; try { |