Method putRequest

src/jrd/Monitoring.cpp:1266–1327

void Monitoring::putRequest(SnapshotData::DumpRecord& record, const Request* request,
							const string& plan)
{
	fb_assert(request);

	const auto dbb = request->req_attachment->att_database;

	record.reset(rel_mon_statements);

	// request id
	record.storeInteger(f_mon_stmt_id, request->getRequestId());
	// attachment id
	if (request->req_attachment)
		record.storeInteger(f_mon_stmt_att_id, request->req_attachment->att_attachment_id);
	// state, transaction ID, timestamp
	if (request->req_transaction && (request->req_flags & req_active))
	{
		const bool is_stalled = (request->req_flags & req_stall);
		record.storeInteger(f_mon_stmt_state, is_stalled ? mon_state_stalled : mon_state_active);
		record.storeInteger(f_mon_stmt_tra_id, request->req_transaction->tra_number);
		record.storeTimestampTz(f_mon_stmt_timestamp, request->getTimeStampTz());

		SINT64 clock;
		if (request->req_timer && request->req_timer->getExpireClock(clock))
		{
			ISC_TIMESTAMP_TZ ts;
			memcpy(&ts, &clock, sizeof(clock));
			record.storeTimestampTz(f_mon_stmt_timer, ts);
		}
	}
	else
		record.storeInteger(f_mon_stmt_state, mon_state_idle);

	const Statement* const statement = request->getStatement();

	// Since ODS 13.1 statement text and plan is put into mon$compiled_statements
	if (dbb->getEncodedOdsVersion() < ODS_13_1)
	{
		// sql text
		if (statement->sqlText)
			record.storeString(f_mon_stmt_sql_text, *statement->sqlText);

		// explained plan
		if (plan.hasData())
			record.storeString(f_mon_stmt_expl_plan, plan);
	}

	// statistics
	const int stat_id = fb_utils::genUniqueId();
	record.storeGlobalId(f_mon_stmt_stat_id, getGlobalId(stat_id));

	// statement timeout, milliseconds
	record.storeInteger(f_mon_stmt_timeout, request->req_timeout);

	if (dbb->getEncodedOdsVersion() >= ODS_13_1)
		record.storeInteger(f_mon_stmt_cmp_stmt_id, statement->getStatementId());

	record.write();