this->threadPoolHook_.registerThread();
thread->startupBaton.post();
- while (1) {
+ while (true) {
auto task = taskQueue_->take();
if (UNLIKELY(task.poison)) {
CHECK(threadsToStop_-- > 0);
}
ThreadPoolExecutor::ThreadPtr ThreadPoolExecutor::StoppedThreadQueue::take() {
- while (1) {
+ while (true) {
{
std::lock_guard<std::mutex> guard(mutex_);
if (queue_.size() > 0) {
// The timeout (if set) keeps running here
return true;
#endif
- } else if ((0
+ } else if ((false
#ifdef SSL_ERROR_WANT_RSA_ASYNC_PENDING
- || error == SSL_ERROR_WANT_RSA_ASYNC_PENDING
+ || error == SSL_ERROR_WANT_RSA_ASYNC_PENDING
#endif
#ifdef SSL_ERROR_WANT_ECDSA_ASYNC_PENDING
- || error == SSL_ERROR_WANT_ECDSA_ASYNC_PENDING
+ || error == SSL_ERROR_WANT_ECDSA_ASYNC_PENDING
#endif
- )) {
+ )) {
// Our custom openssl function has kicked off an async request to do
// rsa/ecdsa private key operation. When that call returns, a callback will
// be invoked that will re-call handleAccept.
} else {
skipListInsert(0, writeValues_[t]);
}
- return 0;
+ return false;
default:
return skipListFind(0, readValues_[t]);
}
} else {
setInsert(idx, writeValues_[t]);
}
- return 0;
+ return false;
default:
return setFind(idx, readValues_[t]);
}
void(*f_fbstring)(folly::fbstring&),
void(*f_wfbstring)(folly::basic_fbstring<wchar_t>&)) {
do {
- if (1) {
+ if (true) {
} else {
EXPECT_TRUE(1) << "Testing clause " << clause;
}