11. Disk Manager (4th Week)

1) Major Functions

1. Structures

disk_reserve_from_cache
│
├── disk_cache_lock_reserve_for_purpose
│   └── disk_cache_lock_reserve
│
├── disk_cache_unlock_reserve_for_purpose
│   └── disk_cache_unlock_reserve
│
├── disk_reserve_from_cache_vols
│   └── disk_reserve_from_cache_volume
│       └── disk_cache_update_vol_free
│
├── disk_extend
│   ├── disk_volume_expand
│   └── disk_add_volume
│
├── disk_lock_extend
│
└── disk_unlock_extend

disk_reserve_from_cache와 연관된 위의 함수들은 실제로 디스크로부터 섹터들을 부여 받는 것이 아니라 예약이 가능한 섹터들의 정보들을 볼륨과 관련하여 context로 기록

(disk_extend 함수는 이후 주차의 발표자가 진행할 예정이며, disk_lock_extend와 disk_unlock_extend 함수 역시 이번 주차의 발표 주제를 벗어남)

2. Diagram

(1) disk_reserve_from_cache calls

(2) disk_reserve_from_cache_vols calls

(3) disk_reserve_from_cache_volume calls

2) disk_cache_lock_reserve_for_purpose & disk_cache_lock_reserve

1. Purpose

캐쉬로부터 섹터 예약을 진행하는 과정에서 볼륨의 목적에 맞는 LOCK을 취득하기 위한 함수

목적에 맞는 값을 DB_VOLPURPOSE 타입의 인자로 넘겨서 disk_cache_lock_reserve 함수를 호출

2. Flows

(1) me라는 int 타입 변수에 thread_get_current_entry_index를 호출하여 자신의 쓰레드 엔트리 인덱스를 기록

int me = thread_get_current_entry_index ();

(2) extend_info의 owner_reserve는 LOCK을 취득하기 이전에는 -1로 되어 있다가, LOCK을 획득하면 그제서야 me로 기록해둔 값을 할당 (따라서 기존에 이미 me에 할당된 값이 존재하는 경우를 LOCK을 취득하기 이전에 검사)

if (me == extend_info->owner_reserve)
{
	/* already owner */
	assert (false);
	return;
}

(3) 쓰레드 엔트리 인덱스의 검증이 끝났다면, pthread_mutex_lock 함수 호출로 목적에 따른 LOCK을 취득

pthread_mutex_lock (&extend_info->mutex_reserve);

(4) LOCK이 취득되더라도 여전히 owner_reserve정보는 자신의 쓰레드 엔트리 값으로 바꾸지 않았기 때문에 -1인 상태므로 이에 대한 검증을 수행 후, owner_reserve값을 me로 할당

assert (extend_info->owner_reserve == -1);
extend_info->owner_reserve = me;

3) disk_cache_unlock_reserve_for_purpose & disk_cache_unlock_reserve

1. Purpose

캐쉬로부터 섹터 예약을 진행하는 과정에서 볼륨의 목적에 맞는 LOCK을 해제하기 위한 함수

목적에 맞는 값을 DB_VOLPURPOSE 타입의 인자로 넘겨서 disk_cache_unlock_reserve 함수를 호출

2. Flows

(1) thread_get_current_entry_index 함수의 호출로 현재 쓰레드 엔트리를 me라는 변수에 할당

int me = thread_get_current_entry_index ();

(2) LOCK을 해제한다는 것은 기존에 취득한 LOCK을 놓겠다는 의미이고, LOCK을 획득했을 때는 owner_reserve에 me를 기록해두었기 떄문에 LOCK을 해제하기 이전에 LOCK을 소지하고 있는지 여부를 검증

assert (me == extend_info->owner_reserve);

(3) 검증을 마쳐서 LOCK을 소지하고 있던 것이 맞다면 owner_reserve 값을 다시 -1로 할당

extend_info->owner_reserve = -1;

(4) LOCK을 해제

