scheduler 예제코드 질문..

typedef struct task_info_tag {
	unsigned long stack[THREAD_STACKSIZE];
	unsigned long sp;
 
	int task_id;
 
	TaskStatus status;
 
	struct task_info_tag *next;
	struct task_info_tag *prev;
}*TaskInfo;

void parent_task(void *context)
{
	// signal 처리를 위한 정보를 위한 구조체
	struct sigaction act;
	sigset_t masksets;
	pid_t pid;
 
	// signal set 초기화
	sigemptyset( &masksets );
	// signal handler로 thread_switch() 등록
	act.sa_handler = thread_switch;
	act.sa_mask = masksets;
	act.sa_flags = SA_NODEFER;
 
	// signal 수신 때 취할 action 설정
	sigaction( SIGUSR1, &act, NULL );
 
	if( ( pid = fork() ) ==  0 ) {
		while(1) {
			sleep(1);
			kill( getppid(), SIGUSR1 );
		}
	} else{
		while (1) {
			// child_task가 1개 남았을 때, 즉, parent_task만 남았을 때
			if ( gh_sch.child_task == 1 ){
				kill( pid, SIGINT );
				break;
			}
		};
	}
}

TaskInfo thread_create(TaskFunc callback, void *context)
{
	TaskInfo taskinfo;
	// task를 위한 공간 할당
	taskinfo = malloc(sizeof(*taskinfo));
	memset(taskinfo, 0x00, sizeof(*taskinfo));
 
	{
		struct frame *f = (struct frame *)&taskinfo->stack[THREAD_STACKSIZE - sizeof(struct frame)/4];
		// taskinfo로 할당된 공간 중 stack부분 뒤쪽에 frame을 위한 공간으로 할당
		// 이에 task가 수행되면서 stack공간을 활용
		int i;
		for(i = 0; i < THREAD_STACKSIZE; ++i) {	// stack overflow check
			taskinfo->stack[i] = i;
		}
		memset(f, 0, sizeof(struct frame));
		f->retaddr = (unsigned long)callback;
		f->retaddr2 = (unsigned long)thread_kill;
		f->data    = (unsigned long)context;
		taskinfo->sp      = (unsigned long)&f->flags;
		f->ebp     = (unsigned long)&f->eax;
	}
	// task 생성에 따라 gh_sch에 child task가 늘었음을 표시
	gh_sch.child_task ++;
	// gh_sch.child_task 값으로 task_id 할당
	taskinfo->task_id = gh_sch.child_task;		
	// task 생성시 TASK_READY로 상태를 설정함
	taskinfo->status = TASK_READY;				
	// taskinfo구조체들의 linkedlist에 새 thread의 taskinfo 구조체를 삽입
	task_insert(taskinfo);	
 
	return taskinfo;
}

static unsigned long spsave, sptmp;
void thread_switch()
{
	asm(    "push %%eax\n\t"
		"push %%ebx\n\t"
		"push %%ecx\n\t"
		"push %%edx\n\t"
		"push %%esi\n\t"
		"push %%edi\n\t"
		"push %%ebp\n\t"
		"push %%ebp\n\t"
		"mov %%esp, %0" 
		: "=r" (spsave) 
	);
 
	gh_sch.running_task->sp = spsave;
 
	scheduler();	
	sptmp = gh_sch.running_task->sp;
 
	asm(	"mov %0, %%esp\n\t" 
		"pop %%ebp\n\t"
		"pop %%ebp\n\t"
		"pop %%edi\n\t"
		"pop %%esi\n\t"
		"pop %%edx\n\t"
		"pop %%ecx\n\t"
		"pop %%ebx\n\t"
		"pop %%eax\n\t"
		::"r" (sptmp)
	); //끝나고 현재 running_task에 대한 callback function을 수행하게됩니다. (retaddr1)
}

void test_func_one(void* context)
{
	int i = 0;
	while (1) 
	{
		i++;
		printf("TASK 1 : %5d\n", i);
		sleep(1);
		if ( i == 15 ){
			break;
		}
	}
}

// my_scheduler의 main 함수
int main(void )
{
	thread_init();
 
	thread_create(test_func_one, NULL); //첫 인자: callback function
	thread_create(test_func_two, NULL);
	thread_create(test_func_three, NULL);
 
	thread_wait();//parent_task()호출
 
	return 0;
}