Function WriteOneActivityToDocument

pg_documentdb/src/commands/current_op.c:725–862

* Given an activity on a worker node via SingleWorkerActivity, * writes the activity to the target pgbson_writer. The activity * is written in a format compatible with the currentOp command output. */

 * is written in a format compatible with the currentOp command output.
 */
static void
WriteOneActivityToDocument(SingleWorkerActivity *workerActivity,
						   pgbson_writer *singleActivityWriter)
{
	DetectMongoCollection(workerActivity);

	char *shardId = psprintf("shard_%d", workerActivity->shardId);
	PgbsonWriterAppendUtf8(singleActivityWriter, "shard", 5, shardId);
	bool isActive = false;
	const char *type = "unknown";
	if (strcmp(workerActivity->state, "active") == 0)
	{
		isActive = true;
		type = "op";
	}
	else if (strcmp(workerActivity->state, "idle") == 0)
	{
		type = "idleSession";
	}
	else if (strcmp(workerActivity->state, "idle in transaction") == 0)
	{
		/* We mark these differently to provide info to the user */
		type = "idleSessionInTransaction";
	}
	else if (strcmp(workerActivity->state, "idle in transaction (aborted)") == 0)
	{
		/* We mark these differently to provide info to the user */
		type = "idleSessionInTransaction";
	}

	PgbsonWriterAppendBool(singleActivityWriter, "active", 6, isActive);
	PgbsonWriterAppendUtf8(singleActivityWriter, "type", 4, type);

	PgbsonWriterAppendUtf8(singleActivityWriter, "opid", 4, workerActivity->operationId);

	/* report the globalPid so that we can track locks back to this process */
	PgbsonWriterAppendInt64(singleActivityWriter, "op_prefix", 9,
							workerActivity->globalPid);


	if (workerActivity->backendType != NULL &&
		strcmp(workerActivity->backendType, "parallel worker") == 0)
	{
		PgbsonWriterAppendBool(singleActivityWriter, "parallelWorker", 14, true);
	}

	if (workerActivity->leaderPid != 0)
	{
		PgbsonWriterAppendInt64(singleActivityWriter, "leaderOpPattern", 14,
								workerActivity->leaderPid);
	}

	if (isActive)
	{
		/* ns is only valid for an active query. */
		int databaseNameLength = strlen(workerActivity->processedMongoDatabase);
		if (databaseNameLength > 0)
		{