pthread_mutex_unlock (&extend_info->mutex_reserve);

4) disk_lock_extend

1. Purpose

볼륨 extend를 수행하기 위해 LOCK을 획득하는 함수

2. Flows

(1) disk_cache_lock_reserve 함수를 호출 했을 때와 마찬가지로 thread_get_current_entry_index 함수를 호출하여 쓰레드 엔트리를 me라는 변수에 할당

int me = thread_get_current_entry_index ();

(2) extend를 위한 LOCK을 잡기 전에는 목적에 따른 LOCK을 잡아두지 않은 상태여야 하므로 이에 대한 검증을 수행 (me와 owner_reserve가 달라야 함)

assert (me != disk_Cache->perm_purpose_info.extend_info.owner_reserve);
assert (me != disk_Cache->temp_purpose_info.extend_info.owner_reserve);

(3) me의 값이 전역 변수인 disk_Cache의 owner_extend와 같다면 이미 LOCK을 획득한 것이므로 그대로 함수 종료

if (me == disk_Cache->owner_extend)
{
	/* already owner */
	assert (false);
	return;
}

(4) LOCK 획득 후 owner_extend값에 me를 할당

pthread_mutex_lock (&disk_Cache->mutex_extend);
assert (disk_Cache->owner_extend == -1);
disk_Cache->owner_extend = me;

5) disk_unlock_extend

1. Purpose

볼륨 extend를 마치고 난 후 LOCK을 해제하는 함수

2. Flows

(1) me 값을 thread_get_current_entry_index를 호출하여 할당

int me = thread_get_current_entry_index ();

(2) LOCK을 소유하고 있다면 disk_Cache 전역 변수의 owner_extend 값이 me와 같으므로 이에 대한 검증 시도

assert (disk_Cache->owner_extend == me);

(3) owner_extend 값을 -1로 되돌리고, LOCK 해제

pthread_mutex_unlock (&disk_Cache->mutex_extend);

6) disk_reserve_from_cache

1. Purpose

필요한 섹터들을 캐쉬로부터 사전 예약하는 함수

2. Parameters

static int
disk_reserve_from_cache (THREAD_ENTRY * thread_p, DISK_RESERVE_CONTEXT * context, bool * did_extend)

THREAD_ENTRY * thread_p

쓰레드 엔트리
DISK_RESERVE_CONTEXT * context

disk_reserve_sectors 함수에서 기록된 예약을 위한 맥락 (함수의 내용들을 수행하는 동안 구조체 내부 값이 변동될 수 있음, 아래와 같은 내용들이 있음)

(1) 예약하려는 섹터 수 (conext.nsect_total)

(2) 캐쉬로부터 예약이 완료되기 까지 남은 섹터 수 (context.n_cache_reserve_remaining)

(3) 예약된 섹터의 id를 기록할 수 있는 공간 (context.vsidp)

(4) 캐쉬로부터 예약을 진행한 섹터 수 (context.n_cache_vol_reserve)

(5) 예약 대상이 되는 볼륨의 이용 목적 (context.purpose)
bool * did_extend

섹터 예약에 있어서 볼륨의 extend가 발생했는지 기록 (disk_reserve_from_cache 함수는 에러 코드를 반환하도록 되어 있으므로 추가적인 반환을 위해선 포인터 전달이 필요)

3. Automatics

DISK_EXTEND_INFO *extend_info;
DKNSECTS save_remaining;
int error_code = NO_ERROR;

DISK_EXTENDED_INFO * extend_info

disk_reserve_from_cache는 TEMPORARY든 PERMANENT든 목적에 관계없이 캐쉬로부터 섹터 예약이 가능해야 하므로, (context에 기록된) 목적에 맞는 extend 정보들을 참조할 수 있도록 이용
DKNSECTS save_remaining

