diff options
Diffstat (limited to 'src/libostree/ostree-repo-pull-private.h')
| -rw-r--r-- | src/libostree/ostree-repo-pull-private.h | 231 |
1 files changed, 110 insertions, 121 deletions
diff --git a/src/libostree/ostree-repo-pull-private.h b/src/libostree/ostree-repo-pull-private.h index 6ee7ba02..982cf1b5 100644 --- a/src/libostree/ostree-repo-pull-private.h +++ b/src/libostree/ostree-repo-pull-private.h @@ -19,159 +19,148 @@ #pragma once -#include "ostree-repo-private.h" #include "ostree-fetcher-util.h" #include "ostree-remote-private.h" +#include "ostree-repo-private.h" G_BEGIN_DECLS -typedef enum { +typedef enum +{ OSTREE_FETCHER_SECURITY_STATE_CA_PINNED, OSTREE_FETCHER_SECURITY_STATE_TLS, OSTREE_FETCHER_SECURITY_STATE_INSECURE, } OstreeFetcherSecurityState; -typedef struct { - OstreeRepo *repo; - int tmpdir_dfd; +typedef struct +{ + OstreeRepo *repo; + int tmpdir_dfd; OstreeRepoPullFlags flags; - char *remote_name; - char *remote_refspec_name; + char *remote_name; + char *remote_refspec_name; OstreeRepoMode remote_mode; OstreeFetcher *fetcher; OstreeFetcherSecurityState fetcher_security_state; - GPtrArray *meta_mirrorlist; /* List of base URIs for fetching metadata */ - GPtrArray *content_mirrorlist; /* List of base URIs for fetching content */ - OstreeRepo *remote_repo_local; - GPtrArray *localcache_repos; /* Array<OstreeRepo> */ + GPtrArray *meta_mirrorlist; /* List of base URIs for fetching metadata */ + GPtrArray *content_mirrorlist; /* List of base URIs for fetching content */ + OstreeRepo *remote_repo_local; + GPtrArray *localcache_repos; /* Array<OstreeRepo> */ - GMainContext *main_context; + GMainContext *main_context; GCancellable *cancellable; OstreeAsyncProgress *progress; - GVariant *extra_headers; - char *append_user_agent; + GVariant *extra_headers; + char *append_user_agent; - gboolean dry_run; - gboolean dry_run_emitted_progress; - gboolean legacy_transaction_resuming; - guint n_network_retries; - enum { + gboolean dry_run; + gboolean dry_run_emitted_progress; + gboolean legacy_transaction_resuming; + guint n_network_retries; + enum + { OSTREE_PULL_PHASE_FETCHING_REFS, OSTREE_PULL_PHASE_FETCHING_OBJECTS - } phase; - gint n_scanned_metadata; - - gboolean gpg_verify; - gboolean gpg_verify_summary; - gboolean require_static_deltas; - gboolean disable_static_deltas; - gboolean has_tombstone_commits; - gboolean disable_verify_bindings; - - GBytes *summary_data; - char *summary_etag; - guint64 summary_last_modified; /* seconds since the epoch */ - GBytes *summary_data_sig; - char *summary_sig_etag; - guint64 summary_sig_last_modified; /* seconds since the epoch */ - GVariant *summary; - GHashTable *summary_deltas_checksums; /* Filled from summary and delta indexes */ - gboolean summary_has_deltas; /* True if the summary existed and had a delta index */ - gboolean has_indexed_deltas; - GHashTable *ref_original_commits; /* Maps checksum to commit, used by timestamp checks */ - GHashTable *verified_commits; /* Set<checksum> of commits that have been verified */ - GHashTable *signapi_verified_commits; /* Map<checksum,verification> of commits that have been signapi verified */ - GHashTable *ref_keyring_map; /* Maps OstreeCollectionRef to keyring remote name */ - GPtrArray *static_delta_superblocks; - GHashTable *expected_commit_sizes; /* Maps commit checksum to known size */ - GHashTable *commit_to_depth; /* Maps parent commit checksum maximum depth */ - GHashTable *scanned_metadata; /* Maps object name to itself */ - GHashTable *fetched_detached_metadata; /* Map<checksum,GVariant> */ - GHashTable *requested_metadata; /* Maps object name to itself */ - GHashTable *requested_content; /* Maps checksum to itself */ - GHashTable *requested_fallback_content; /* Maps checksum to itself */ - GHashTable *pending_fetch_metadata; /* Map<ObjectName,FetchObjectData> */ - GHashTable *pending_fetch_content; /* Map<checksum,FetchObjectData> */ - GHashTable *pending_fetch_delta_indexes; /* Set<FetchDeltaIndexData> */ - GHashTable *pending_fetch_delta_superblocks; /* Set<FetchDeltaSuperData> */ - GHashTable *pending_fetch_deltaparts; /* Set<FetchStaticDeltaData> */ - guint n_outstanding_metadata_fetches; - guint n_outstanding_metadata_write_requests; - guint n_outstanding_content_fetches; - guint n_outstanding_content_write_requests; - guint n_outstanding_deltapart_fetches; - guint n_outstanding_deltapart_write_requests; - guint n_total_deltaparts; - guint n_total_delta_fallbacks; - guint64 fetched_deltapart_size; /* How much of the delta we have now */ - guint64 total_deltapart_size; - guint64 total_deltapart_usize; - gint n_requested_metadata; - gint n_requested_content; - guint n_fetched_deltaparts; - guint n_fetched_deltapart_fallbacks; - guint n_fetched_metadata; - guint n_fetched_content; + } phase; + gint n_scanned_metadata; + + gboolean gpg_verify; + gboolean gpg_verify_summary; + gboolean require_static_deltas; + gboolean disable_static_deltas; + gboolean has_tombstone_commits; + gboolean disable_verify_bindings; + + GBytes *summary_data; + char *summary_etag; + guint64 summary_last_modified; /* seconds since the epoch */ + GBytes *summary_data_sig; + char *summary_sig_etag; + guint64 summary_sig_last_modified; /* seconds since the epoch */ + GVariant *summary; + GHashTable *summary_deltas_checksums; /* Filled from summary and delta indexes */ + gboolean summary_has_deltas; /* True if the summary existed and had a delta index */ + gboolean has_indexed_deltas; + GHashTable *ref_original_commits; /* Maps checksum to commit, used by timestamp checks */ + GHashTable *verified_commits; /* Set<checksum> of commits that have been verified */ + GHashTable *signapi_verified_commits; /* Map<checksum,verification> of commits that have been + signapi verified */ + GHashTable *ref_keyring_map; /* Maps OstreeCollectionRef to keyring remote name */ + GPtrArray *static_delta_superblocks; + GHashTable *expected_commit_sizes; /* Maps commit checksum to known size */ + GHashTable *commit_to_depth; /* Maps parent commit checksum maximum depth */ + GHashTable *scanned_metadata; /* Maps object name to itself */ + GHashTable *fetched_detached_metadata; /* Map<checksum,GVariant> */ + GHashTable *requested_metadata; /* Maps object name to itself */ + GHashTable *requested_content; /* Maps checksum to itself */ + GHashTable *requested_fallback_content; /* Maps checksum to itself */ + GHashTable *pending_fetch_metadata; /* Map<ObjectName,FetchObjectData> */ + GHashTable *pending_fetch_content; /* Map<checksum,FetchObjectData> */ + GHashTable *pending_fetch_delta_indexes; /* Set<FetchDeltaIndexData> */ + GHashTable *pending_fetch_delta_superblocks; /* Set<FetchDeltaSuperData> */ + GHashTable *pending_fetch_deltaparts; /* Set<FetchStaticDeltaData> */ + guint n_outstanding_metadata_fetches; + guint n_outstanding_metadata_write_requests; + guint n_outstanding_content_fetches; + guint n_outstanding_content_write_requests; + guint n_outstanding_deltapart_fetches; + guint n_outstanding_deltapart_write_requests; + guint n_total_deltaparts; + guint n_total_delta_fallbacks; + guint64 fetched_deltapart_size; /* How much of the delta we have now */ + guint64 total_deltapart_size; + guint64 total_deltapart_usize; + gint n_requested_metadata; + gint n_requested_content; + guint n_fetched_deltaparts; + guint n_fetched_deltapart_fallbacks; + guint n_fetched_metadata; + guint n_fetched_content; /* Objects imported via hardlink/reflink/copying or --localcache-repo*/ - guint n_imported_metadata; - guint n_imported_content; - - gboolean timestamp_check; /* Verify commit timestamps */ - char *timestamp_check_from_rev; - int maxdepth; - guint64 max_metadata_size; - guint64 start_time; - - gboolean is_mirror; - gboolean trusted_http_direct; - gboolean is_commit_only; + guint n_imported_metadata; + guint n_imported_content; + + gboolean timestamp_check; /* Verify commit timestamps */ + char *timestamp_check_from_rev; + int maxdepth; + guint64 max_metadata_size; + guint64 start_time; + + gboolean is_mirror; + gboolean trusted_http_direct; + gboolean is_commit_only; OstreeRepoImportFlags importflags; - GPtrArray *signapi_commit_verifiers; - GPtrArray *signapi_summary_verifiers; + GPtrArray *signapi_commit_verifiers; + GPtrArray *signapi_summary_verifiers; - GPtrArray *dirs; + GPtrArray *dirs; - gboolean have_previous_bytes; - guint64 previous_bytes_sec; - guint64 previous_total_downloaded; + gboolean have_previous_bytes; + guint64 previous_bytes_sec; + guint64 previous_total_downloaded; - GError *cached_async_error; - GError **async_error; - gboolean caught_error; + GError *cached_async_error; + GError **async_error; + gboolean caught_error; GQueue scan_object_queue; GSource *idle_src; } OtPullData; -gboolean -_signapi_init_for_remote (OstreeRepo *repo, - const char *remote_name, - GPtrArray **out_commit_verifiers, - GPtrArray **out_summary_verifiers, - GError **error); -gboolean -_sign_verify_for_remote (GPtrArray *signers, - GBytes *signed_data, - GVariant *metadata, - char **out_success_message, - GError **error); - -gboolean -_verify_unwritten_commit (OtPullData *pull_data, - const char *checksum, - GVariant *commit, - GVariant *detached_metadata, - const OstreeCollectionRef *ref, - GCancellable *cancellable, - GError **error); - -gboolean -_process_gpg_verify_result (OtPullData *pull_data, - const char *checksum, - OstreeGpgVerifyResult *result, - GError **error); +gboolean _signapi_init_for_remote (OstreeRepo *repo, const char *remote_name, + GPtrArray **out_commit_verifiers, + GPtrArray **out_summary_verifiers, GError **error); +gboolean _sign_verify_for_remote (GPtrArray *signers, GBytes *signed_data, GVariant *metadata, + char **out_success_message, GError **error); + +gboolean _verify_unwritten_commit (OtPullData *pull_data, const char *checksum, GVariant *commit, + GVariant *detached_metadata, const OstreeCollectionRef *ref, + GCancellable *cancellable, GError **error); + +gboolean _process_gpg_verify_result (OtPullData *pull_data, const char *checksum, + OstreeGpgVerifyResult *result, GError **error); G_END_DECLS |