MCPcopy Index your code
hub / github.com/Firstyear/opensuse-proxy-cache / async_refresh

Function async_refresh

opensuse-proxy-cache/src/main.rs:347–362  ·  view source on GitHub ↗
(
    client: reqwest::Client,
    prefetch_tx: Sender<PrefetchReq>,
    url: &Url,
    submit_tx: &Sender<CacheMeta>,
    file: NamedTempFile,
    obj: &CacheObj<PathBuf, Status>,
    prefetch_paths:

Source from the content-addressed store, hash-verified

345
346#[instrument(skip_all)]
347fn async_refresh(
348 client: reqwest::Client,
349 prefetch_tx: Sender<PrefetchReq>,
350 url: &Url,
351 submit_tx: &Sender<CacheMeta>,
352 file: NamedTempFile,
353 obj: &CacheObj<PathBuf, Status>,
354 prefetch_paths: Option<Vec<PrefetchItem>>,
355) {
356 let u = url.clone();
357 let tx = submit_tx.clone();
358 let obj = obj.clone();
359 tokio::spawn(async move {
360 async_refresh_task(client, prefetch_tx, u, tx, file, obj, prefetch_paths).await
361 });
362}
363
364#[instrument(skip_all)]
365async fn async_refresh_task(

Callers 2

head_viewFunction · 0.85
get_viewFunction · 0.85

Calls 1

async_refresh_taskFunction · 0.85

Tested by

no test coverage detected