디스크의 extend를 위해 이용되는 extend_info의 nsect_intention을 조작하는데 사용되는 변수 (예약하려는 남은 섹터 수인 context 구조체 내부의 n_cache_reserve_remaining을 통해서 초기화 됨, extend 이전에 높인 nsect_intention을 extend 이후에 낮출 필요가 있는데 n_cache_reserve_remaining은 extend 과정에서 예약을 진행하면서 그 값이 변경되기 때문에 save_remaining에 예약이 필요한 남은 섹터수를 기록하게 됨)
int error_code

함수 내에서 특정 작업 수행 후, 에러 여부 기록 용도의 변수

4. Flows

(1) 디스크 캐쉬가 초기화 되어 존재하고 있는지 확인

if (disk_Cache == NULL)
{
	/* not initialized? */
	assert_release (false);
	return ER_FAILED;
}

(2) 디스크 캐쉬를 조작하기 위해 목적에 따른 LOCK을 획득

disk_cache_lock_reserve_for_purpose (context->purpose);

(3) a. 목적이 Temporary인 경우에는 DB_PERMANENT_VOLTYPE인 볼륨에서 먼저 예약 진행 (이 과정에서 단순하게 예약이 완료 되면 목적에 따른 LOCK을 해제하고 NO_ERROR 반환)

현재 예약이 되어 차지하고 있는 섹터 수 + 앞으로 예약이 필요한 섹터수가 DB_TEMPORARY_VOLTYPE인 볼륨의 섹터 수보다 크거나 같다면, 목적에 따른 LOCK을 해제하고 공간 초과 에러를 반환 (만일 에러가 발생하지 않으면 그대로 분기문을 탈출)

이 때의 extend_info는 &disk_Cache->temp_purpose_info.extend_info가 됨

if (context->purpose == DB_TEMPORARY_DATA_PURPOSE)
{
	/* if we want to allocate temporary files, we have two options: preallocated permanent volumes (but with the
	 * purpose of temporary files) or temporary volumes. try first the permanent volumes */

	extend_info = &disk_Cache->temp_purpose_info.extend_info;

	if (disk_Cache->temp_purpose_info.nsect_perm_free > 0)
	{
		 disk_reserve_from_cache_vols (DB_PERMANENT_VOLTYPE, context);
	}
	if (context->n_cache_reserve_remaining <= 0)
	{
		/* found enough sectors */
		assert (context->n_cache_reserve_remaining == 0);
		disk_cache_unlock_reserve_for_purpose (context->purpose);
		return NO_ERROR;
	}

	/* reserve sectors from temporary volumes */
	extend_info = &disk_Cache->temp_purpose_info.extend_info;
	if (extend_info->nsect_total - extend_info->nsect_free + context->n_cache_reserve_remaining >= disk_Temp_max_sects)
	{
		/* too much temporary space */
		assert (false);
		er_set (ER_ERROR_SEVERITY, ARG_FILE_LINE, ER_BO_MAXTEMP_SPACE_HAS_BEEN_EXCEEDED, 1, disk_Temp_max_sects);
		disk_cache_unlock_reserve_for_purpose (context->purpose);
		return ER_BO_MAXTEMP_SPACE_HAS_BEEN_EXCEEDED;
	}

	/* fall through */
}

(3) b. 목적이 Permanent인 경우에는 DB_PERMANENT_VOLTYPE인 볼륨에서 바로 진행하면 됨

따라서 extend_info는 &disk_Cache->perm_purpose_info.extend_info가 됨

else
{
	extend_info = &disk_Cache->perm_purpose_info.extend_info;
	/* fall through */
}

(4) 목적이 Temporary 라면 DB_TEMPORARY_VOLTYPE, 목적이 Permanent 라면 DB_PERMANENT_VOLTYPE 로 예약을 진행할 수 있게 됨

(5) 예약을 진행해야 하는 섹터 수가 여전히 존재해야하고, 목적에 따른 LOCK이 여전히 걸려 있어야 추후 로직을 진행할 수 있음 (extend_info 구조체의 owner_reserve가 자기 자신의 쓰레드 엔트리 인덱스 값이어야 함)

