Mercurial > hg > CbC > old > DPP
diff tableau3.cbc @ 0:d4bc23cb728b
Import from CVS (CVS_DB/member/atsuki/cbc/DPP)
author | Yasutaka Higa <e115763@ie.u-ryukyu.ac.jp> |
---|---|
date | Wed, 16 Dec 2015 15:16:11 +0900 |
parents | |
children | a15437a1e94c |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/tableau3.cbc Wed Dec 16 15:16:11 2015 +0900 @@ -0,0 +1,301 @@ +/* +** Dining Philosophers Problem's scheduler +** with state developper as a tableau method + +** 連絡先: 琉球大学情報工学科 河野 真治 +** (E-Mail Address: kono@ie.u-ryukyu.ac.jp) +** +** このソースのいかなる複写,改変,修正も許諾します。ただし、 +** その際には、誰が貢献したを示すこの部分を残すこと。 +** 再配布や雑誌の付録などの問い合わせも必要ありません。 +** 営利利用も上記に反しない範囲で許可します。 +** バイナリの配布の際にはversion messageを保存することを条件とします。 +** このプログラムについては特に何の保証もしない、悪しからず。 +** +** Everyone is permitted to do anything on this program +** including copying, modifying, improving, +** as long as you don't try to pretend that you wrote it. +** i.e., the above copyright notice has to appear in all copies. +** Binary distribution requires original version messages. +** You don't have to ask before copying, redistribution or publishing. +** THE AUTHOR DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE. + +*/ +#include <stdlib.h> +#include <time.h> +#include "dpp2.h" +#include "queue.h" +#include "memory.h" +#include "state_db.h" +#include "ltl.h" + +int NUM_PHILOSOPHER = 5; /* A number of philosophers must be more than 2. */ + +static code (*ret)(int); +static void *env; + +static PhilsPtr phils_list = NULL; + +static int max_step = 100; + +static StateDB state_db; +static MemoryPtr mem; +static StateNode st; +static int always_flag; // for LTL + +int +list_length(TaskPtr list) +{ + int length; + TaskPtr t; + + if (!list) return 0; + t = list->next; + + for (length = 1; t && t != list; length++) { + t = t->next; + } + return length; +} + +TaskPtr +get_task(int num, TaskPtr list) +{ + while (num-- > 0) { + list = list->next; + } + return list; +} + + +static TaskIteratorPtr task_iter; +static int depth,count; + +/* + Performe depth frist search + Possible task iterleave is generated by TaskIterator + (using task ring) + State are recorded in StateDB + all memory fragments are regsitered by add_memory_range() + including task queue + */ + + +code tableau(TaskPtr list) +{ + StateDB out; + + st.hash = get_memory_hash(mem,0); + if (lookup_StateDB(&st, &state_db, &out)) { + // found in the state database + //printf("found %d\n",count); + while(!(list = next_task_iterator(task_iter))) { + // no more branch, go back to the previous one + TaskIteratorPtr prev_iter = task_iter->prev; + if (!prev_iter) { + printf("All done count %d\n",count); + printf("Number of unique states %d\n", state_count()); + memory_usage(); + show_result(always_flag); + goto ret(0),env; + } + //printf("no more branch %d\n",count); + depth--; + free_task_iterator(task_iter); + task_iter = prev_iter; + } + // return to previous state + // here we assume task list is fixed, we don't have to + // recover task list itself + restore_memory(task_iter->state->memory); + //printf("restore list %x next %x\n",(int)list,(int)(list->next)); + } else { + // one step further + depth++; + task_iter = create_task_iterator(list,out,task_iter); + } + //printf("depth %d count %d\n", depth, count++); + count++; + goto list->phils->next(list->phils,list); +} + +code get_next_task_fifo(TaskPtr list) +{ + TaskPtr t = list; + TaskPtr e; + + if (max_step--<0) goto die("Simuration end."); + + list = list->next; + goto list->phils->next(list->phils,list); +} + +code scheduler(PhilsPtr phils, TaskPtr list) +{ + goto check(&always_flag, phils, list); + // goto next_next_task_fifo(list); +} + +code task_entry1(int count, PhilsPtr self, TaskPtr list, TaskPtr last); + +code task_entry2(int count,PhilsPtr self, TaskPtr list,TaskPtr last, TaskPtr q) +{ + if (!q) { + goto die("Can't allocate Task\n"); + } else { + add_memory_range(q,sizeof(Task),&mem); + goto enqueue(count, self, list, last, q, task_entry1); + } +} + +code task_entry1(int count, PhilsPtr self, TaskPtr list, TaskPtr last) +{ + StateDB out; + /* + printf("int count %d, PhilsPtr self %x, TaskPtr list %x, TaskPtr last %x\n", + count, self, list, last); + */ + + if (count++ < NUM_PHILOSOPHER) { + self = self->left; + goto create_queue(count,self,list,last,task_entry2); + } else { + // make circular task list + last->next = list; + st.memory = mem; + st.hash = get_memory_hash(mem,0); + lookup_StateDB(&st, &state_db, &out); + task_iter = create_task_iterator(list,out,0); + // start first task + goto list->phils->next(list->phils,list); + } +} + +code task_entry0(int count, PhilsPtr self, TaskPtr list, TaskPtr last, TaskPtr q) +{ + add_memory_range(q,sizeof(Task),&mem); + goto task_entry1(count, self, q, q); +} + +code init_final(PhilsPtr self) +{ + self->right = phils_list; + phils_list->left = self; + self->right_fork = phils_list->left_fork; + always_flag = 1; + //add_memory_range(&always_flag, sizeof(int), &mem); + //printf("init all\n"); + + goto create_queue(1, self, 0, 0, task_entry0); +} + +code init_phils2(PhilsPtr self, int count, int id) +{ + PhilsPtr tmp_self; + + tmp_self = (PhilsPtr)malloc(sizeof(Phils)); + if (!tmp_self) { + goto die("Can't allocate Phils\n"); + } + self->right = tmp_self; + tmp_self->id = id; + tmp_self->right_fork = NULL; + tmp_self->left_fork = self->right_fork; + tmp_self->right = NULL; + tmp_self->left = self; + tmp_self->next = pickup_lfork; + add_memory_range(tmp_self,sizeof(Phils),&mem); + + count--; + id++; + + if (count == 0) { + goto init_final(tmp_self); + } else { + goto init_fork2(tmp_self, count, id); + } +} + +code init_fork2(PhilsPtr self, int count, int id) +{ + ForkPtr tmp_fork; + + tmp_fork = (ForkPtr)malloc(sizeof(Fork)); + if (!tmp_fork) { + goto die("Can't allocate Fork\n"); + } + tmp_fork->id = id; + tmp_fork->owner = NULL; + self->right_fork = tmp_fork; + add_memory_range(tmp_fork,sizeof(Fork),&mem); + + goto init_phils2(self, count, id); +} + +code init_phils1(ForkPtr fork, int count, int id) +{ + PhilsPtr self; + + self = (PhilsPtr)malloc(sizeof(Phils)); + if (!self) { + goto die("Can't allocate Phils\n"); + } + phils_list = self; + self->id = id; + self->right_fork = NULL; + self->left_fork = fork; + self->right = NULL; + self->left = NULL; + self->next = pickup_lfork; + add_memory_range(self,sizeof(Phils),&mem); + + count--; + id++; + + goto init_fork2(self, count, id); +} + +code init_fork1(int count) +{ + ForkPtr fork; + int id = 1; + + fork = (ForkPtr)malloc(sizeof(Fork)); + if (!fork) { + goto die("Can't allocate Fork\n"); + } + fork->id = id; + fork->owner = NULL; + add_memory_range(fork,sizeof(Fork),&mem); + + goto init_phils1(fork, count, id); +} + +code die(char *err) +{ + printf("%s\n", err); + goto ret(1), env; +} + +int main(int ac, char *av[]) +{ + ret = return; + env = environment; + // srand((unsigned)time(NULL)); + // srandom((unsigned long)time(NULL)); + reset_state_count(); + srandom(555); + + if (ac==2) { + NUM_PHILOSOPHER = atoi(av[1]); + if (NUM_PHILOSOPHER >10 ||NUM_PHILOSOPHER < 2) { + printf("illegal number of philosopher = %d\n", NUM_PHILOSOPHER ); + return 1; + } + //printf("number of philosopher = %d\n", NUM_PHILOSOPHER ); + } + + goto init_fork1(NUM_PHILOSOPHER); +} + +/* end */