Skip to content

Commit

Permalink
put the simple data types into tuple to avoid clippy warning on too m…
Browse files Browse the repository at this point in the history
…any arguments
  • Loading branch information
lucasw committed Sep 29, 2024
1 parent e90dfce commit f7b29e3
Showing 1 changed file with 4 additions and 6 deletions.
10 changes: 4 additions & 6 deletions mcap_tools/src/mcap_record.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,15 +23,15 @@ fn rename_active(mcap_name: &str) -> std::io::Result<()> {

// start all the threads
async fn mcap_record(
full_node_name: String,
prefix: String,
name_prefix_size: (String, String, u64),
channel_receiver: mpsc::Receiver<(String, String, String)>,
connection_summaries: Arc<Mutex<HashMap<String, BTreeMap<String, String>>>>,
msg_receiver: mpsc::Receiver<(String, String, u64, u32, Vec<u8>)>,
finish: Arc<AtomicBool>,
num_received_messages: Arc<AtomicUsize>,
size_limit: u64,
) -> Result<(), anyhow::Error> {
let (full_node_name, prefix, size_limit) = name_prefix_size;

// schemas should be able to persist across mcap file boundaries
let schemas = Arc::new(Mutex::new(HashMap::new()));

Expand Down Expand Up @@ -385,14 +385,12 @@ async fn main() -> Result<(), anyhow::Error> {
};

let _ = mcap_record(
full_node_name,
prefix.to_string(),
(full_node_name, prefix.to_string(), size_limit),
channel_receiver,
connection_summaries.clone(),
msg_receiver,
finish.clone(),
num_received_messages.clone(),
size_limit,
)
.await;

Expand Down

0 comments on commit f7b29e3

Please sign in to comment.