| 497 | } |
| 498 | |
| 499 | void ReactorThread::RunThread() { |
| 500 | ThreadRestrictions::SetWaitAllowed(false); |
| 501 | ThreadRestrictions::SetIOAllowed(false); |
| 502 | DVLOG(6) << "Calling ReactorThread::RunThread()..."; |
| 503 | loop_.run(0); |
| 504 | VLOG(1) << name() << " thread exiting."; |
| 505 | |
| 506 | // No longer need the messenger. This causes the messenger to |
| 507 | // get deleted when all the reactors exit. |
| 508 | reactor_->messenger_.reset(); |
| 509 | } |
| 510 | |
| 511 | bool ReactorThread::FindConnection(const ConnectionId& conn_id, |
| 512 | CredentialsPolicy cred_policy, |