Page MenuHomePhabricator
Files F3500471

D4413.id14081.diff
No OneTemporary
Actions

D4413.id14081.diff
View Options

diff --git a/services/commtest/tests/backup/add_attachments.rs b/services/commtest/tests/backup/add_attachments.rs
--- a/services/commtest/tests/backup/add_attachments.rs
+++ b/services/commtest/tests/backup/add_attachments.rs
@@ -24,13 +24,13 @@
let log_id = backup_data.log_items[index].id.clone();
println!("add attachments for log {}/{}", index, log_id);
log_id
- },
+ }
None => {
println!("add attachments for backup");
String::new()
- },
+ }
};
-
+
let holders: String = match log_index {
Some(log_index) => backup_data.log_items[log_index]
.attachments_holders
diff --git a/services/commtest/tests/backup/pull_backup.rs b/services/commtest/tests/backup/pull_backup.rs
--- a/services/commtest/tests/backup/pull_backup.rs
+++ b/services/commtest/tests/backup/pull_backup.rs
@@ -50,18 +50,15 @@
let mut backup_id: Option<String> = None;
let mut log_id: Option<String> = None;
match id {
- Some(BackupId(id)) => {
- backup_id = Some(id)
- },
- Some(LogId(id)) => {
- log_id = Some(id)
- },
- None => {},
+ Some(BackupId(id)) => backup_id = Some(id),
+ Some(LogId(id)) => log_id = Some(id),
+ None => {}
};
match response_data {
Some(CompactionChunk(chunk)) => {
assert_eq!(
- state, State::Compaction,
+ state,
+ State::Compaction,
"invalid state, expected compaction, got {:?}",
state
);
@@ -80,9 +77,11 @@
assert_eq!(state, State::Log, "invalid state, expected compaction");
let log_id = log_id.expect("log id expected but not received");
if log_id != current_id {
- result
- .log_items
- .push(Item::new(log_id.clone(), Vec::new(), Vec::new()));
+ result.log_items.push(Item::new(
+ log_id.clone(),
+ Vec::new(),
+ Vec::new(),
+ ));
current_id = log_id;
}
let log_items_size = result.log_items.len() - 1;
@@ -119,7 +118,7 @@
}
}
}
- None => {},
+ None => {}
}
}
Ok(result)
diff --git a/services/commtest/tests/backup_test.rs b/services/commtest/tests/backup_test.rs
--- a/services/commtest/tests/backup_test.rs
+++ b/services/commtest/tests/backup_test.rs
@@ -21,7 +21,8 @@
#[tokio::test]
async fn backup_test() -> Result<(), Error> {
- let port = env::var("COMM_SERVICES_PORT_BACKUP").expect("port env var expected but not received");
+ let port = env::var("COMM_SERVICES_PORT_BACKUP")
+ .expect("port env var expected but not received");
let mut client =
BackupServiceClient::connect(format!("http://localhost:{}", port)).await?;
@@ -45,15 +46,25 @@
// In this case its data should be moved to the S3
Item::new(
String::new(),
- vec![tools::get_dynamo_db_item_size_limit() - ByteSize::b(attachments_fill_size/2).as_u64() as usize],
+ vec![
+ tools::get_dynamo_db_item_size_limit()
+ - ByteSize::b(attachments_fill_size / 2).as_u64() as usize,
+ ],
vec!["holder0".to_string(), "holder1".to_string()],
),
// just a small item
- Item::new(String::new(), vec![ByteSize::b(100).as_u64() as usize], vec!["holder0".to_string()]),
+ Item::new(
+ String::new(),
+ vec![ByteSize::b(100).as_u64() as usize],
+ vec!["holder0".to_string()],
+ ),
// a big item that should be placed in the S3 right away
Item::new(
String::new(),
- vec![tools::get_grpc_chunk_size_limit(), tools::get_grpc_chunk_size_limit()],
+ vec![
+ tools::get_grpc_chunk_size_limit(),
+ tools::get_grpc_chunk_size_limit(),
+ ],
vec![
"holder0".to_string(),
"holder1".to_string(),
@@ -100,8 +111,7 @@
assert_eq!(
expected, from_result,
"number of logs do not match, expected {}, got {}",
- expected,
- from_result
+ expected, from_result
);
// check log sizes
@@ -111,9 +121,7 @@
assert_eq!(
from_result, expected,
"log number {} sizes do not match, expected {}, got {}",
- i,
- expected,
- from_result
+ i, expected, from_result
);
}
diff --git a/services/commtest/tests/blob_test.rs b/services/commtest/tests/blob_test.rs
--- a/services/commtest/tests/blob_test.rs
+++ b/services/commtest/tests/blob_test.rs
@@ -17,8 +17,10 @@
#[tokio::test]
async fn blob_test() -> Result<(), Error> {
- let port = env::var("COMM_SERVICES_PORT_BLOB").expect("port env var expected but not received");
- let mut client = BlobServiceClient::connect(format!("http://localhost:{}", port)).await?;
+ let port = env::var("COMM_SERVICES_PORT_BLOB")
+ .expect("port env var expected but not received");
+ let mut client =
+ BlobServiceClient::connect(format!("http://localhost:{}", port)).await?;
let blob_data = vec![
BlobData {

File Metadata

Mime Type
text/plain
Expires
Sat, Dec 21, 1:42 AM (16 h, 31 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2684525
Default Alt Text
D4413.id14081.diff (4 KB)

Event Timeline