Function _MatrixSynchronize

src/graph/graph.c:171–230

resize given matrix, such that its number of row and columns matches the number of nodes in the graph. Also, synchronize matrix to execute any pending operations

// matches the number of nodes in the graph. Also, synchronize
// matrix to execute any pending operations
void _MatrixSynchronize
(
	const Graph *g,
	RG_Matrix m
) {
	GrB_Info  info;
	GrB_Index n_rows;
	GrB_Index n_cols;

	RG_Matrix_nrows(&n_rows, m);
	RG_Matrix_ncols(&n_cols, m);

	bool      dirty = RG_Matrix_isDirty(m);
	GrB_Index dims  = Graph_RequiredMatrixDim(g);

	UNUSED(info);

	// matrix must be resized if its dimensions missmatch required dimensions
	bool require_resize = (n_rows != dims || n_cols != dims);

	// matrix fully synced, nothing to do
	if(!require_resize && !dirty) {
		return;
	}

	// lock matrix
	RG_Matrix_Lock(m);

	// recheck
	RG_Matrix_nrows(&n_rows, m);
	RG_Matrix_ncols(&n_cols, m);
	dirty = RG_Matrix_isDirty(m);
	dims = Graph_RequiredMatrixDim(g);
	require_resize = (n_rows != dims || n_cols != dims);

	// some other thread performed sync
	if(!require_resize && !dirty) {
		goto cleanup;
	}

	// resize if required
	if(require_resize) {
		info = RG_Matrix_resize(m, dims, dims);
		ASSERT(info == GrB_SUCCESS);
	}

	// flush pending changes if dirty
	// we need to call 'RG_Matrix_isDirty' again
	// as 'RG_Matrix_resize' might require 'wait' for HyperSparse matrices
	if(RG_Matrix_isDirty(m)) {
		info = RG_Matrix_wait(m, false);
		ASSERT(info == GrB_SUCCESS);
	}

	ASSERT(RG_Matrix_isDirty(m) == false);

cleanup:
	// unlock matrix mutex