blob: 4dabacddea323845c24d36183fd5ef01e7d2c3d3 (
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
|
//! This module contains a WIP relay tunnel reactor.
//!
//! The initial version will duplicate some of the logic from
//! the client tunnel reactor.
//!
//! TODO(relay): refactor the relay tunnel
//! to share the same base tunnel implementation
//! as the client tunnel (to reduce code duplication).
//!
//! See the design notes at doc/dev/notes/relay-reactor.md
pub(crate) mod channel;
#[allow(unreachable_pub)] // TODO(relay): use in tor-chanmgr(?)
pub mod channel_provider;
pub(crate) mod reactor;
use futures::channel::mpsc;
use reactor::{RelayCtrlCmd, RelayCtrlMsg};
/// A handle for interacting with a relay circuit.
#[allow(unused)] // TODO(relay)
pub struct RelayCirc {
/// Sender for reactor control messages.
control: mpsc::UnboundedSender<RelayCtrlMsg>,
/// Sender for reactor control commands.
command: mpsc::UnboundedSender<RelayCtrlCmd>,
}
impl RelayCirc {
/// Return true if this circuit is closed and therefore unusable.
pub fn is_closing(&self) -> bool {
self.control.is_closed()
}
}
|