assert (context->n_cache_reserve_remaining > 0);
assert (extend_info->owner_reserve == thread_get_entry_index (thread_p));

(6) a. 볼륨 내의 가용 공간 수가 예약하려는 섹터수보다 커서 예약 진행이 가능하다면, disk_reserve_from_cache_vols를 호출하여 예약을 진행 (이 때 예약하려는 섹터의 수가 0 이하 값이 된다면 예약을 무사히 진행한 것이므로, 목적에 따른 LOCK을 해제하고 NO_ERROR를 반환)

if (extend_info->nsect_free > context->n_cache_reserve_remaining)
{
	disk_reserve_from_cache_vols (extend_info->voltype, context);
	if (context->n_cache_reserve_remaining <= 0)
	{
		/* found enough sectors */
		assert (context->n_cache_reserve_remaining == 0);
		disk_cache_unlock_reserve (extend_info);
		return NO_ERROR;
	}
}

(6) b. 볼륨의 extend를 수행하여 예약을 진행해야하는 경우에는 extend 전용 LOCK을 획득해야 함

(7) a. extend 전용 LOCK을 획득하는 과정에서 이미 다른 쓰레드 엔트리가 extend를 수행했을 수 있기 때문에, 다시 목적에 따른 LOCK을 획득하여 이를 판별

만일 이미 extend가 되어 있다면 굳이 현재 쓰레드 엔트리에서 extend를 수행할 필요가 없으므로, 섹터 예약 후에 목적에 따른 LOCK 해제 및 extend 전용 LOCK을 해제하고 NO_ERROR를 반환

disk_cache_unlock_reserve (extend_info);

/* now lock expand */
disk_lock_extend ();

/* check again free sectors */
disk_cache_lock_reserve (extend_info);
if (extend_info->nsect_free > context->n_cache_reserve_remaining)
{
	/* somebody else expanded? try again to reserve */
	/* also update intention */
	extend_info->nsect_intention -= context->n_cache_reserve_remaining;

	disk_log ("disk_reserve_from_cache", "somebody else extended disk. try reserve from cache again. "
		"also decrement intention by %d to %d for %s.", context->n_cache_reserve_remaining,
		extend_info->nsect_intention, disk_type_to_string (extend_info->voltype));

	disk_reserve_from_cache_vols (extend_info->voltype, context);
	if (context->n_cache_reserve_remaining <= 0)
	{
		assert (context->n_cache_reserve_remaining == 0);
		disk_cache_unlock_reserve (extend_info);
		disk_unlock_extend ();
		return NO_ERROR;
	}

	extend_info->nsect_intention += context->n_cache_reserve_remaining;

	disk_log ("disk_reserve_from_cache", "could not reserve enough from cache. need to do extend. "
		"increment intention by %d to %d for %s.", context->n_cache_reserve_remaining,
		extend_info->nsect_intention, disk_type_to_string (extend_info->voltype));
}

(7) b. 하지만 목적에 따른 LOCK을 획득 했을 때 extend가 진행되지 않았다는 것이 확인되면, 현재 쓰레드 엔트리에서 디스크 extend를 수행해야 하므로 목적에 따른 LOCK을 해제하고 disk_extend 함수를 호출하여 extend를 수행

/* ok, we really have to extend the disk space ourselves */
save_remaining = context->n_cache_reserve_remaining;

disk_cache_unlock_reserve (extend_info);

error_code = disk_extend (thread_p, extend_info, context);

(8) 디스크 extend가 완료되면 이에 대한 로그를 기록하기 위해 목적에 따른 LOCK을 잡고, 로그를 남긴 뒤에 해당 LOCK을 해제

/* remove intention */
disk_cache_lock_reserve (extend_info);
extend_info->nsect_intention -= save_remaining;
disk_log ("disk_reserve_from_cache", "extend done. decrement intention by %d to %d for %s. \n",
	save_remaining, extend_info->nsect_intention, disk_type_to_string (extend_info->voltype));
