feat(net): 引入kthread，将Inet-网卡处理流程移入内核线程中

[Samuka007]

todo:

• kthread 调度优先级
• 为每个 Iface 引入中断处理线程，性能会更好？
• 仍然有死锁问题？

[Samuka007]

DragonOS/kernel/src/driver/net/kthread.rs

Lines 15 to 47 in 2452957

	#[unified_init(INITCALL_SUBSYS)]
	pub fn net_poll_init() -> Result<(), system_error::SystemError> {
	let closure = KernelThreadClosure::StaticEmptyClosure((&(net_poll_thread as fn() -> i32), ()));
	let pcb = KernelThreadMechanism::create_and_run(closure, "net_poll".to_owned())
	.ok_or("")
	.expect("create net_poll thread failed");
	log::info!("net_poll thread created");
	unsafe {
	NET_POLL_THREAD = Some(pcb);
	}
	return Ok(());
	}
	fn net_poll_thread() -> i32 {
	log::info!("net_poll thread started");
	loop {
	for (_, iface) in NET_DEVICES.read_irqsave().iter() {
	iface.poll();
	}
	let irq_guard = unsafe { CurrentIrqArch::save_and_disable_irq() };
	ProcessManager::mark_sleep(true).expect("clocksource_watchdog_kthread:mark sleep failed");
	drop(irq_guard);
	schedule(SchedMode::SM_NONE);
	}
	}
	/// 拉起线程
	pub(super) fn wakeup_poll_thread() {
	if unsafe { NET_POLL_THREAD.is_none() } {
	return;
	}
	let _ = ProcessManager::wakeup(unsafe { NET_POLL_THREAD.as_ref().unwrap() });
	}

目前是只为整个中断流程起了单独一个内核线程，在任意网卡中断来临时，处理所有网卡。

@fslongjin 调度优先级是要在哪个地方改？

[fslongjin]

DragonOS/kernel/src/driver/net/kthread.rs

Lines 15 to 47 in 2452957

	#[unified_init(INITCALL_SUBSYS)]
	pub fn net_poll_init() -> Result<(), system_error::SystemError> {
	let closure = KernelThreadClosure::StaticEmptyClosure((&(net_poll_thread as fn() -> i32), ()));
	let pcb = KernelThreadMechanism::create_and_run(closure, "net_poll".to_owned())
	.ok_or("")
	.expect("create net_poll thread failed");
	log::info!("net_poll thread created");
	unsafe {
	NET_POLL_THREAD = Some(pcb);
	}
	return Ok(());
	}
	fn net_poll_thread() -> i32 {
	log::info!("net_poll thread started");
	loop {
	for (_, iface) in NET_DEVICES.read_irqsave().iter() {
	iface.poll();
	}
	let irq_guard = unsafe { CurrentIrqArch::save_and_disable_irq() };
	ProcessManager::mark_sleep(true).expect("clocksource_watchdog_kthread:mark sleep failed");
	drop(irq_guard);
	schedule(SchedMode::SM_NONE);
	}
	}
	/// 拉起线程
	pub(super) fn wakeup_poll_thread() {
	if unsafe { NET_POLL_THREAD.is_none() } {
	return;
	}
	let _ = ProcessManager::wakeup(unsafe { NET_POLL_THREAD.as_ref().unwrap() });
	}

目前是只为整个中断流程起了单独一个内核线程，在任意网卡中断来临时，处理所有网卡。
@fslongjin 调度优先级是要在哪个地方改？

cfs的话应该是调整nice值。
目前为了能跑，可以先不管这个。