diff options
author | Karen Arutyunov <karen@codesynthesis.com> | 2024-05-22 19:34:06 +0300 |
---|---|---|
committer | Karen Arutyunov <karen@codesynthesis.com> | 2024-05-23 15:40:29 +0300 |
commit | 1dfc20c02d3b1076570a7146581799eab0773d6d (patch) | |
tree | 3d08ca9a4ccb69393dc365b0e96563f8d42b93be /mod/ci-common.cxx | |
parent | 3d7f248ee7aa7e5b470cb9bc2fcf76852e798db5 (diff) |
Replace ci_start::abandon() with ci_start::cancel()
Diffstat (limited to 'mod/ci-common.cxx')
-rw-r--r-- | mod/ci-common.cxx | 50 |
1 files changed, 18 insertions, 32 deletions
diff --git a/mod/ci-common.cxx b/mod/ci-common.cxx index 6ce47f2..7c41a7b 100644 --- a/mod/ci-common.cxx +++ b/mod/ci-common.cxx @@ -685,12 +685,13 @@ namespace brep return r; } - void ci_start:: - abandon (const basic_mark& error, - const basic_mark&, - const basic_mark* trace, - odb::core::database& db, - tenant_service&& service) const + optional<tenant_service> ci_start:: + cancel (const basic_mark&, + const basic_mark&, + const basic_mark* trace, + odb::core::database& db, + const string& type, + const string& id) const { using namespace odb::core; @@ -701,37 +702,22 @@ namespace brep using query = query<build_tenant>; shared_ptr<build_tenant> t ( - db.query_one<build_tenant> (query::service.id == service.id && - query::service.type == service.type)); - + db.query_one<build_tenant> (query::service.id == id && + query::service.type == type)); if (t == nullptr) - { - error << "unable to find tenant for service " << service.id << ' ' - << service.type; - - return; - } - else if (!t->unloaded_timestamp) - { - error << "tenant " << t->id << " for service " << service.id << ' ' - << service.type << " is already loaded"; + return nullopt; - return; - } - - // We could probably remove the tenant from the database, but let's just - // archive it and keep for troubleshooting. - // - if (!t->archived) - { - t->archived = true; - db.update (t); - } + optional<tenant_service> r (move (t->service)); + t->service = nullopt; + t->archived = true; + db.update (t); tr.commit (); if (trace != nullptr) - *trace << "unloaded CI request " << t->id << " for service " - << service.id << ' ' << service.type << " is abandoned"; + *trace << "CI request " << t->id << " for service " << id << ' ' << type + << " is canceled"; + + return r; } } |