diff options
Diffstat (limited to 'src/storage.c')
| -rw-r--r-- | src/storage.c | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/src/storage.c b/src/storage.c index 5eaf5e7..5df9843 100644 --- a/src/storage.c +++ b/src/storage.c @@ -17,6 +17,7 @@ typedef int (*storage_create_t)(struct storage *, const struct storage_settings typedef void (*storage_destroy_t)(struct storage *); typedef int (*storage_run_create_t)(struct storage *, const char *repo_url, const char *rev); +typedef int (*storage_run_finished_t)(struct storage *, int repo_id, int ec); typedef int (*storage_get_run_queue_t)(struct storage *, struct run_queue *); struct storage_api { @@ -25,6 +26,7 @@ struct storage_api { storage_destroy_t destroy; storage_run_create_t run_create; + storage_run_finished_t run_finished; storage_get_run_queue_t get_run_queue; }; @@ -35,6 +37,7 @@ static const struct storage_api apis[] = { storage_sqlite_destroy, storage_sqlite_run_create, + storage_sqlite_run_finished, storage_sqlite_get_run_queue, }, }; @@ -95,6 +98,14 @@ int storage_run_create(struct storage *storage, const char *repo_url, const char return api->run_create(storage, repo_url, rev); } +int storage_run_finished(struct storage *storage, int run_id, int ec) +{ + const struct storage_api *api = get_api(storage->type); + if (!api) + return -1; + return api->run_finished(storage, run_id, ec); +} + int storage_get_run_queue(struct storage *storage, struct run_queue *queue) { const struct storage_api *api = get_api(storage->type); |