in src/afs.cc [3289:3318]
void process_select_prepared_statement_requests()
{
#ifdef AFS_VERBOSE
const char* tag = "select prepared statement";
#endif
std::lock_guard<std::mutex> lock(mutex_);
for (auto& request : selectPreparedStatementRequests_)
{
request->finished = true;
auto session = static_cast<SharedSessionData*>(
dshash_find(sessions_, &(request->localSession->id), false));
if (!session)
{
request->localSession->errorMessage =
std::string("stolen session: ") +
std::to_string(request->localSession->id);
continue;
}
auto executorPID = session->executorPID;
{
SharedSessionReleaser sessionReleaser(sessions_, session);
ProcessorLockGuard lock(this);
set_shared_string(session->preparedStatementHandle, request->handle);
session->action = Action::SelectPreparedStatement;
}
P("%s: %s: %s: kill executor: %d", Tag, tag_, tag, executorPID);
kill(executorPID, SIGUSR1);
}
selectPreparedStatementRequests_.clear();
}