packaging
/
ostree
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

lib/repo-pull: Factor out enqueue function for FetchStaticDeltaData 

This introduces no functional changes, but will make upcoming support
for retrying downloads easier to add.

Signed-off-by: Philip Withnall <withnall@endlessm.com>

Closes: #1599
Approved by: jlebon
This commit is contained in:
Philip Withnall 2018-05-22 12:20:15 +01:00 committed by Atomic Bot
parent dc1fde704d
commit 23d4beead1
1 changed files with 21 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/libostree/ostree-repo-pull.c
View File

@ -226,6 +226,8 @@ static void queue_scan_one_metadata_object_c (OtPullData *pull_da
static void enqueue_one_object_request_s (OtPullData *pull_data, static void enqueue_one_object_request_s (OtPullData *pull_data,
FetchObjectData *fetch_data); FetchObjectData *fetch_data);
static void enqueue_one_static_delta_part_request_s (OtPullData *pull_data,
FetchStaticDeltaData *fetch_data);
static gboolean scan_one_metadata_object (OtPullData *pull_data, static gboolean scan_one_metadata_object (OtPullData *pull_data,
const char *checksum, const char *checksum,
@ -2131,6 +2133,24 @@ process_one_static_delta_fallback (OtPullData *pull_data,
return TRUE; return TRUE;
} }
static void
enqueue_one_static_delta_part_request_s (OtPullData *pull_data,
FetchStaticDeltaData *fetch_data)
{
if (fetcher_queue_is_full (pull_data))
{
g_debug ("queuing fetch of static delta %s-%s part %u",
fetch_data->from_revision ?: "empty",
fetch_data->to_revision, fetch_data->i);
g_hash_table_add (pull_data->pending_fetch_deltaparts, fetch_data);
}
else
{
start_fetch_deltapart (pull_data, fetch_data);
}
}
static void static void
start_fetch_deltapart (OtPullData *pull_data, start_fetch_deltapart (OtPullData *pull_data,
FetchStaticDeltaData *fetch) FetchStaticDeltaData *fetch)
@ -2313,12 +2333,7 @@ process_one_static_delta (OtPullData *pull_data,
} }
else else
{ {
if (!fetcher_queue_is_full (pull_data)) enqueue_one_static_delta_part_request_s (pull_data, g_steal_pointer (&fetch_data));
start_fetch_deltapart (pull_data, fetch_data);
else
{
g_hash_table_add (pull_data->pending_fetch_deltaparts, fetch_data);
}
} }
} }