Function CommandCtx_New

src/commands/cmd_context.c:18–63

create a new command context

// create a new command context
CommandCtx *CommandCtx_New
(
	RedisModuleCtx *ctx,           // redis module context
	RedisModuleBlockedClient *bc,  // blocked client
	RedisModuleString *cmd_name,   // command to execute
	RedisModuleString *query,      // query string
	GraphContext *graph_ctx,       // graph context
	ExecutorThread thread,         // which thread executes this command
	bool replicated_command,       // whether this instance was spawned by a replication command
	bool compact,                  // whether this query was issued with the compact flag
	long long timeout,             // the query timeout, if specified
	bool timeout_rw,               // apply timeout on both read and write queries
	uint64_t received_ts,          // command received at this  UNIX timestamp
	simple_timer_t timer           // stopwatch started upon command received
) {
	CommandCtx *context = rm_malloc(sizeof(CommandCtx));

	context->bc                 = bc;
	context->ctx                = ctx;
	context->query              = NULL;
	context->thread             = thread;
	context->compact            = compact;
	context->timeout            = timeout;
	context->ref_count          = ATOMIC_VAR_INIT(1);
	context->graph_ctx          = graph_ctx;
	context->timeout_rw         = timeout_rw;
	context->received_ts        = received_ts;
	context->command_name       = NULL;
	context->replicated_command = replicated_command;

	simple_timer_copy(timer, context->timer);

	if(cmd_name) {
		// make a copy of command name
		const char *command_name = RedisModule_StringPtrLen(cmd_name, NULL);
		context->command_name = rm_strdup(command_name);
	}

	if(query) {
		// make a copy of query
		const char *q = RedisModule_StringPtrLen(query, NULL);
		context->query = rm_strdup(q);
	}

	return context;
}

// increment command context reference count
void CommandCtx_Incref