|
@@ -79,11 +79,9 @@ impl CashierService {
|
|
|
loop {
|
|
loop {
|
|
|
match recv_queue.recv().await {
|
|
match recv_queue.recv().await {
|
|
|
Ok(msg) => {
|
|
Ok(msg) => {
|
|
|
- let slabstore = self.slabstore.clone();
|
|
|
|
|
let _ = executor
|
|
let _ = executor
|
|
|
.spawn(Self::handle_request(
|
|
.spawn(Self::handle_request(
|
|
|
msg,
|
|
msg,
|
|
|
- slabstore,
|
|
|
|
|
send_queue.clone(),
|
|
send_queue.clone(),
|
|
|
))
|
|
))
|
|
|
.detach();
|
|
.detach();
|
|
@@ -97,7 +95,6 @@ impl CashierService {
|
|
|
}
|
|
}
|
|
|
async fn handle_request(
|
|
async fn handle_request(
|
|
|
msg: (PeerId, Request),
|
|
msg: (PeerId, Request),
|
|
|
- slabstore: Arc<SlabStore>,
|
|
|
|
|
send_queue: async_channel::Sender<(PeerId, Reply)>,
|
|
send_queue: async_channel::Sender<(PeerId, Reply)>,
|
|
|
) -> Result<()> {
|
|
) -> Result<()> {
|
|
|
let request = msg.1;
|
|
let request = msg.1;
|