Function CurrentOpAggregateCore

pg_documentdb/src/commands/current_op.c:270–299

* Core implementation logic for currentOp on the query Coordinator. */

 * Core implementation logic for currentOp on the query Coordinator.
 */
static void
CurrentOpAggregateCore(pgbson *spec, TupleDesc descriptor,
					   Tuplestorestate *tupleStore)
{
	CurrentOpOptions options = { 0 };
	PopulateCurrentOpOptions(spec, &options);

	List *workerBsons = NIL;
	if (options.localOps)
	{
		workerBsons = list_make1(CurrentOpWorkerCore(spec));
	}
	else
	{
		int numValues = 1;
		Datum values[1] = { PointerGetDatum(spec) };
		Oid types[1] = { BsonTypeId() };
		workerBsons = RunQueryOnAllServerNodes("CurrentOp", values, types, numValues,
											   command_current_op_worker,
											   ApiToApiInternalSchemaName,
											   "current_op_worker");
	}

	MergeWorkerBsons(workerBsons, descriptor, tupleStore);

	/* The index queue and build status only needs to run on the coordinator
	 * run this only here.
	 */
	AddIndexBuilds(descriptor, tupleStore);
}


/*