in src/afs.cc [2638:2672]
arrow::Result<uint64_t> connect(const std::string& databaseName,
const std::string& userName,
const std::string& password,
const std::string& clientAddress)
{
auto id = assign_session_id();
ARROW_ASSIGN_OR_RAISE(auto localSession, find_session(id));
auto request = std::make_shared<ConnectRequest>(
id, databaseName, userName, password, clientAddress);
{
std::lock_guard<std::mutex> lock(mutex_);
connectRequests_.push_back(request);
}
kill(MyProcPid, SIGUSR1);
{
std::unique_lock<std::mutex> lock(mutex_);
conditionVariable_.wait(lock, [&] {
if (localSession->errorMessage.has_value())
{
return true;
}
if (INTERRUPTS_PENDING_CONDITION())
{
return true;
}
return request->finished;
});
}
ARROW_RETURN_NOT_OK(check_local_session_error(localSession));
if (INTERRUPTS_PENDING_CONDITION())
{
return arrow::Status::Invalid("interrupted");
}
return id;
}