Function RdbSaveGraph_v13

src/serializers/encoder/v13/encode_graph.c:171–262

}

void RdbSaveGraph_v13
(
	RedisModuleIO *rdb,
	void *value
) {
	// Encoding format for graph context and graph meta key:
	//  Header
	//  Payload(s) count: N
	//  Key content X N:
	//      Payload type (Nodes / Edges / Deleted nodes/ Deleted edges/ Graph schema)
	//      Entities in payload
	//  Payload(s) X N
	//
	// This function will encode each payload type (if needed) in the following order:
	// 1. Nodes
	// 2. Deleted nodes
	// 3. Edges
	// 4. Deleted edges
	// 5. Graph schema
	//
	// Each payload type can spread over one or more keys. For example:
	// A graph with 200,000 nodes, and the number of entities per payload
	// is 100,000 then there will be two nodes payloads,
	// each containing 100,000 nodes, encoded into two different RDB meta keys

	GraphContext *gc = value;

	// TODO: remove, no need, as GIL is taken

	// acquire a read lock if we're not in a thread-safe context
	if(_shouldAcquireLocks()) Graph_AcquireReadLock(gc->g);

	EncodeState current_state = GraphEncodeContext_GetEncodeState(gc->encoding_context);

	if(current_state == ENCODE_STATE_INIT) {
		// inital state, populate encoding context header
		GraphEncodeContext_InitHeader(gc->encoding_context, gc->graph_name, gc->g);
	}

	// save header
	_RdbSaveHeader(rdb, gc);

	// save payloads info for this key and retrive the key schema
	PayloadInfo *key_schema = _RdbSaveKeySchema(rdb, gc);

	uint payloads_count = array_len(key_schema);
	for(uint i = 0; i < payloads_count; i++) {
		// if the current key encoding more than one payload type,
		// payloads count >1 and we are in a new state, zero the entities count
		if(i > 0) GraphEncodeContext_SetProcessedEntitiesOffset(gc->encoding_context, 0);
		PayloadInfo payload = key_schema[i];
		switch(payload.state) {
		case ENCODE_STATE_NODES:
			RdbSaveNodes_v13(rdb, gc, payload.entities_count);
			break;
		case ENCODE_STATE_DELETED_NODES:
			RdbSaveDeletedNodes_v13(rdb, gc, payload.entities_count);
			break;