add:依然为解决,留个版本

app/port/luat_shell_air101.c

@@ -26,45 +26,89 @@ void luat_shell_notify_recv(void) {
 static tls_os_queue_t *shell_queue = NULL;
 
 static int16_t luat_shell_uart_cb(uint16_t len, void* user_data){
+	// printf("luat_shell_uart_cb\r");
 	int uartid = (int)user_data;
-	char buff[512] = {0};
 	if(uartid >= 100)
 	{
-		int l = 1;
-		while (l > 0 && l <= 512) {
-			l = luat_uart_read(0, buff, 512);
-			//printf("uart read buff %d %s\n", l, buff);
-			if (l > 0 && l <= 512){
-				// luat_shell_push(buff, l);
-				// 多一个字节放\0
-				uart_data* send_buf = (uart_data*)luat_heap_malloc(sizeof(uart_data)+l+1);
-				if(send_buf == NULL)
-					break;
-				
-				send_buf->len = l;
-    			memmove(send_buf->buff, buff, l);
-				send_buf->buff[l] = 0; // 放个0x0, 确认一下
-				tls_os_queue_send(shell_queue, (void *)send_buf, sizeof(uart_data)+l);
-			}
-		}
+		// printf("before tls_os_queue_send\r");
+		tls_os_queue_send(shell_queue, (void *)user_data, 0);
+		// printf("after tls_os_queue_send\r");
 	}
     return 0;
 }
 
 static void luat_shell(void *sdata){
-	uart_data* receive_buf;
+	int* tag;
 	// char* receive_buf;
+	char buff[512];
 	int ret = 0;
+	int len = 1;
 	while (1) {
-		ret = tls_os_queue_receive(shell_queue, (void **) &receive_buf, 0, 0);
+		// printf("tls_os_queue_receive \r");
+		ret = tls_os_queue_receive(shell_queue, (void **) &tag, 0, 0);
 		if (ret) {
+			// printf("tls_os_queue_receive ret = %d\r", ret);
 			break;
 		}
-		luat_shell_push(receive_buf->buff, receive_buf->len);
-		luat_heap_free(receive_buf);
+		len = 1;
+		while (len > 0 && len < 512) {
+			// printf("before luat_uart_read\r");
+			len = luat_uart_read(0, buff, 511);
+			// printf("after luat_uart_read %d\r", len);
+			if (len > 0 && len < 512) {
+				buff[511] = 0x00; // 确保结尾
+				// printf("before luat_shell_push %d\r", len);
+				luat_shell_push(buff, len);
+				// printf("after luat_shell_push %d\r", len);
+			}
+		}
+		// printf("shell loop end\r");
 	}
 }
 
+// static int16_t luat_shell_uart_cb(uint16_t len, void* user_data){
+// 	printf("luat_shell_uart_cb len %d uartid %d\n", len,(int)user_data);
+// 	int uartid = (int)user_data;
+// 	char buff[512] = {0};
+// 	if(uartid >= 100)
+// 	{
+// 		int l = 1;
+// 		while (l > 0 && l <= 512) {
+// 			l = luat_uart_read(0, buff, 512);
+// 			//printf("uart read buff %d %s\n", l, buff);
+// 			if (l > 0 && l <= 512){
+// 				// luat_shell_push(buff, l);
+// 				// 多一个字节放\0
+// 				uart_data* send_buf = (uart_data*)luat_heap_malloc(sizeof(uart_data)+l+1);
+// 				if(send_buf == NULL)
+// 					break;
+				
+// 				send_buf->len = l;
+//     			memmove(send_buf->buff, buff, l);
+// 				send_buf->buff[l] = 0; // 放个0x0, 确认一下
+// 				tls_os_queue_send(shell_queue, (void *)send_buf, sizeof(uart_data)+l);
+// 			}
+// 		}
+// 	}
+//     return 0;
+// }
+
+// static void luat_shell(void *sdata){
+// 	uart_data* receive_buf;
+// 	// char* receive_buf;
+// 	int ret = 0;
+// 	while (1) {
+// 		ret = tls_os_queue_receive(shell_queue, (void **) &receive_buf, 0, 0);
+// 		if (ret) {
+// 			break;
+// 		}
+// 		printf(">>> before luat_shell_push\r\n");
+// 		luat_shell_push(receive_buf->buff, receive_buf->len);
+// 		printf("<<< after luat_shell_push\r\n");
+// 		luat_heap_free(receive_buf);
+// 	}
+// }
+
 #define    TASK_START_STK_SIZE         512
 static OS_STK __attribute__((aligned(4))) 			TaskStartStk[TASK_START_STK_SIZE] = {0};
 void luat_shell_poweron(int _drv) {