D4867.id16065.diff
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

D4867.id16065.diff
View Options

	diff --git a/services/backup/rust_lib/src/lib.rs b/services/backup/rust_lib/src/lib.rs
	--- a/services/backup/rust_lib/src/lib.rs
	+++ b/services/backup/rust_lib/src/lib.rs
	@@ -8,13 +8,16 @@
	}
	}

	-use lazy_static::lazy_static;
	-use libc;
	-use libc::c_char;
	-use std::sync::{Arc, Mutex};
	+mod constants;
	+
	+use constants::MPSC_CHANNEL_BUFFER_CAPACITY;
	use tokio::runtime::Runtime;
	use tokio::sync::mpsc;
	use tokio::task::JoinHandle;
	+use lazy_static::lazy_static;
	+use std::sync::{Arc, Mutex};
	+use libc;
	+use libc::c_char;

	pub struct Client {
	tx: Option<mpsc::Sender<String>>,
	@@ -40,7 +43,20 @@
	}

	pub fn rust_initialize_cxx() -> () {
	- unimplemented!();
	+ println!("[RUST] initializing");
	+ assert!(!rust_is_initialized_cxx(), "client cannot be initialized twice");
	+ let (tx, mut rx): (mpsc::Sender<String>, mpsc::Receiver<String>) =
	+ mpsc::channel(MPSC_CHANNEL_BUFFER_CAPACITY);
	+ let handle = RUNTIME.spawn(async move {
	+ println!("[RUST] [receiver] begin");
	+ while let Some(data) = rx.recv().await {
	+ println!("[RUST] [receiver] data: {}", data);
	+ }
	+ println!("[RUST] [receiver] done");
	+ });
	+ CLIENT.lock().expect("access client").handle = Some(handle);
	+ CLIENT.lock().expect("access client").tx = Some(tx);
	+ println!("[RUST] initialized");
	}

	pub fn rust_process_cxx(_: *const c_char) -> () {