We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 63ae338 commit bfbecd6Copy full SHA for bfbecd6
tx-pool/src/verify_mgr.rs
@@ -76,6 +76,10 @@ impl Worker {
76
77
async fn process_inner(&mut self) {
78
loop {
79
+ if self.exit_signal.is_cancelled() {
80
+ info!("Verify worker::process_inner exit_signal is cancelled");
81
+ return;
82
+ }
83
if self.status != ChunkCommand::Resume {
84
return;
85
}
@@ -170,7 +174,6 @@ impl VerifyMgr {
170
174
171
175
172
176
fn send_child_command(&self, command: ChunkCommand) {
173
- //info!("[verify-test] verify-mgr send child command: {:?}", command);
177
for w in &self.workers {
178
if let Err(err) = w.0.send(command.clone()) {
179
info!("send worker command failed, error: {}", err);
0 commit comments