Skip to content

Commit

Permalink
Attempt at fixing downlink. Swapping to making all compile
Browse files Browse the repository at this point in the history
  • Loading branch information
rrasmuss4200 committed Oct 9, 2024
1 parent 61533dc commit b4bd587
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 8 deletions.
9 changes: 2 additions & 7 deletions ex3_obc_fsw/bulk_msg_dispatcher/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -85,13 +85,6 @@ fn main() -> Result<(), IoError> {
num_bytes = bulk_msg.msg_body.len() as u64;
trace!("Num of 4k msgs: {}", num_of_4kb_msgs);

if let Some(data_fd) = &server.data_fd {
// Want to write to gs_bulk, not BulkMsgDispatcher fd
send_num_msgs_and_bytes_to_gs(num_of_4kb_msgs, bulk_msg.msg_body.len() as u64, data_fd)?;
} else {
warn!("No data file descriptor found in coms_interface.");
}

server.clear_buffer();
}
Err(e) => {
Expand All @@ -101,12 +94,14 @@ fn main() -> Result<(), IoError> {
}
}
if messages.len() > 1 {
// doesn't work right now! Donwlink broken :(
if let Some(data_fd) = &server.data_fd {
// Want to write to gs_bulk, not BulkMsgDispatcher fd
send_num_msgs_and_bytes_to_gs(num_of_4kb_msgs, num_bytes, data_fd)?;
} else {
warn!("No data file descriptor found in coms_interface.");
}
messages = Vec::new();
server.clear_buffer();
}
}
Expand Down
1 change: 0 additions & 1 deletion ex3_obc_fsw/cmd_dispatcher/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ fn main() {
}
}).collect();

println!("GOT {:?}", component_streams.get(8)); // prints BulkMsgDisp connection
for x in 0..ComponentIds::LAST as usize {
let payload = match ComponentIds::try_from(x as u8) {
Ok(p) => {
Expand Down

0 comments on commit b4bd587

Please sign in to comment.