blob: ddc4bafb354fd900a5748c4740c478cbdef3f333 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
//! 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;
}
|
