@@ -145,7 +145,7 @@ pub fn spawn<T: context::Context>(
145
145
}
146
146
147
147
if restart_queue {
148
- log:: debug!( "restart queue(queue_executed: {}" , queue_executed) ;
148
+ // log::debug!("restart queue(queue_executed: {}", queue_executed);
149
149
if queue_executed {
150
150
let mut ctx = context_manager. lock ( ) . expect ( "Mutex to be locked" ) ;
151
151
ctx. reset_data ( tasks_graph_changed) ;
@@ -155,24 +155,24 @@ pub fn spawn<T: context::Context>(
155
155
156
156
let default_state = TypeId :: of :: < ( ) > ( ) ;
157
157
let current_state = ctx. current_state ( ) ;
158
- log:: debug!( "current state: {:?}" , current_state) ;
158
+ // log::debug!("current state: {:?}", current_state);
159
159
if current_state != default_state {
160
160
if let Some ( tasks) = pool. select_for_state ( & default_state) {
161
161
for task in tasks. iter ( ) {
162
- log:: debug!(
163
- "tasks for default state: {:?}" ,
164
- pool. get( * task) . and_then( |t| t. name( ) )
165
- ) ;
162
+ // log::debug!(
163
+ // "tasks for default state: {:?}",
164
+ // pool.get(*task).and_then(|t| t.name())
165
+ // );
166
166
}
167
167
queue. extend_from_slice ( tasks) ;
168
168
}
169
169
}
170
170
if let Some ( tasks) = pool. select_for_state ( & current_state) {
171
171
for task in tasks. iter ( ) {
172
- log:: debug!(
173
- "tasks for current state: {:?}" ,
174
- pool. get( * task) . and_then( |t| t. name( ) )
175
- ) ;
172
+ // log::debug!(
173
+ // "tasks for current state: {:?}",
174
+ // pool.get(*task).and_then(|t| t.name())
175
+ // );
176
176
}
177
177
queue. extend_from_slice ( tasks) ;
178
178
}
@@ -198,28 +198,28 @@ pub fn spawn<T: context::Context>(
198
198
while index < stop_index {
199
199
let task_id = queue[ index] ;
200
200
if let Some ( mut task) = pool. take ( & task_id) {
201
- log:: debug!( "task({}): begin control" , task. name( ) ) ;
201
+ // log::debug!("task({}): begin control", task.name());
202
202
if !task. is_scheduled ( ) {
203
- log:: debug!( "task({}): not scheduled yet" , task. name( ) ) ;
203
+ // log::debug!("task({}): not scheduled yet", task.name());
204
204
if task. name ( ) == "dotrix::window::input::ReadInput" {
205
- log:: debug!(
206
- "task({}): not scheduled yet: {:?}" ,
207
- task. name( ) ,
208
- task. dependencies( )
209
- ) ;
205
+ // log::debug!(
206
+ // "task({}): not scheduled yet: {:?}",
207
+ // task.name(),
208
+ // task.dependencies()
209
+ // );
210
210
}
211
211
if let Some ( dependencies_state) = context_manager
212
212
. lock ( )
213
213
. unwrap ( )
214
214
. match_dependencies ( task. dependencies ( ) )
215
215
{
216
- log:: debug!( "task({}): to be scheduled" , task. name( ) ) ;
216
+ // log::debug!("task({}): to be scheduled", task.name());
217
217
task. schedule_with ( dependencies_state) ;
218
218
} else {
219
- log:: debug!(
220
- "task({}): dependencies are not sattisfied" ,
221
- task. name( )
222
- ) ;
219
+ // log::debug!(
220
+ // "task({}): dependencies are not sattisfied",
221
+ // task.name()
222
+ // );
223
223
}
224
224
}
225
225
0 commit comments