Function CommitNewEntities

src/execution_plan/ops/shared/create_functions.c:196–262

Lock the graph and commit all changes introduced by the operation.

// Lock the graph and commit all changes introduced by the operation.
void CommitNewEntities
(
	OpBase *op,
	PendingCreations *pending
) {
	Graph *g = QueryCtx_GetGraph();
	uint node_count = array_len(pending->created_nodes);
	uint edge_count = array_len(pending->created_edges);

	// lock everything
	QueryCtx_LockForCommit();

	//--------------------------------------------------------------------------
	// commit nodes
	//--------------------------------------------------------------------------

	if(node_count > 0) {
		Graph_AllocateNodes(g, node_count);

		// set graph matrix sync policy to resize
		// no need to perform sync
		Graph_SetMatrixPolicy(g, SYNC_POLICY_RESIZE);
		_CommitNodesBlueprint(pending);

		// set graph matrix sync policy to NOP
		// no need to perform sync/resize
		Graph_SetMatrixPolicy(g, SYNC_POLICY_NOP);
		_CommitNodes(pending);

		// clear pending attributes array
		array_clear(pending->node_attributes);

		if(unlikely(ErrorCtx_EncounteredError())) {
			goto cleanup;
		}
	}

	//--------------------------------------------------------------------------
	// commit edges
	//--------------------------------------------------------------------------

	if(edge_count > 0) {
		Graph_AllocateEdges(g, edge_count);

		// set graph matrix sync policy to resize
		// no need to perform sync
		Graph_SetMatrixPolicy(g, SYNC_POLICY_RESIZE);
		_CommitEdgesBlueprint(pending->edges_to_create);

		// set graph matrix sync policy to NOP
		// no need to perform sync/resize
		Graph_SetMatrixPolicy(g, SYNC_POLICY_NOP);
		_CommitEdges(pending);

		// clear pending attributes array
		array_clear(pending->edge_attributes);

		if(unlikely(ErrorCtx_EncounteredError())) {