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

pull: Use a basic exponential moving average for bytes/sec 

Still should look what other downloading programs do, but this
is better then what we had before.
This commit is contained in:
Colin Walters 2012-12-23 14:29:15 -05:00
parent 0ab1f78ec8
commit 3c67c209db
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/ostree/ostree-pull.c
View File

@ -111,6 +111,8 @@ typedef struct {
guint outstanding_filecontent_requests; guint outstanding_filecontent_requests;
guint outstanding_content_stage_requests; guint outstanding_content_stage_requests;
gboolean have_previous_bytes;
guint64 previous_bytes_sec;
guint64 previous_total_downloaded; guint64 previous_total_downloaded;
GError **async_error; GError **async_error;
@ -188,6 +190,7 @@ uri_fetch_update_status (gpointer user_data)
ot_lfree char *fetcher_status; ot_lfree char *fetcher_status;
GString *status; GString *status;
guint64 current_bytes_transferred; guint64 current_bytes_transferred;
guint64 current_delta_bytes_transferred;
guint64 delta_bytes_transferred; guint64 delta_bytes_transferred;
status = g_string_new (""); status = g_string_new ("");
@ -203,7 +206,16 @@ uri_fetch_update_status (gpointer user_data)
g_atomic_int_get (&pull_data->n_requested_content)); g_atomic_int_get (&pull_data->n_requested_content));
current_bytes_transferred = ostree_fetcher_bytes_transferred (pull_data->fetcher); current_bytes_transferred = ostree_fetcher_bytes_transferred (pull_data->fetcher);
delta_bytes_transferred = current_bytes_transferred - pull_data->previous_total_downloaded; current_delta_bytes_transferred = current_bytes_transferred - pull_data->previous_total_downloaded;
if (pull_data->have_previous_bytes)
delta_bytes_transferred = (guint64)(0.5 * current_delta_bytes_transferred + 0.5 * pull_data->previous_bytes_sec);
else
{
pull_data->have_previous_bytes = TRUE;
delta_bytes_transferred = current_delta_bytes_transferred;
}
pull_data->previous_bytes_sec = delta_bytes_transferred;
pull_data->previous_total_downloaded = current_bytes_transferred; pull_data->previous_total_downloaded = current_bytes_transferred;
if (delta_bytes_transferred < 1024) if (delta_bytes_transferred < 1024)