415 lines
14 KiB
C
415 lines
14 KiB
C
/* ------------------ **
|
|
** Includes **
|
|
** ------------------ */
|
|
|
|
#include "Yap.h"
|
|
#if defined(TABLING) && defined(YAPOR)
|
|
#include "Yatom.h"
|
|
#include "Heap.h"
|
|
#include "tab.macros.h"
|
|
#include "or.macros.h"
|
|
|
|
|
|
|
|
/* ------------------------------------- **
|
|
** Local functions declaration **
|
|
** ------------------------------------- */
|
|
|
|
static void complete_suspension_branch(susp_fr_ptr susp_fr, choiceptr top_cp, or_fr_ptr *chain_or_fr, dep_fr_ptr *chain_dep_fr);
|
|
|
|
|
|
|
|
/* -------------------------- **
|
|
** Global functions **
|
|
** -------------------------- */
|
|
|
|
void public_completion(void) {
|
|
dep_fr_ptr chain_dep_fr, next_dep_fr;
|
|
or_fr_ptr chain_or_fr, top_or_fr, next_or_fr;
|
|
susp_fr_ptr susp_fr, next_susp_fr;
|
|
qg_sol_fr_ptr solutions, aux_solutions;
|
|
|
|
if (YOUNGER_CP(LOCAL_top_cp, B_FZ)) {
|
|
/* the current node is a generator node without younger consumer **
|
|
** nodes --> we only have the current node to complete */
|
|
sg_fr_ptr top_sg_fr;
|
|
|
|
/* complete subgoals */
|
|
top_sg_fr = SgFr_next(GEN_CP_SG_FR(LOCAL_top_cp));
|
|
do {
|
|
mark_as_completed(LOCAL_top_sg_fr);
|
|
LOCAL_top_sg_fr = SgFr_next(LOCAL_top_sg_fr);
|
|
} while (LOCAL_top_sg_fr != top_sg_fr);
|
|
|
|
/* no dependency frames to release */
|
|
chain_dep_fr = NULL;
|
|
|
|
/* no need to adjust freeze registers */
|
|
} else {
|
|
/* the current node is a leader node with younger consumer **
|
|
** nodes ---> we need to complete all dependent subgoals */
|
|
|
|
/* complete subgoals */
|
|
if (DepFr_leader_dep_is_on_stack(LOCAL_top_dep_fr)) {
|
|
while (LOCAL_top_sg_fr &&
|
|
EQUAL_OR_YOUNGER_CP(SgFr_gen_cp(LOCAL_top_sg_fr), LOCAL_top_cp)) {
|
|
mark_as_completed(LOCAL_top_sg_fr);
|
|
LOCAL_top_sg_fr = SgFr_next(LOCAL_top_sg_fr);
|
|
}
|
|
} else {
|
|
while (LOCAL_top_sg_fr &&
|
|
YOUNGER_CP(SgFr_gen_cp(LOCAL_top_sg_fr), LOCAL_top_cp)) {
|
|
mark_as_completed(LOCAL_top_sg_fr);
|
|
LOCAL_top_sg_fr = SgFr_next(LOCAL_top_sg_fr);
|
|
}
|
|
}
|
|
|
|
/* chain dependency frames to release */
|
|
chain_dep_fr = NULL;
|
|
while (YOUNGER_CP(DepFr_cons_cp(LOCAL_top_dep_fr), LOCAL_top_cp)) {
|
|
LOCK(DepFr_lock(LOCAL_top_dep_fr));
|
|
next_dep_fr = DepFr_next(LOCAL_top_dep_fr);
|
|
DepFr_next(LOCAL_top_dep_fr) = chain_dep_fr;
|
|
chain_dep_fr = LOCAL_top_dep_fr;
|
|
LOCAL_top_dep_fr = next_dep_fr;
|
|
}
|
|
|
|
/* adjust freeze registers */
|
|
adjust_freeze_registers();
|
|
}
|
|
|
|
/* chain or-frames to release */
|
|
chain_or_fr = NULL;
|
|
top_or_fr = LOCAL_top_cp_on_stack->cp_or_fr;
|
|
while (top_or_fr != LOCAL_top_or_fr) {
|
|
or_fr_ptr next_or_fr_on_stack;
|
|
LOCK_OR_FRAME(top_or_fr);
|
|
susp_fr = OrFr_suspensions(top_or_fr);
|
|
while (susp_fr) {
|
|
complete_suspension_branch(susp_fr, OrFr_node(top_or_fr), &chain_or_fr, &chain_dep_fr);
|
|
next_susp_fr = SuspFr_next(susp_fr);
|
|
FREE_SUSPENSION_FRAME(susp_fr);
|
|
susp_fr = next_susp_fr;
|
|
}
|
|
next_or_fr_on_stack = OrFr_next_on_stack(top_or_fr);
|
|
OrFr_next_on_stack(top_or_fr) = chain_or_fr;
|
|
chain_or_fr = top_or_fr;
|
|
top_or_fr = next_or_fr_on_stack;
|
|
}
|
|
LOCK_OR_FRAME(top_or_fr);
|
|
susp_fr = OrFr_suspensions(top_or_fr);
|
|
while (susp_fr) {
|
|
complete_suspension_branch(susp_fr, OrFr_node(top_or_fr), &chain_or_fr, &chain_dep_fr);
|
|
next_susp_fr = SuspFr_next(susp_fr);
|
|
FREE_SUSPENSION_FRAME(susp_fr);
|
|
susp_fr = next_susp_fr;
|
|
}
|
|
OrFr_suspensions(top_or_fr) = NULL;
|
|
OrFr_nearest_suspnode(top_or_fr) = top_or_fr;
|
|
UNLOCK_OR_FRAME(top_or_fr);
|
|
|
|
/* release dependency frames */
|
|
while (chain_dep_fr) {
|
|
next_dep_fr = DepFr_next(chain_dep_fr);
|
|
FREE_DEPENDENCY_FRAME(chain_dep_fr);
|
|
chain_dep_fr = next_dep_fr;
|
|
}
|
|
|
|
/* release or frames */
|
|
solutions = NULL;
|
|
while (chain_or_fr) {
|
|
aux_solutions = OrFr_qg_solutions(chain_or_fr);
|
|
if (aux_solutions) {
|
|
CUT_join_answers_in_an_unique_frame(aux_solutions);
|
|
SolFr_next(aux_solutions) = solutions;
|
|
solutions = aux_solutions;
|
|
}
|
|
next_or_fr = OrFr_next_on_stack(chain_or_fr);
|
|
FREE_OR_FRAME(chain_or_fr);
|
|
chain_or_fr = next_or_fr;
|
|
}
|
|
if (solutions) {
|
|
CUT_join_answers_in_an_unique_frame(solutions);
|
|
SolFr_next(solutions) = OrFr_qg_solutions(LOCAL_top_or_fr);
|
|
OrFr_qg_solutions(LOCAL_top_or_fr) = solutions;
|
|
}
|
|
|
|
/* adjust top register */
|
|
LOCAL_top_cp_on_stack = LOCAL_top_cp;
|
|
|
|
return;
|
|
}
|
|
|
|
|
|
void complete_suspension_frames(or_fr_ptr or_fr) {
|
|
dep_fr_ptr chain_dep_fr;
|
|
or_fr_ptr chain_or_fr;
|
|
susp_fr_ptr susp_fr;
|
|
qg_sol_fr_ptr solutions;
|
|
|
|
/* complete suspension frames */
|
|
chain_dep_fr = NULL;
|
|
chain_or_fr = NULL;
|
|
susp_fr = OrFr_suspensions(or_fr);
|
|
do {
|
|
susp_fr_ptr next_susp_fr;
|
|
complete_suspension_branch(susp_fr, OrFr_node(or_fr), &chain_or_fr, &chain_dep_fr);
|
|
next_susp_fr = SuspFr_next(susp_fr);
|
|
FREE_SUSPENSION_FRAME(susp_fr);
|
|
susp_fr = next_susp_fr;
|
|
} while (susp_fr);
|
|
OrFr_suspensions(or_fr) = NULL;
|
|
OrFr_nearest_suspnode(or_fr) = or_fr;
|
|
|
|
/* release dependency frames */
|
|
while (chain_dep_fr) {
|
|
dep_fr_ptr next_dep_fr;
|
|
next_dep_fr = DepFr_next(chain_dep_fr);
|
|
FREE_DEPENDENCY_FRAME(chain_dep_fr);
|
|
chain_dep_fr = next_dep_fr;
|
|
}
|
|
|
|
/* release or frames */
|
|
solutions = NULL;
|
|
while (chain_or_fr) {
|
|
or_fr_ptr next_or_fr;
|
|
qg_sol_fr_ptr aux_solutions;
|
|
aux_solutions = OrFr_qg_solutions(chain_or_fr);
|
|
if (aux_solutions) {
|
|
CUT_join_answers_in_an_unique_frame(aux_solutions);
|
|
SolFr_next(aux_solutions) = solutions;
|
|
solutions = aux_solutions;
|
|
}
|
|
next_or_fr = OrFr_next_on_stack(chain_or_fr);
|
|
FREE_OR_FRAME(chain_or_fr);
|
|
chain_or_fr = next_or_fr;
|
|
}
|
|
if (solutions) {
|
|
CUT_join_answers_in_an_unique_frame(solutions);
|
|
SolFr_next(solutions) = OrFr_qg_solutions(or_fr);
|
|
OrFr_qg_solutions(LOCAL_top_or_fr) = solutions;
|
|
}
|
|
|
|
return;
|
|
}
|
|
|
|
|
|
void suspend_branch(void) {
|
|
or_fr_ptr or_frame;
|
|
|
|
/* suspension only occurs in shared nodes that **
|
|
** are leaders with younger consumer nodes */
|
|
#ifdef OPTYAP_ERRORS
|
|
if (LOCAL_top_cp->cp_or_fr != LOCAL_top_or_fr)
|
|
OPTYAP_ERROR_MESSAGE("LOCAL_top_cp->cp_or_fr != LOCAL_top_or_fr (suspend_branch)");
|
|
if (B_FZ == LOCAL_top_cp)
|
|
OPTYAP_ERROR_MESSAGE("B_FZ = LOCAL_top_cp (suspend_branch)");
|
|
if (YOUNGER_CP(LOCAL_top_cp, LOCAL_top_cp_on_stack))
|
|
OPTYAP_ERROR_MESSAGE("YOUNGER_CP(LOCAL_top_cp, LOCAL_top_cp_on_stack) (suspend_branch)");
|
|
if (LOCAL_top_cp->cp_or_fr != LOCAL_top_or_fr)
|
|
OPTYAP_ERROR_MESSAGE("LOCAL_top_cp->cp_or_fr != LOCAL_top_or_fr (suspend_branch)");
|
|
or_frame = LOCAL_top_cp_on_stack->cp_or_fr;
|
|
while (or_frame != LOCAL_top_or_fr) {
|
|
if (YOUNGER_CP(LOCAL_top_cp, OrFr_node(or_frame))) {
|
|
OPTYAP_ERROR_MESSAGE("YOUNGER_CP(LOCAL_top_cp, OrFr_node(or_frame)) (suspend_branch)");
|
|
break;
|
|
}
|
|
or_frame = OrFr_next_on_stack(or_frame);
|
|
}
|
|
#endif /* OPTYAP_ERRORS */
|
|
|
|
or_frame = LOCAL_top_cp_on_stack->cp_or_fr;
|
|
LOCK_OR_FRAME(or_frame);
|
|
if (B_FZ == LOCAL_top_cp_on_stack && OrFr_owners(or_frame) > 1) {
|
|
/* there are other workers sharing the whole branch **
|
|
** --> we can avoid suspension <-- */
|
|
|
|
/* update shared nodes */
|
|
OrFr_owners(or_frame)--;
|
|
UNLOCK_OR_FRAME(or_frame);
|
|
or_frame = OrFr_next_on_stack(or_frame);
|
|
while (or_frame != LOCAL_top_or_fr) {
|
|
LOCK_OR_FRAME(or_frame);
|
|
OrFr_owners(or_frame)--;
|
|
UNLOCK_OR_FRAME(or_frame);
|
|
or_frame = OrFr_next_on_stack(or_frame);
|
|
}
|
|
} else {
|
|
/* the branch has private parts **
|
|
** --> suspend branch <-- */
|
|
susp_fr_ptr new_susp_fr;
|
|
long h_size, b_size, tr_size;
|
|
UNLOCK_OR_FRAME(or_frame);
|
|
|
|
/* alloc suspension frame */
|
|
h_size = (unsigned long) H_FZ - (unsigned long) LOCAL_top_cp->cp_h;
|
|
b_size = (unsigned long) LOCAL_top_cp - (unsigned long) B_FZ;
|
|
tr_size = (unsigned long) TR_FZ - (unsigned long) LOCAL_top_cp->cp_tr;
|
|
new_suspension_frame(new_susp_fr, LOCAL_top_cp_on_stack->cp_or_fr, LOCAL_top_dep_fr, LOCAL_top_sg_fr,
|
|
LOCAL_top_cp->cp_h, B_FZ, LOCAL_top_cp->cp_tr, h_size, b_size, tr_size);
|
|
|
|
/* store suspension frame in current top or-frame */
|
|
LOCK_OR_FRAME(LOCAL_top_or_fr);
|
|
if (OrFr_nearest_suspnode(LOCAL_top_or_fr) == LOCAL_top_or_fr)
|
|
OrFr_nearest_suspnode(LOCAL_top_or_fr) = NULL;
|
|
SuspFr_next(new_susp_fr) = OrFr_suspensions(LOCAL_top_or_fr);
|
|
OrFr_suspensions(LOCAL_top_or_fr) = new_susp_fr;
|
|
UNLOCK_OR_FRAME(LOCAL_top_or_fr);
|
|
}
|
|
|
|
/* adjust top pointers */
|
|
while (LOCAL_top_sg_fr && YOUNGER_CP(SgFr_gen_cp(LOCAL_top_sg_fr), LOCAL_top_cp_on_stack)) {
|
|
SgFr_gen_worker(LOCAL_top_sg_fr) = MAX_WORKERS;
|
|
LOCAL_top_sg_fr = SgFr_next(LOCAL_top_sg_fr);
|
|
}
|
|
while (LOCAL_top_sg_fr && YOUNGER_CP(SgFr_gen_cp(LOCAL_top_sg_fr), LOCAL_top_cp)) {
|
|
LOCAL_top_sg_fr = SgFr_next(LOCAL_top_sg_fr);
|
|
}
|
|
while (YOUNGER_CP(DepFr_cons_cp(LOCAL_top_dep_fr), LOCAL_top_cp)) {
|
|
LOCAL_top_dep_fr = DepFr_next(LOCAL_top_dep_fr);
|
|
}
|
|
LOCAL_top_cp_on_stack = LOCAL_top_cp;
|
|
|
|
/* adjust freeze registers */
|
|
adjust_freeze_registers();
|
|
|
|
return;
|
|
}
|
|
|
|
|
|
void resume_suspension_frame(susp_fr_ptr resume_fr, or_fr_ptr top_or_fr) {
|
|
or_fr_ptr or_frame;
|
|
sg_fr_ptr sg_frame;
|
|
|
|
/* copy suspended stacks */
|
|
memcpy(SuspFr_global_reg(resume_fr),
|
|
SuspFr_global_start(resume_fr),
|
|
SuspFr_global_size(resume_fr));
|
|
memcpy(SuspFr_local_reg(resume_fr),
|
|
SuspFr_local_start(resume_fr),
|
|
SuspFr_local_size(resume_fr));
|
|
memcpy(SuspFr_trail_reg(resume_fr),
|
|
SuspFr_trail_start(resume_fr),
|
|
SuspFr_trail_size(resume_fr));
|
|
|
|
#ifdef OPTYAP_ERRORS
|
|
if (CONS_CP(DepFr_cons_cp(SuspFr_top_dep_fr(resume_fr)))->ccp_h != SuspFr_global_reg(resume_fr) + SuspFr_global_size(resume_fr))
|
|
OPTYAP_ERROR_MESSAGE("DepFr_cons_cp(SuspFr_top_dep_fr)->cp_h != SuspFr_global_reg + SuspFr_global_size (resume_suspension_frame)");
|
|
if (CONS_CP(DepFr_cons_cp(SuspFr_top_dep_fr(resume_fr)))->ccp_tr != SuspFr_trail_reg(resume_fr) + SuspFr_trail_size(resume_fr))
|
|
OPTYAP_ERROR_MESSAGE("DepFr_cons_cp(SuspFr_top_dep_fr)->cp_tr != SuspFr_trail_reg + SuspFr_trail_size (resume_suspension_frame)");
|
|
if (DepFr_cons_cp(SuspFr_top_dep_fr(resume_fr)) != SuspFr_local_reg(resume_fr))
|
|
OPTYAP_ERROR_MESSAGE("DepFr_cons_cp(SuspFr_top_dep_fr) != SuspFr_local_reg (resume_suspension_frame)");
|
|
if ((void *)LOCAL_top_cp < SuspFr_local_reg(resume_fr) + SuspFr_local_size(resume_fr))
|
|
OPTYAP_ERROR_MESSAGE("LOCAL_top_cp < SuspFr_local_reg + SuspFr_local_size (resume_suspension_frame)");
|
|
#endif /* OPTYAP_ERRORS */
|
|
|
|
/* update shared nodes */
|
|
or_frame = top_or_fr;
|
|
while (or_frame != LOCAL_top_or_fr) {
|
|
LOCK_OR_FRAME(or_frame);
|
|
OrFr_owners(or_frame)++;
|
|
UNLOCK_OR_FRAME(or_frame);
|
|
or_frame = OrFr_next_on_stack(or_frame);
|
|
}
|
|
or_frame = top_or_fr;
|
|
while (or_frame != LOCAL_top_or_fr) {
|
|
LOCK_OR_FRAME(or_frame);
|
|
BITMAP_insert(OrFr_members(or_frame), worker_id);
|
|
BRANCH(worker_id, OrFr_depth(or_frame)) = 1;
|
|
UNLOCK_OR_FRAME(or_frame);
|
|
or_frame = OrFr_next(or_frame);
|
|
}
|
|
|
|
/* adjust top pointers */
|
|
LOCAL_top_or_fr = top_or_fr;
|
|
LOCAL_top_cp = OrFr_node(top_or_fr);
|
|
LOCAL_top_sg_fr = SuspFr_top_sg_fr(resume_fr);
|
|
LOCAL_top_dep_fr = SuspFr_top_dep_fr(resume_fr);
|
|
LOCAL_top_cp_on_stack = OrFr_node(SuspFr_top_or_fr_on_stack(resume_fr));
|
|
sg_frame = LOCAL_top_sg_fr;
|
|
while (sg_frame && YOUNGER_CP(SgFr_gen_cp(sg_frame), LOCAL_top_cp_on_stack)) {
|
|
SgFr_gen_worker(sg_frame) = worker_id;
|
|
sg_frame = SgFr_next(sg_frame);
|
|
}
|
|
|
|
/* adjust freeze registers */
|
|
adjust_freeze_registers();
|
|
|
|
/* free suspension frame */
|
|
FREE_SUSPENSION_FRAME(resume_fr);
|
|
|
|
return;
|
|
}
|
|
|
|
|
|
|
|
/* ------------------------- **
|
|
** Local functions **
|
|
** ------------------------- */
|
|
|
|
static
|
|
void complete_suspension_branch(susp_fr_ptr susp_fr, choiceptr top_cp, or_fr_ptr *chain_or_fr, dep_fr_ptr *chain_dep_fr) {
|
|
or_fr_ptr aux_or_fr;
|
|
sg_fr_ptr aux_sg_fr;
|
|
dep_fr_ptr aux_dep_fr;
|
|
|
|
/* complete all subgoals */
|
|
aux_dep_fr = SuspFr_top_dep_fr(susp_fr);
|
|
aux_sg_fr = SuspFr_top_sg_fr(susp_fr);
|
|
if (DepFr_leader_dep_is_on_stack(aux_dep_fr)) {
|
|
while (aux_sg_fr &&
|
|
! SgFr_state(aux_sg_fr) &&
|
|
EQUAL_OR_YOUNGER_CP(SgFr_gen_cp(aux_sg_fr), top_cp)) {
|
|
mark_as_completed(aux_sg_fr);
|
|
aux_sg_fr = SgFr_next(aux_sg_fr);
|
|
}
|
|
} else {
|
|
while (aux_sg_fr &&
|
|
! SgFr_state(aux_sg_fr) &&
|
|
YOUNGER_CP(SgFr_gen_cp(aux_sg_fr), top_cp)) {
|
|
mark_as_completed(aux_sg_fr);
|
|
aux_sg_fr = SgFr_next(aux_sg_fr);
|
|
}
|
|
}
|
|
|
|
/* chain dependency frames to release (using DepFr_next) */
|
|
while (IS_UNLOCKED(DepFr_lock(aux_dep_fr)) &&
|
|
YOUNGER_CP(DepFr_cons_cp(aux_dep_fr), top_cp)) {
|
|
dep_fr_ptr next_dep_fr;
|
|
LOCK(DepFr_lock(aux_dep_fr));
|
|
next_dep_fr = DepFr_next(aux_dep_fr);
|
|
DepFr_next(aux_dep_fr) = *chain_dep_fr;
|
|
*chain_dep_fr = aux_dep_fr;
|
|
aux_dep_fr = next_dep_fr;
|
|
}
|
|
|
|
/* chain or-frames to release (using OrFr_next_on_stack) **
|
|
** we use the OrFr_next_on_stack field instead of OrFr_next **
|
|
** to avoid conflicts with the 'find_dependency_node' macro */
|
|
aux_or_fr = SuspFr_top_or_fr_on_stack(susp_fr);
|
|
while (IS_UNLOCKED(OrFr_lock(aux_or_fr))) {
|
|
susp_fr_ptr aux_susp_fr;
|
|
or_fr_ptr next_or_fr_on_stack;
|
|
#ifdef OPTYAP_ERRORS
|
|
if (YOUNGER_CP(top_cp, OrFr_node(aux_or_fr)))
|
|
OPTYAP_ERROR_MESSAGE("YOUNGER_CP(top_cp, OrFr_node(aux_or_fr)) (complete_suspension_branch)");
|
|
#endif /* OPTYAP_ERRORS */
|
|
LOCK_OR_FRAME(aux_or_fr);
|
|
aux_susp_fr = OrFr_suspensions(aux_or_fr);
|
|
while (aux_susp_fr) {
|
|
susp_fr_ptr next_susp_fr;
|
|
complete_suspension_branch(aux_susp_fr, OrFr_node(aux_or_fr), chain_or_fr, chain_dep_fr);
|
|
next_susp_fr = SuspFr_next(aux_susp_fr);
|
|
FREE_SUSPENSION_FRAME(aux_susp_fr);
|
|
aux_susp_fr = next_susp_fr;
|
|
}
|
|
next_or_fr_on_stack = OrFr_next_on_stack(aux_or_fr);
|
|
OrFr_next_on_stack(aux_or_fr) = *chain_or_fr;
|
|
*chain_or_fr = aux_or_fr;
|
|
aux_or_fr = next_or_fr_on_stack;
|
|
}
|
|
|
|
return;
|
|
}
|
|
#endif /* TABLING && YAPOR */
|