void QueueIO::recv_data_internal()

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();
  }
}