update

examples/mqttclient/src/main.rs

@@ -56,6 +56,8 @@ fn client() -> io::Result<()> {
 
     stream.write_all(&connect_bytes).unwrap();
 
+    println!("connect send ok");
+
     let mut socket = Socket(stream);
 
     let res = Packet::read_from(&mut socket).expect("read connack fail");
@@ -73,12 +75,6 @@ fn client() -> io::Result<()> {
     let mut buf = [0; MAX_CMD_LEN];
     let mut cursor = 0;
 
-    // spawn(|| loop {
-    //     sleep(Duration::from_secs(5));
-
-    //     println!("tick");
-    // });
-
     loop {
         if stdin.read(&mut buf[cursor..cursor + 1]).ok() != Some(1) {
             continue;
@@ -122,6 +118,6 @@ fn client() -> io::Result<()> {
 
 #[cfg_attr(feature = "axstd", no_mangle)]
 fn main() {
-    println!("Hello, simple http client!");
+    println!("Hello, simple mqtt client!");
     client().expect("test http client failed");
 }

modules/axtask/src/api.rs

@@ -210,7 +210,7 @@ pub fn exit(exit_code: i32) -> ! {
 pub fn run_idle() -> ! {
     loop {
         yield_now();
-        debug!("idle task: waiting for IRQs...");
+        // debug!("idle task: waiting for IRQs...");
         #[cfg(feature = "irq")]
         axhal::arch::wait_for_irqs();
     }