Skip to content

Commit

Permalink
Update naming.
Browse files Browse the repository at this point in the history
  • Loading branch information
PLeVasseur committed Apr 5, 2024
1 parent 3fd1670 commit 87f9926
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions up-streamer/src/ustreamer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ const USTREAMER_FN_NEW_TAG: &str = "new():";
const USTREAMER_FN_ADD_FORWARDING_RULE_TAG: &str = "add_forwarding_rule():";
const USTREAMER_FN_DELETE_FORWARDING_RULE_TAG: &str = "delete_forwarding_rule():";

type RegisteredForwardingRules = Arc<
type ForwardingRules = Arc<
Mutex<
HashMap<
(
Expand All @@ -41,7 +41,7 @@ type RegisteredForwardingRules = Arc<
>,
>;
type TransportForwarderCount = Arc<Mutex<HashMap<ComparableTransport, usize>>>;
type TransportForwarderMap =
type TransportForwarders =
Arc<Mutex<HashMap<ComparableTransport, (TransportForwarder, Sender<Arc<UMessage>>)>>>;

/// A [`UStreamer`] is used to coordinate the addition and deletion of forwarding rules between
Expand Down Expand Up @@ -223,8 +223,8 @@ type TransportForwarderMap =
pub struct UStreamer {
#[allow(dead_code)]
name: String,
registered_forwarding_rules: RegisteredForwardingRules,
transport_forwarders: TransportForwarderMap,
registered_forwarding_rules: ForwardingRules,
transport_forwarders: TransportForwarders,
transport_forwarder_count: TransportForwarderCount,
message_queue_size: usize,
}
Expand Down

0 comments on commit 87f9926

Please sign in to comment.