server_common/librust
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
azw 2023-11-09 00:20:53 +00:00
parent 9761c32056
commit a3415fcd42
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
r9/src/queue.rs
View File

@ -22,11 +22,11 @@ impl<T> Queue<T> {
return this; return this;
} }
pub fn push(&mut self, node: &Rc::<RefCell::<crate::ListHead<T>>>) { pub fn push(&self, node: &Rc::<RefCell::<crate::ListHead<T>>>) {
crate::ListHead::<T>::add_tail(&self.msg_list, node); crate::ListHead::<T>::add_tail(&self.msg_list, node);
} }
pub fn fetch(&mut self) { pub fn fetch(&self) {
if !self.msg_list.borrow().empty() && if !self.msg_list.borrow().empty() &&
self.work_list.borrow().empty() { self.work_list.borrow().empty() {
crate::ListHead::replace_init(&self.work_list, &self.msg_list); crate::ListHead::replace_init(&self.work_list, &self.msg_list);