64 par

deploy/stage/smpcv2-0-stage/values-iris-mpc.yaml

@@ -78,7 +78,7 @@ env:
     value: "even_odd_binary_output_16k"
 
   - name: SMPC__LOAD_CHUNKS_PARALLELISM
-    value: "128"
+    value: "64"
 
   - name: SMPC__CLEAR_DB_BEFORE_INIT
     value: "true"

deploy/stage/smpcv2-1-stage/values-iris-mpc.yaml

@@ -78,7 +78,7 @@ env:
     value: "even_odd_binary_output_16k"
 
   - name: SMPC__LOAD_CHUNKS_PARALLELISM
-    value: "128"
+    value: "64"
 
   - name: SMPC__CLEAR_DB_BEFORE_INIT
     value: "true"

deploy/stage/smpcv2-2-stage/values-iris-mpc.yaml

@@ -78,7 +78,7 @@ env:
     value: "even_odd_binary_output_16k"
 
   - name: SMPC__LOAD_CHUNKS_PARALLELISM
-    value: "128"
+    value: "64"
 
   - name: SMPC__CLEAR_DB_BEFORE_INIT
     value: "true"

iris-mpc/src/bin/server.rs

@@ -735,7 +735,7 @@ async fn resolve_export_bucket_ips(host: String) -> eyre::Result<Vec<IpAddr>> {
     let resolver = TokioAsyncResolver::tokio(ResolverConfig::default(), resolver_opts);
     loop {
         // Check if we've collected enough unique IPs
-        if all_ips.len() >= 30 {
+        if all_ips.len() >= 4 {
             break;
         }
         match resolver.lookup_ip(&host).await {
@@ -790,7 +790,7 @@ async fn server_main(config: Config) -> eyre::Result<()> {
 
     // Increase S3 retries to 5
     let static_resolver = StaticResolver::new(db_chunks_bucket_ips.await?);
-    let _http_client = HyperClientBuilder::new()
+    let http_client = HyperClientBuilder::new()
         .crypto_mode(CryptoMode::Ring)
         .build_with_resolver(static_resolver);
 
@@ -803,7 +803,7 @@ async fn server_main(config: Config) -> eyre::Result<()> {
         // disable stalled stream protection to avoid panics during s3 import
         .stalled_stream_protection(StalledStreamProtectionConfig::disabled())
         .retry_config(retry_config)
-        // .http_client(http_client)
+        .http_client(http_client)
         .build();
 
     let s3_client = Arc::new(S3Client::from_conf(s3_config));