Function _emit_running_query

src/commands/cmd_info.c:93–123

replies with query information

// replies with query information
static void _emit_running_query
(
    RedisModuleCtx *ctx,   // redis module context
    const CommandCtx *cmd  // command context
) {
	ASSERT(ctx != NULL);
	ASSERT(cmd != NULL);

	// compute query execution time
	const double total_time = TIMER_GET_ELAPSED_MILLISECONDS(cmd->timer);

	RedisModule_ReplyWithArray(ctx, 5 * 2);

	// emit query received timestamp
	Info_SectionAddEntryLongLong(ctx, RECEIVED_TIMESTAMP_KEY_NAME,
			cmd->received_ts);

	// emit graph name
	Info_SectionAddEntryString(ctx, GRAPH_NAME_KEY_NAME,
			GraphContext_GetName(cmd->graph_ctx));

	// emit query
	Info_SectionAddEntryString(ctx, QUERY_KEY_NAME, cmd->query);

	// emit query wait duration
	Info_SectionAddEntryDouble(ctx, EXECUTION_DURATION_KEY_NAME, total_time);

	// emit rather or not query was replicated
	Info_SectionAddEntryLongLong(ctx, REPLICATION_KEY_NAME,
			cmd->replicated_command);
}

// replies with query information
static void _emit_waiting_query