Page MenuHomePhabricator
Files F2835750

D5010.id16442.diff
No OneTemporary
Actions

D5010.id16442.diff
View Options

diff --git a/services/backup/blob_client/src/put_client.rs b/services/backup/blob_client/src/put_client.rs
--- a/services/backup/blob_client/src/put_client.rs
+++ b/services/backup/blob_client/src/put_client.rs
@@ -176,7 +176,28 @@
}
pub fn put_client_blocking_read_cxx() -> Result<String, String> {
- unimplemented!();
+ check_error()?;
+ let response: Option<String> = RUNTIME.block_on(async {
+ if let Ok(mut maybe_client) = CLIENT.lock() {
+ if let Some(mut client) = (*maybe_client).take() {
+ if let Some(data) = client.rx.recv().await {
+ return Some(data);
+ } else {
+ report_error(
+ "couldn't receive data via client's receiver".to_string(),
+ );
+ }
+ *maybe_client = Some(client);
+ } else {
+ report_error("no client detected".to_string());
+ }
+ } else {
+ report_error("couldn't access client".to_string());
+ }
+ None
+ });
+ check_error()?;
+ response.ok_or("response not received properly".to_string())
}
/**

File Metadata

Mime Type
text/plain
Expires
Sun, Sep 29, 2:30 PM (22 h, 8 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2200481
Default Alt Text
D5010.id16442.diff (1 KB)

Event Timeline