Skip to content

Commit

Permalink
revert commented out load to actor part
Browse files Browse the repository at this point in the history
  • Loading branch information
eaypek-tfh committed Jan 21, 2025
1 parent e36e7d3 commit c85c402
Show file tree
Hide file tree
Showing 4 changed files with 24 additions and 24 deletions.
4 changes: 2 additions & 2 deletions deploy/stage/smpcv2-0-stage/values-iris-mpc.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -81,13 +81,13 @@ env:
value: "64"

- name: SMPC__LOAD_CHUNKS_DEFAULT_CLIENT
value: "true"
value: "false"

- name: SMPC__LOAD_CHUNKS_BUFFER_SIZE
value: "4096"

- name: SMPC__LOAD_CHUNKS_STATIC_IPS
value: "4"
value: "16"

- name: SMPC__CLEAR_DB_BEFORE_INIT
value: "true"
Expand Down
4 changes: 2 additions & 2 deletions deploy/stage/smpcv2-1-stage/values-iris-mpc.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -81,13 +81,13 @@ env:
value: "64"

- name: SMPC__LOAD_CHUNKS_DEFAULT_CLIENT
value: "true"
value: "false"

- name: SMPC__LOAD_CHUNKS_BUFFER_SIZE
value: "4096"

- name: SMPC__LOAD_CHUNKS_STATIC_IPS
value: "4"
value: "16"

- name: SMPC__CLEAR_DB_BEFORE_INIT
value: "true"
Expand Down
4 changes: 2 additions & 2 deletions deploy/stage/smpcv2-2-stage/values-iris-mpc.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -81,13 +81,13 @@ env:
value: "64"

- name: SMPC__LOAD_CHUNKS_DEFAULT_CLIENT
value: "true"
value: "false"

- name: SMPC__LOAD_CHUNKS_BUFFER_SIZE
value: "4096"

- name: SMPC__LOAD_CHUNKS_STATIC_IPS
value: "4"
value: "16"

- name: SMPC__CLEAR_DB_BEFORE_INIT
value: "true"
Expand Down
36 changes: 18 additions & 18 deletions iris-mpc/src/bin/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1262,13 +1262,13 @@ async fn server_main(config: Config) -> eyre::Result<()> {
StoredIris::DB(iris) => {
n_loaded_from_db += 1;
serial_ids_from_db.insert(iris.id());
// actor.load_single_record_from_db(
// iris.index() - 1,
// iris.left_code(),
// iris.left_mask(),
// iris.right_code(),
// iris.right_mask(),
// );
actor.load_single_record_from_db(
iris.index() - 1,
iris.left_code(),
iris.left_mask(),
iris.right_code(),
iris.right_mask(),
);
}
StoredIris::S3(iris) => {
if serial_ids_from_db.contains(&iris.id()) {
Expand All @@ -1280,17 +1280,17 @@ async fn server_main(config: Config) -> eyre::Result<()> {
continue;
}
n_loaded_from_s3 += 1;
// actor.load_single_record_from_s3(
// iris.index() - 1,
// iris.left_code_odd(),
// iris.left_code_even(),
// iris.right_code_odd(),
// iris.right_code_even(),
// iris.left_mask_odd(),
// iris.left_mask_even(),
// iris.right_mask_odd(),
// iris.right_mask_even(),
// );
actor.load_single_record_from_s3(
iris.index() - 1,
iris.left_code_odd(),
iris.left_code_even(),
iris.right_code_odd(),
iris.right_code_even(),
iris.left_mask_odd(),
iris.left_mask_even(),
iris.right_mask_odd(),
iris.right_mask_even(),
);
}
};

Expand Down

0 comments on commit c85c402

Please sign in to comment.