Function current_op

pg_documentdb/src/commands/current_op.c:190–230

Datum
current_op(pgbson *commandSpec)
{
	ReportFeatureUsage(FEATURE_COMMAND_CURRENTOP);

	pgbson *filterSpec = NULL;
	pgbson *aggregateSpec = BuildAggregateSpecFromCommandSpec(commandSpec, &filterSpec);

	/* Now write the response */
	pgbson_writer writer;
	PgbsonWriterInit(&writer);

	StringInfo str = makeStringInfo();
	appendStringInfo(str,
					 "WITH currentOpQuery AS (SELECT %s.current_op_aggregation($1) AS document), "
					 "currentOpResponse AS (SELECT COALESCE(array_agg(document), '{}') AS \"inprog\", "
					 " 1::float AS \"ok\" FROM currentOpQuery WHERE $2 IS NULL OR document OPERATOR(%s.@@) $2) "
					 " SELECT %s.row_get_bson(currentOpResponse) FROM currentOpResponse",
					 ApiInternalSchemaNameV2, ApiCatalogSchemaName, CoreSchemaName);

	Oid argTypes[2] = { BsonTypeId(), BsonTypeId() };
	Datum argValues[2] = { PointerGetDatum(aggregateSpec), PointerGetDatum(filterSpec) };
	char argNulls[2] = { ' ', ' ' };
	if (filterSpec == NULL)
	{
		argNulls[1] = 'n';
	}

	bool readOnly = true;
	bool isNull = false;
	Datum result = ExtensionExecuteQueryWithArgsViaSPI(str->data, 2, argTypes, argValues,
													   argNulls, readOnly, SPI_OK_SELECT,
													   &isNull);
	if (isNull)
	{
		ereport(ERROR, (errmsg(
							"Unexpected - currentOp internal query returned a null response")));
	}

	PG_RETURN_DATUM(result);
}


/*