Naive concurrent commits

concurrent-commits.txt

void Commit(Row[] rows) 
{
	// yield priority to commits that came before 
	GetGlobalLock();
	ReleaseGlobalLock();
	
	// attempt to lock all rows
	int i = 0;
	for (i = 0; i < rows.Length; i++)
	{
		if (!rows[i].Lock())
		{
			break;
		}
	}
	
	
	// check if row locks needs releasing
	if (i != rows.Length)
	{
		while (--i >=0)
		{
			rows[i].Unlock();
		}
	}
	
	if (i != rows.Length)
	{
		GetGlobalLock();
		Write(rows);
		ReleaseGlobalLock();
	}
	else
	{
		Write(rows);
		for (i = 0; i < rows.Length; i++)
		{
			rows[i].Unlock();
		}
	}
}