Lines
0 %
Functions
Branches
100 %
//! Implementations for methods on Connection.
use derive_deftly::Deftly;
use std::sync::Arc;
use tor_rpcbase::{self as rpc, templates::*};
use super::Connection;
/// Cancel a single request.
///
/// Note that calling this method does not guarantee that the request is actually cancelled:
/// the request might finish first.
/// What we do guarantee is that either this method returns successfully and the request is cancelled,
/// or that this method fails and the request is not cancelled.
/// We also guarantee that both the request and this method will finish "fairly quickly"
/// after this method is called.
/// In Arti's current implementation, a cancel request is itself is not cancellable.
/// For more information see `rpc-meta-draft.md`.
#[derive(Debug, serde::Deserialize, Deftly)]
#[derive_deftly(DynMethod)]
#[deftly(rpc(method_name = "rpc:cancel", no_cancel))]
struct RpcCancel {
/// The ID for the request that we should try to cancel.
request_id: crate::msgs::RequestId,
}
impl rpc::RpcMethod for RpcCancel {
type Output = rpc::Nil;
type Update = rpc::NoUpdates;
/// Implement `RpcCancel` on a connection.
async fn connection_rpc_cancel(
conn: Arc<Connection>,
cancel: Box<RpcCancel>,
_ctx: Arc<dyn rpc::Context>,
) -> Result<rpc::Nil, super::CancelError> {
conn.cancel_request(&cancel.request_id).map(|()| rpc::NIL)
rpc::static_rpc_invoke_fn! {
connection_rpc_cancel;