Function GraphContext_New

src/graph/graphcontext.c:89–137

creates and initializes a graph context struct

// creates and initializes a graph context struct
GraphContext *GraphContext_New
(
	const char *graph_name
) {
	GraphContext *gc = rm_malloc(sizeof(GraphContext));

	gc->version          = 0;  // initial graph version
	gc->slowlog          = SlowLog_New();
	gc->queries_log      = QueriesLog_New();
	gc->ref_count        = 0;  // no refences
	gc->attributes       = raxNew();
	gc->index_count      = 0;  // no indicies
	gc->string_mapping   = array_new(char *, 64);
	gc->encoding_context = GraphEncodeContext_New();
	gc->decoding_context = GraphDecodeContext_New();

	// read NODE_CREATION_BUFFER size from configuration
	// this value controls how much extra room we're willing to spend for:
	// 1. graph entity storage
	// 2. matrices dimensions
	size_t node_cap;
	size_t edge_cap;
	bool rc = Config_Option_get(Config_NODE_CREATION_BUFFER, &node_cap);
	assert(rc);
	edge_cap = node_cap;

	gc->g = Graph_New(node_cap, edge_cap);
	gc->graph_name = rm_strdup(graph_name);
	gc->telemetry_stream = RedisModule_CreateStringPrintf(NULL,
			TELEMETRY_FORMAT, gc->graph_name);

	// allocate the default space for schemas and indices
	gc->node_schemas = array_new(Schema *, GRAPH_DEFAULT_LABEL_CAP);
	gc->relation_schemas = array_new(Schema *, GRAPH_DEFAULT_RELATION_TYPE_CAP);

	// initialize the read-write lock to protect access to the attributes rax
	int rc1 = pthread_rwlock_init(&gc->_attribute_rwlock, NULL);
	assert(rc1 == 0);

	// build the execution plans cache
	uint64_t cache_size;
	Config_Option_get(Config_CACHE_SIZE, &cache_size);
	gc->cache = Cache_New(cache_size, (CacheEntryFreeFunc)ExecutionCtx_Free,
						  (CacheEntryCopyFunc)ExecutionCtx_Clone);

	Graph_SetMatrixPolicy(gc->g, SYNC_POLICY_FLUSH_RESIZE);

	return gc;
}

// _GraphContext_Create tries to get a graph context
// and if it does not exists, create a new one