aboutsummaryrefslogtreecommitdiff
path: root/src/desktop/serial.rs
diff options
context:
space:
mode:
authorAstatin <[email protected]>2025-08-24 17:19:47 +0200
committerAstatin <[email protected]>2025-08-24 17:19:47 +0200
commit219157faec53a8f2df8912ef3ae4e7941fa23305 (patch)
treea89ddbe02bf3502b3c2e0379f1aebec1da7b7e73 /src/desktop/serial.rs
parent70b95279579146bf46910257f8e0ecb1ff62b24f (diff)
Fix serial read_controlHEADlatestmain
Diffstat (limited to 'src/desktop/serial.rs')
-rw-r--r--src/desktop/serial.rs7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/desktop/serial.rs b/src/desktop/serial.rs
index 36cfba8..c7c3d6f 100644
--- a/src/desktop/serial.rs
+++ b/src/desktop/serial.rs
@@ -4,6 +4,7 @@ use std::net::{TcpListener, TcpStream};
use std::sync::mpsc::{self, Receiver, Sender};
use std::thread;
+use crate::logs::{log, LogLevel};
use crate::consts::CPU_CLOCK_SPEED;
use crate::io::Serial;
@@ -166,7 +167,7 @@ impl TcpSerial {
thread::spawn(move || {
match TcpListener::bind(("0.0.0.0", port)).unwrap().accept() {
Ok((socket, addr)) => {
- println!("Connection on {:?}", addr);
+ log(LogLevel::Infos, format!("Connection on {:?}", addr));
Self::handle_stream(socket, tx, rx);
}
_ => (),
@@ -193,7 +194,7 @@ impl TcpSerial {
let (output, rx) = mpsc::channel::<u8>();
thread::spawn(move || {
if let Ok(socket) = TcpStream::connect(&addr) {
- println!("Connected to {:?}", addr);
+ log(LogLevel::Infos, format!("Connected to {:?}", addr));
Self::handle_stream(socket, tx, rx);
}
});
@@ -251,8 +252,8 @@ impl Serial for TcpSerial {
self.current_data = x;
self.external_clock = true;
self.transfer_requested = false;
+ self.next_byte_transfer_cycle = cycles + ((CPU_CLOCK_SPEED as u128) / 1024);
}
- self.next_byte_transfer_cycle = cycles + ((CPU_CLOCK_SPEED as u128) / 16384);
true
} else if !self.external_clock && !self.current_transfer && self.transfer_requested {
if cycles > self.next_byte_transfer_cycle {