Function Effects_Apply

src/effects/effects_apply.c:508–583

applys effects encoded in buffer

// applys effects encoded in buffer
void Effects_Apply
(
	GraphContext *gc,          // graph to operate on
	const char *effects_buff,  // encoded effects
	size_t l                   // size of buffer
) {
	// validations
	ASSERT(l > 0);  // buffer can't be empty
	ASSERT(effects_buff != NULL);  // buffer can't be NULL

	// read buffer in a stream fashion
	FILE *stream = fmemopen((void*)effects_buff, l, "r");

	// validate effects version
	if(ValidateVersion(stream) == false) {
		// replica/primary out of sync
		exit(1);
	}

	// lock graph for writing
	Graph *g = GraphContext_GetGraph(gc);
	Graph_AcquireWriteLock(g);

	// update graph sync policy
	MATRIX_POLICY policy = Graph_SetMatrixPolicy(g, SYNC_POLICY_RESIZE);

	// as long as there's data in stream
	while(ftell(stream) < l) {
		// read effect type
		EffectType t = ReadEffectType(stream);
		switch(t) {
			case EFFECT_DELETE_NODE:
				ApplyDeleteNode(stream, gc);
				break;
			case EFFECT_DELETE_EDGE:
				ApplyDeleteEdge(stream, gc);
				break;
			case EFFECT_UPDATE_NODE:
				ApplyUpdateNode(stream, gc);
				break;
			case EFFECT_UPDATE_EDGE:
				ApplyUpdateEdge(stream, gc);
				break;
			case EFFECT_CREATE_NODE:    
				ApplyCreateNode(stream, gc);
				break;
			case EFFECT_CREATE_EDGE:
				ApplyCreateEdge(stream, gc);
				break;
			case EFFECT_SET_LABELS:
				ApplyLabels(stream, gc, true);
				break;
			case EFFECT_REMOVE_LABELS: 
				ApplyLabels(stream, gc, false);
				break;
			case EFFECT_ADD_SCHEMA:
				ApplyAddSchema(stream, gc);
				break;