in fbpcf/mpc/QueueIO.cpp [19:26]
void QueueIO::recv_data_internal(void* data, int64_t len) {
for (auto i = 0; i < len; i++) {
while (inQueue_->rlock()->empty()) {
}
*((char*)data + i) = inQueue_->rlock()->front();
inQueue_->wlock()->pop();
}
}