disk_cache_unlock_reserve (extend_info);

(9) 디스크 extend 과정에서 이미 섹터 예약이 모두 끝났고, 더 이상의 extend는 필요 없으므로 extend 전용 LOCK도 해제

disk_unlock_extend ();

(10) 위 과정 동안 에러가 없었는지 확인하고, 예약하려는 섹터가 남았는지 확인

문제가 없다면 did_extend를 true로 만들고 NO_ERROR를 반환 (extend 되지 않고 정상적으로 예약이 되었다면 (3) a 혹은 (6) a에서 종료)

if (error_code != NO_ERROR)
{
	ASSERT_ERROR ();
	return error_code;
}
if (context->n_cache_reserve_remaining > 0)
{
	assert_release (false);
	return ER_FAILED;
}

*did_extend = true;

/* all cache reservations were made */
return NO_ERROR;

7) disk_reserve_from_cache_vols

1. Purpose

예약이 필요한 섹터들을 DB의 볼륨들로부터 사전 예약을 진행하기 위해, 목적에 따라 반복 형태와 증감 방향을 정하여 각 볼륨마다 사전 예약 정보를 진행할 수 있게 해주는 함수

2. Parameters

STATIC_INLINE void
disk_reserve_from_cache_vols (DB_VOLTYPE type, DISK_RESERVE_CONTEXT * context)

DB_VOLTYPE type

예약을 진행하려는 볼륨의 타입
DISK_RESERVE_CONTEXT * context

disk_reserve_from_cache 함수의 동일 인자 참고

3. Automatics

VOLID volid_iter;
VOLID start_iter, end_iter, incr;
DKNSECTS min_free;

VOLID volid_iter

start_iter와 end_iter까지 반복을 수행할 때 사용할 인덱스 용도의 변수
VOLID start_iter, end_iter, incr;

시작 인덱스, 끝 인덱스, 증감 방향 및 크기
DKNSECTS min_free

예약을 진행할 수 있는 최소의 가용 섹터 수

4. Flows

(1) 인자로 받은 DB_VOLTYPE과 DB_VOLPURPOSE가 유효한 값인지 확인 (DB_TEMPORARY_VOLTYPE이면서 목적이 Permanent인 대상을 걸러내기 위함)

assert (disk_compatible_type_and_purpose (type, context->purpose));

(2) DB_VOLTYPE에 맞춰서 start_iter, end_iter, incr와 min_free를 설정

a. type == DB_PERMANENT_VOLTYPE

start_iter는 0부터 시작
end_iter는 Permanent 타입의 볼륨 수까지
incr는 1개씩 증가 방향
min_free는 (context에 기록되어 있는) 예약해야 하는 총 섹터 수와 Permanent 목적의 한 볼륨이 가질 수 있는 최대 섹터 수 중 더 작은 값을 절반으로 나눈 값

if (type == DB_PERMANENT_VOLTYPE)
{
	start_iter = 0;
	end_iter = disk_Cache->nvols_perm;
	incr = 1;

	min_free = MIN (context->nsect_total, disk_Cache->perm_purpose_info.extend_info.nsect_vol_max) / 2;
}

b. type == DB_TEMPORARY_VOLTYPE

start_iter는 LOG_MAX_DB_VOLID로 VOLID_MAX - 1의 인덱스부터 시작
end_iter는 LOG_MAX_DB_VOLID에서 Temporary 타입의 볼륨 수만큼 뺀 수까지
incr는 1개씩 감소 방향
min_free는 (context에 기록되어 있는) 예약해야 하는 총 섹터 수와 Temporary 목적의 한 볼륨이 가질 수 있는 최대 섹터 수 중 더 작은 값을 절반으로 나눈 값

