Sync with upstream Tock to remove the latest patch.
This commit is contained in:
@@ -295,7 +295,7 @@ index ece4a443..9a1afc84 100644
|
||||
}
|
||||
+
|
||||
+ pub fn in_writeable_flash_region(&self, ptr: usize, len: usize) -> bool {
|
||||
+ self.kernel.process_map_or(false, self.idx, |process| {
|
||||
+ self.kernel.process_map_or(false, *self, |process| {
|
||||
+ let ptr = match ptr.checked_sub(process.flash_start() as usize) {
|
||||
+ None => return false,
|
||||
+ Some(ptr) => ptr,
|
||||
|
||||
@@ -1,46 +0,0 @@
|
||||
diff --git a/kernel/src/common/dynamic_deferred_call.rs b/kernel/src/common/dynamic_deferred_call.rs
|
||||
index 53f5143d..ca349972 100644
|
||||
--- a/kernel/src/common/dynamic_deferred_call.rs
|
||||
+++ b/kernel/src/common/dynamic_deferred_call.rs
|
||||
@@ -226,23 +226,25 @@ impl DynamicDeferredCall {
|
||||
/// `call_global_instance_while`.
|
||||
pub(self) fn call_while<F: Fn() -> bool>(&self, f: F) {
|
||||
if self.call_pending.get() {
|
||||
- // Reset call_pending here, as it may be set again in the deferred calls
|
||||
- self.call_pending.set(false);
|
||||
+ for (i, client_state) in self.client_states.iter().enumerate() {
|
||||
+ if !f() {
|
||||
+ break;
|
||||
+ }
|
||||
+ if client_state.scheduled.get() {
|
||||
+ client_state.client.map(|client| {
|
||||
+ client_state.scheduled.set(false);
|
||||
+ client.call(DeferredCallHandle(i));
|
||||
+ });
|
||||
+ }
|
||||
+ }
|
||||
|
||||
- self.client_states
|
||||
- .iter()
|
||||
- .enumerate()
|
||||
- .filter(|(_i, client_state)| client_state.scheduled.get())
|
||||
- .filter_map(|(i, client_state)| {
|
||||
- client_state
|
||||
- .client
|
||||
- .map(|c| (i, &client_state.scheduled, *c))
|
||||
- })
|
||||
- .take_while(|_| f())
|
||||
- .for_each(|(i, call_reqd, client)| {
|
||||
- call_reqd.set(false);
|
||||
- client.call(DeferredCallHandle(i));
|
||||
- });
|
||||
+ // Recompute call_pending here, as some deferred calls may have been skipped due to the
|
||||
+ // `f` predicate becoming false.
|
||||
+ self.call_pending.set(
|
||||
+ self.client_states
|
||||
+ .iter()
|
||||
+ .any(|client_state| client_state.scheduled.get()),
|
||||
+ );
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user