Function dump_sql_with_networking

src/pglite/pg_dump.rs:188–320

(
    addr: SocketAddr,
    options: &PgDumpOptions,
    networking: N,
)

}

fn dump_sql_with_networking<N>(
    addr: SocketAddr,
    options: &PgDumpOptions,
    networking: N,
) -> Result<String>
where
    N: VirtualNetworking + Sync,
{
    options.validate()?;
    let _phase = timing::phase("pg_dump");
    let wasm = {
        let _phase = timing::phase("pg_dump.load_embedded_module");
        assets::pg_dump_wasm()
            .ok_or_else(|| anyhow!("WASIX pg_dump asset is not bundled in this build"))?
    };
    let engine = aot::headless_engine();
    let module = {
        let _phase = timing::phase("pg_dump.load_aot");
        aot::load_pg_dump_module(&engine)?
    };
    let _store = Store::new(engine.clone());

    let fs_root = TempDir::new().context("create pg_dump WASIX filesystem root")?;
    let runtime = {
        let _phase = timing::phase("pg_dump.tokio_runtime");
        tokio::runtime::Builder::new_multi_thread()
            .enable_all()
            .build()
            .context("create Tokio runtime for WASIX pg_dump")?
    };
    let (host_fs, wasix_runtime) = {
        let _phase = timing::phase("pg_dump.wasix_runtime");
        let _runtime_guard = runtime.enter();
        let host_fs = SyncHostFileSystem::new(fs_root.path()).with_context(|| {
            format!(
                "create host filesystem rooted at {}",
                fs_root.path().display()
            )
        })?;
        let host_fs = Arc::new(host_fs) as Arc<dyn virtual_fs::FileSystem + Send + Sync>;
        let mut wasix_runtime = PluggableRuntime::new(Arc::new(TokioTaskManager::new(
            tokio::runtime::Handle::current(),
        )));
        wasix_runtime.set_engine(engine.clone());
        wasix_runtime.set_networking_implementation(networking);
        (host_fs, wasix_runtime)
    };

    let output_path = "/host/out.sql";
    let port = addr.port().to_string();
    let host = match addr {
        SocketAddr::V4(addr) => addr.ip().to_string(),
        SocketAddr::V6(addr) => addr.ip().to_string(),
    };
    let mut args = options.args.clone();
    args.extend([
        "-U".to_owned(),
        options.username.clone(),