else
{
	start_iter = LOG_MAX_DBVOLID;
	end_iter = LOG_MAX_DBVOLID - disk_Cache->nvols_temp;
	incr = -1;

	min_free = MIN (context->nsect_total, disk_Cache->temp_purpose_info.extend_info.nsect_vol_max) / 2;
}

(3) 각 목적의 nsect_vol_max는 PRM_ID_DB_VOLUME_SIZE 인덱스에 해당하는 값을 읽어와서 min_free 값이 계산 되기 때문에 읽어온 값이 올바르지 않으면, 위 과정의 MIN 함수에 의해 min_free가 원하지 않는 값으로 초기화 될 수 있음

min_free라는 값은 볼륨의 예약할 수 있는 섹터 수가 충분한지 확인할 때 사용되고, 의미 상 적어도 1개의 섹터가 적절함

따라서 min_free로 결정된 값은 1 이상의 값이 되어야 함

min_free = MAX (min_free, 1);

> 예약하려는 총 섹터 수가 볼륨이 가질 수 있는 최대 섹터 수보다 작은 경우
min_free는 예약하려는 총 섹터 수의 절반

> 예약하려는 총 섹터 수가 볼륨이 가질 수 있는 최대 섹터 수보다 큰 경우
min_free는 볼륨이 가질 수 있는 총 섹터 수의 절반

(4) volid_iter를 이용하여 start_iter부터 end_iter까지 incr만큼 증감하여 disk_reserve_from_cache_volume 함수를 호출 (이 때 조건 검사로 볼륨의 목적이 맞지 않는지, 볼륨의 가용 섹터 수가 적어도 min_free 이상 보유가 되어 있는지 확인, 만일 조건에 하나라도 어긋나면 다음 볼륨으로 넘어감)

for (volid_iter = start_iter; volid_iter != end_iter && context->n_cache_reserve_remaining > 0; volid_iter += incr)
{
	if (disk_Cache->vols[volid_iter].purpose != context->purpose)
	{
		/* not the right purpose. */
		continue;
	}
	if (disk_Cache->vols[volid_iter].nsect_free < min_free)
	{
		/* avoid unnecessary fragmentation */
		continue;
	}
	/* reserve from this volume */
	disk_reserve_from_cache_volume (volid_iter, context);
}

8) disk_reserve_from_cache_volume

1. Purpose

예약이 필요한 섹터들을 DB의 각 볼륨으로부터 사전 예약을 진행하는 함수

2. Parameters

STATIC_INLINE void
disk_reserve_from_cache_volume (VOLID volid, DISK_RESERVE_CONTEXT * context)

VOLID volid

섹터 예약의 대상이 되는 볼륨 ID
DISK_RESERVE_CONTEXT * context

disk_reserve_from_cache 함수의 동일 인자 참고

3. Automatics

DKNSECTS nsects;

DKNSECTS nsects

한 볼륨 상에서 예약을 진행할 섹터 수

4. Flows

(1) 예약을 진행한 볼륨의 수가 LOG_MAX_DBVOLID보다 작아야 하므로, 이에 대한 검증을 진행

if (context->n_cache_vol_reserve >= LOG_MAX_DBVOLID)
{
	assert_release (false);
	return;
}

(2) context의 목적에 맞는 extend_info에 쓰레드 엔트리 인덱스를 기록하고 있는 owner_reserve 값이 thread_get_current_entry_index 함수의 호출 결과와 같은지 검증

disk_check_own_reserve_for_purpose (context->purpose);

(3) 예약을 진행하려는 섹터 수가 존재해야하고, 인자로 받은 volid에 해당하는 볼륨에 가용 섹터 수가 존재해야함

assert (context->n_cache_reserve_remaining > 0);
assert (disk_Cache->vols[volid].nsect_free > 0);

(4) 볼륨 상에서 예약이 가능한 섹터 수는 volid에 해당하는 볼륨의 가용 섹터 수와 예약을 해야하는 섹터 수 중 더 작은 값을 현재 볼륨에서 진행할 수 있으므로, 이 둘 중 더 작은 값을 nsects에 할당

