Function _GraphContext_Free

src/graph/graphcontext.c:867–973

Free all data associated with graph

// Free all data associated with graph
static void _GraphContext_Free(void *arg) {
	GraphContext *gc = (GraphContext *)arg;
	uint len;

	// disable matrix synchronization for graph deletion
	Graph_SetMatrixPolicy(gc->g, SYNC_POLICY_NOP);

	if(gc->decoding_context == NULL ||
			GraphDecodeContext_Finished(gc->decoding_context)) {
		Graph_Free(gc->g);
	} else {
		Graph_PartialFree(gc->g);
	}

	// Redis main thread is 0
	RedisModuleCtx *ctx = NULL;
	bool main_thread = ThreadPools_GetThreadID() == 0;
	bool should_lock = !main_thread && RedisModule_GetThreadSafeContext != NULL;

	if(should_lock) {
		ctx = RedisModule_GetThreadSafeContext(NULL);
		// GIL need to be acquire because RediSearch change Redis data structure
		RedisModule_ThreadSafeContextLock(ctx);
	}

	//--------------------------------------------------------------------------
	// delete graph telemetry stream
	//--------------------------------------------------------------------------

	if(gc->telemetry_stream != NULL) {
		bool should_create = (ctx == NULL);
		if(should_create) {
			ctx = RedisModule_GetThreadSafeContext(NULL);
		}
		_DeleteTelemetryStream(ctx, gc);
		RedisModule_FreeString(ctx, gc->telemetry_stream);
		if (should_create) {
			RedisModule_FreeThreadSafeContext(ctx);
			ctx = NULL;
		}
	}

	//--------------------------------------------------------------------------
	// free node schemas
	//--------------------------------------------------------------------------

	if(gc->node_schemas) {
		len = array_len(gc->node_schemas);
		for(uint32_t i = 0; i < len; i ++) {
			Schema_Free(gc->node_schemas[i]);
		}
		array_free(gc->node_schemas);
	}

	//--------------------------------------------------------------------------
	// free relation schemas
	//--------------------------------------------------------------------------