Skip to content

Commit

Permalink
cleanup other logs
Browse files Browse the repository at this point in the history
  • Loading branch information
bcherry committed Oct 8, 2024
1 parent 817d301 commit 29fc1b5
Showing 1 changed file with 1 addition and 10 deletions.
11 changes: 1 addition & 10 deletions livekit-ffi/src/server/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -245,19 +245,10 @@ impl FfiServer {
}

pub fn store_rpc_response_sender(&self, invocation_id: u64, sender: oneshot::Sender<Result<String, RpcError>>) {
log::warn!("FfiServer::store_rpc_response_sender - Storing sender for invocation_id: {}", invocation_id);
self.rpc_response_senders.lock().insert(invocation_id, sender);
log::warn!("FfiServer::store_rpc_response_sender - Sender stored successfully for invocation_id: {}", invocation_id);
}

pub fn take_rpc_response_sender(&self, invocation_id: u64) -> Option<oneshot::Sender<Result<String, RpcError>>> {
log::warn!("FfiServer::take_rpc_response_sender - Attempting to take sender for invocation_id: {}", invocation_id);
let result = self.rpc_response_senders.lock().remove(&invocation_id);
if result.is_some() {
log::warn!("FfiServer::take_rpc_response_sender - Sender found and removed for invocation_id: {}", invocation_id);
} else {
log::warn!("FfiServer::take_rpc_response_sender - No sender found for invocation_id: {}", invocation_id);
}
result
return self.rpc_response_senders.lock().remove(&invocation_id);
}
}

0 comments on commit 29fc1b5

Please sign in to comment.