nsects = MIN (disk_Cache->vols[volid].nsect_free, context->n_cache_reserve_remaining);

(5) 캐쉬에 볼륨에 대한 가용 섹터 수를 갱신 (위에서 제시된 nsects 수만큼 가용 섹터 수에서 제할 수 있으므로 -nsects를 이용)

disk_cache_update_vol_free (volid, -nsects);

(6) context의 cache_vol_reserve 배열에 순서대로 volid와 예약을 진행할 수 있는 섹터 수 nsects를 각각 volid와 nsect에 할당

예약을 진행해야 하는 섹터 수는 nsects만큼 감소해야 하므로 n_cache_reserve_remaining을 그만큼 감소

context->cache_vol_reserve[context->n_cache_vol_reserve].volid = volid;
context->cache_vol_reserve[context->n_cache_vol_reserve].nsect = nsects;
context->n_cache_reserve_remaining -= nsects;

(7) 로그를 남기고 cache_vol_reserve 배열에 사용될 인덱스를 증가 (따라서 최종적으로 disk_reserve_from_cache_volume을 마쳤을 때 n_cache_vol_reserve는 예약에 사용된 볼륨 수가 됨)

disk_log ("disk_reserve_from_cache_volume", "reserved %d sectors from volid = %d, \n" DISK_RESERVE_CONTEXT_MSG,
	    nsects, volid, DISK_RESERVE_CONTEXT_AS_ARGS (context));

context->n_cache_vol_reserve++;

(8) 예약을 위한 정보들을 기록했다면, 예약을 진행해야 하는 섹터 수들은 0 이상으로 남아 있어야 (음수가 되면 필요 이상으로의 예약 정보를 기록한 것이므로) 함

assert (context->n_cache_reserve_remaining >= 0);

9) disk_cache_update_vol_free

1. Purpose

사전 예약을 진행하면서 각 볼륨마다 유지하고 있는 가용 섹터 수를 캐쉬 내에 delta_free만큼 반영하는 함수

2. Parameters

STATIC_INLINE void
disk_cache_update_vol_free (VOLID volid, DKNSECTS delta_free)

VOLID volid

가용 섹터 수를 조정하려는 볼륨 ID
DKNSECTS delta_free

캐쉬의 가용 섹터 수를 갱신하기 위한 변화량

3. Flows

(1) 캐쉬의 가용 섹터 수를 조정할 때는 이를 조작하기 위한 LOCK을 획득한 상태여야 함

볼륨의 가용 섹터 수를 delta_free만큼 더함 (delta_free는 음수 일 수 있음)

이에 대한 결과는 0 이상의 값이어야 함

/* must be locked */
disk_Cache->vols[volid].nsect_free += delta_free;
assert (disk_Cache->vols[volid].nsect_free >= 0);

disk_check_own_reserve_for_purpose (disk_Cache->vols[volid].purpose);

(3) a. 목적이 Permanent 인 경우에는 DB_PERMANENT_VOLTYPE 이어야 하므로 이에 대한 검증을 진행

목적에 해당되는 extend_info 역시 가용 섹터 수를 변경 시켜야 하므로 delta_free만큼 증감을 진행

이에 대한 결과로 목적에 해당되는 extend_info의 가용 섹터 수는 0 이상이어야 함

검증이 끝나면 로그를 남김

if (disk_Cache->vols[volid].purpose == DB_PERMANENT_DATA_PURPOSE)
{
	assert (disk_get_voltype (volid) == DB_PERMANENT_VOLTYPE);
	disk_Cache->perm_purpose_info.extend_info.nsect_free += delta_free;
	assert (disk_Cache->perm_purpose_info.extend_info.nsect_free >= 0);

	disk_log ("disk_cache_update_vol_free", "updated cached free for volid %d to %d and perm_perm to %d; "
		"delta free = %d", volid, disk_Cache->vols[volid].nsect_free,
		disk_Cache->perm_purpose_info.extend_info.nsect_free, delta_free);
}

