in src/afs.cc [2204:2233]
void set_parameters()
{
const char* tag = "set parameters";
pgstat_report_activity(STATE_RUNNING,
(std::string(Tag) + ": setting parameters").c_str());
auto session = find_session();
SharedSessionReleaser sessionReleaser(sessions_, session);
std::string handle;
auto preparedStatement = find_prepared_statement(session, handle, tag);
P("%s: %s: %s: %s", Tag, tag_, tag, handle.c_str());
if (!preparedStatement)
{
return;
}
auto input = std::make_shared<SharedRingBufferInputStream>(this, localSession_);
auto status = preparedStatement->set_parameters(input);
if (!status.ok())
{
set_error_message(session,
std::string(Tag) + ": " + tag_ + ": " + tag +
": failed to set parameters: <" + handle +
">: " + status.ToString(),
tag);
}
session->setParametersFinished = true;
signal_server(tag);
}