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

1

Browse Source
This commit is contained in:
aozhiwei 2023-10-10 08:50:18 +08:00
parent aff0907a6b
commit 1709853ee5
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/timer.rs
View File

@ -83,7 +83,7 @@ impl Timer {
} }
self.timer_tick = (self.get_tick_count)(); self.timer_tick = (self.get_tick_count)();
let cb = Rc::new( let cb = Rc::new(
|e: i32, args: Option<Vec<Rc::<dyn Any>>>| { |_event: i32, _args: Option<Vec<Rc::<dyn Any>>>| {
//self.gc_timer(e, args); //self.gc_timer(e, args);
} }
); );
@ -98,7 +98,7 @@ impl Timer {
} }
fn clear(&mut self, cb: Option<Rc::<dyn Fn (i32, Option<Vec<Rc::<dyn Any>>>)>>) { fn clear(&mut self) {
} }
@ -155,6 +155,20 @@ impl Timer {
} }
{ {
let idx = t.borrow().expires - self.timer_tick; let idx = t.borrow().expires - self.timer_tick;
let mut index = 0;
let vec: &mut Rc::<RefCell::<crate::ListHead<TimerList>>>;
if idx < 0 {
index = self.timer_tick & (TVR_MASK as i64);
vec = &mut self.tv1[index as usize];
} else if idx < TVR_SIZE as i64 {
index = t.borrow().expires & (TVR_MASK as i64);
vec = &mut self.tv1[index as usize];
} else {
index = t.borrow().expires & (TVR_MASK as i64);
vec = &mut self.tv1[index as usize];
}
crate::ListHead::add_tail(&vec,
&t.borrow_mut().timer_entry);
} }
return Rc::downgrade(&t.borrow().wp); return Rc::downgrade(&t.borrow().wp);
} }