(3) b. 목적이 Temporary라면 DB_PERMANENT_VOLTYPE 인지, DB_TEMPORARY_VOLTYPE 인지에 따라 수행 로직이 달라짐

(4) a. 목적이 Temporary 이면서, DB_PERMANENT_VOLTYPE 인 경우

해당되는 extend_info의 가용 섹터수를 변경 시켜야 하므로 delta_free만큼 증감을 진행

이에 대한 결과로 목적에 해당되는 extend_info의 가용 섹터 수는 0 이상이어야 함

검증이 끝나면 로그를 남김

if (disk_get_voltype (volid) == DB_PERMANENT_VOLTYPE)
{
	disk_Cache->temp_purpose_info.nsect_perm_free += delta_free;
	assert (disk_Cache->temp_purpose_info.nsect_perm_free >= 0);

	disk_log ("disk_cache_update_vol_free", "updated cached free for volid %d to %d and perm_temp to %d; "
		"delta free = %d", volid, disk_Cache->vols[volid].nsect_free,
		disk_Cache->temp_purpose_info.nsect_perm_free, delta_free);
}

단, 목적이 Temporary이면서 DB_PERMANENT_VOLTYPE 일 때는 disk_Cache의 DISK_TEMP_PURPOSE_INFO의 nsect_perm_free를 증감

(4) b. 목적이 Temporary 이면서, DB_TEMPORARY_VOLTYPE 인 경우

해당되는 extend_info의 가용 섹터수를 변경 시켜야 하므로 delta_free만큼 증감을 진행

이에 대한 결과로 목적에 해당되는 extend_info의 가용 섹터 수는 0 이상이어야 함

검증이 끝나면 로그를 남김

else
{
	disk_Cache->temp_purpose_info.extend_info.nsect_free += delta_free;
	assert (disk_Cache->temp_purpose_info.extend_info.nsect_free >= 0);

	disk_log ("disk_cache_update_vol_free", "updated cached free for volid %d to %d and temp_temp to %d; "
		"delta free = %d", volid, disk_Cache->vols[volid].nsect_free,
		disk_Cache->temp_purpose_info.extend_info.nsect_free, delta_free);
}

단, 목적이 Temporary이면서 DB_TEMPORARY_VOLTYPE 일 때는 disk_Cache의 DISK_TEMP_PURPOSE_INFO의 DISK_EXTEND_INFO의 nsect_free를 증감

FilesExpand file tree

README.md

Latest commit

History

README.md

File metadata and controls

11. Disk Manager (4th Week)

1) Major Functions

1. Structures

2. Diagram

2) disk_cache_lock_reserve_for_purpose & disk_cache_lock_reserve

1. Purpose

2. Flows

3) disk_cache_unlock_reserve_for_purpose & disk_cache_unlock_reserve

1. Purpose

2. Flows

4) disk_lock_extend

1. Purpose

2. Flows

5) disk_unlock_extend

1. Purpose

2. Flows

6) disk_reserve_from_cache

1. Purpose

2. Parameters

THREAD_ENTRY * thread_p

DISK_RESERVE_CONTEXT * context

bool * did_extend

3. Automatics

DISK_EXTENDED_INFO * extend_info

DKNSECTS save_remaining

int error_code

4. Flows

7) disk_reserve_from_cache_vols

1. Purpose

2. Parameters

DB_VOLTYPE type

DISK_RESERVE_CONTEXT * context

3. Automatics

VOLID volid_iter

VOLID start_iter, end_iter, incr;

DKNSECTS min_free

4. Flows

8) disk_reserve_from_cache_volume

1. Purpose

2. Parameters

VOLID volid

DISK_RESERVE_CONTEXT * context

3. Automatics

DKNSECTS nsects

4. Flows

9) disk_cache_update_vol_free

1. Purpose

2. Parameters

VOLID volid

DKNSECTS delta_free

3. Flows