265 lines
9.3 KiB
C
265 lines
9.3 KiB
C
/**********************************************************************
|
|
|
|
The OPTYap Prolog system
|
|
OPTYap extends the Yap Prolog system to support or-parallel tabling
|
|
|
|
Copyright: R. Rocha and NCC - University of Porto, Portugal
|
|
File: or.cut.c
|
|
version: $Id: or.cut.c,v 1.3 2008-03-25 16:45:53 vsc Exp $
|
|
|
|
**********************************************************************/
|
|
|
|
/* ------------------ **
|
|
** Includes **
|
|
** ------------------ */
|
|
|
|
#include "Yap.h"
|
|
#ifdef YAPOR
|
|
#include "Yatom.h"
|
|
#include "YapHeap.h"
|
|
#include "or.macros.h"
|
|
#ifdef TABLING
|
|
#include "tab.macros.h"
|
|
#endif /* TABLING */
|
|
|
|
|
|
|
|
/* -------------------------- **
|
|
** Global functions **
|
|
** -------------------------- */
|
|
|
|
void prune_shared_branch(choiceptr prune_cp) {
|
|
int i, ltt, depth;
|
|
bitmap members;
|
|
choiceptr leftmost_cp;
|
|
or_fr_ptr leftmost_or_fr;
|
|
qg_sol_fr_ptr qg_solutions, aux_qg_solutions;
|
|
#ifdef TABLING_INNER_CUTS
|
|
tg_sol_fr_ptr tg_solutions, aux_tg_solutions;
|
|
#endif /* TABLING_INNER_CUTS */
|
|
|
|
leftmost_or_fr = CUT_leftmost_or_frame();
|
|
leftmost_cp = GetOrFr_node(leftmost_or_fr);
|
|
qg_solutions = NULL;
|
|
#ifdef TABLING_INNER_CUTS
|
|
tg_solutions = NULL;
|
|
#endif /* TABLING_INNER_CUTS */
|
|
if (EQUAL_OR_YOUNGER_CP(prune_cp, leftmost_cp)) {
|
|
/* pruning being leftmost */
|
|
or_fr_ptr prune_or_fr;
|
|
|
|
/* send prune requests */
|
|
prune_or_fr = prune_cp->cp_or_fr;
|
|
depth = OrFr_depth(prune_or_fr);
|
|
ltt = BRANCH_LTT(worker_id, depth);
|
|
LOCK_OR_FRAME(prune_or_fr);
|
|
members = OrFr_members(prune_or_fr);
|
|
BITMAP_delete(members, worker_id);
|
|
for (i = 0; i < number_workers; i++) {
|
|
if (BITMAP_member(members, i) && ltt == BRANCH_LTT(i, depth)) {
|
|
CUT_send_prune_request(i, prune_cp);
|
|
}
|
|
}
|
|
UNLOCK_OR_FRAME(prune_or_fr);
|
|
|
|
/* move up to prune_cp */
|
|
do {
|
|
ltt = BRANCH_LTT(worker_id, OrFr_depth(LOCAL_top_or_fr));
|
|
LOCK_OR_FRAME(LOCAL_top_or_fr);
|
|
aux_qg_solutions = OrFr_qg_solutions(LOCAL_top_or_fr);
|
|
#ifdef TABLING_INNER_CUTS
|
|
aux_tg_solutions = OrFr_tg_solutions(LOCAL_top_or_fr);
|
|
#endif /* TABLING_INNER_CUTS */
|
|
if (BITMAP_alone(OrFr_members(LOCAL_top_or_fr), worker_id)) {
|
|
#ifdef TABLING
|
|
if (OrFr_suspensions(LOCAL_top_or_fr) || OrFr_owners(LOCAL_top_or_fr) != 1)
|
|
pruning_over_tabling_data_structures();
|
|
#endif /* TABLING */
|
|
FREE_OR_FRAME(LOCAL_top_or_fr);
|
|
} else {
|
|
OrFr_qg_solutions(LOCAL_top_or_fr) = NULL;
|
|
#ifdef TABLING_INNER_CUTS
|
|
OrFr_tg_solutions(LOCAL_top_or_fr) = NULL;
|
|
#endif /* TABLING_INNER_CUTS */
|
|
OrFr_alternative(LOCAL_top_or_fr) = NULL;
|
|
BITMAP_delete(OrFr_members(LOCAL_top_or_fr), worker_id);
|
|
#ifdef TABLING
|
|
OrFr_owners(LOCAL_top_or_fr)--;
|
|
#endif /* TABLING */
|
|
UNLOCK_OR_FRAME(LOCAL_top_or_fr);
|
|
}
|
|
if ((aux_qg_solutions = CUT_prune_solution_frames(aux_qg_solutions, ltt))) {
|
|
CUT_join_answers_in_an_unique_frame(aux_qg_solutions);
|
|
SolFr_next(aux_qg_solutions) = qg_solutions;
|
|
qg_solutions = aux_qg_solutions;
|
|
}
|
|
#ifdef TABLING_INNER_CUTS
|
|
if ((aux_tg_solutions = CUT_prune_tg_solution_frames(aux_tg_solutions, ltt))) {
|
|
CUT_join_tg_solutions(& tg_solutions, aux_tg_solutions);
|
|
}
|
|
#endif /* TABLING_INNER_CUTS */
|
|
SCH_update_local_or_tops();
|
|
} while (Get_LOCAL_top_cp() != prune_cp);
|
|
|
|
#ifdef YAPOR_ERRORS
|
|
if (Get_LOCAL_prune_request() && EQUAL_OR_YOUNGER_CP(Get_LOCAL_prune_request(), Get_LOCAL_top_cp()))
|
|
YAPOR_ERROR_MESSAGE("EQUAL_OR_YOUNGER_CP(LOCAL_prune_request, LOCAL_top_cp) (prune_shared_branch)");
|
|
#endif /* YAPOR_ERRORS */
|
|
/* store answers not pruned */
|
|
if (qg_solutions)
|
|
CUT_join_answers_in_an_unique_frame(qg_solutions);
|
|
LOCK_OR_FRAME(leftmost_or_fr);
|
|
if (Get_LOCAL_prune_request()) {
|
|
UNLOCK_OR_FRAME(leftmost_or_fr);
|
|
if (qg_solutions)
|
|
CUT_free_solution_frame(qg_solutions);
|
|
#ifdef TABLING_INNER_CUTS
|
|
CUT_free_tg_solution_frames(tg_solutions);
|
|
#endif /* TABLING_INNER_CUTS */
|
|
} else {
|
|
if (qg_solutions)
|
|
CUT_store_answers(leftmost_or_fr, qg_solutions);
|
|
#ifdef TABLING_INNER_CUTS
|
|
if (tg_solutions)
|
|
tg_solutions = CUT_store_tg_answers(leftmost_or_fr, tg_solutions, BRANCH_LTT(worker_id, OrFr_depth(leftmost_or_fr)));
|
|
#endif /* TABLING_INNER_CUTS */
|
|
UNLOCK_OR_FRAME(leftmost_or_fr);
|
|
#ifdef TABLING_INNER_CUTS
|
|
CUT_validate_tg_answers(tg_solutions);
|
|
#endif /* TABLING_INNER_CUTS */
|
|
}
|
|
} else {
|
|
/* pruning not being leftmost */
|
|
int prune_more;
|
|
prune_more = 1;
|
|
|
|
/* send prune requests */
|
|
depth = OrFr_depth(leftmost_or_fr);
|
|
ltt = BRANCH_LTT(worker_id, depth);
|
|
LOCK_OR_FRAME(leftmost_or_fr);
|
|
members = OrFr_members(leftmost_or_fr);
|
|
BITMAP_delete(members, worker_id);
|
|
for (i = 0; i < number_workers; i++) {
|
|
if (BITMAP_member(members, i)) {
|
|
if (ltt >= BRANCH_LTT(i, depth)) {
|
|
CUT_send_prune_request(i, leftmost_cp->cp_b);
|
|
} else if (BRANCH_CUT(i, depth)) {
|
|
prune_more = 0;
|
|
}
|
|
}
|
|
}
|
|
UNLOCK_OR_FRAME(leftmost_or_fr);
|
|
|
|
/* move up to leftmost_cp */
|
|
while (Get_LOCAL_top_cp() != leftmost_cp) {
|
|
ltt = BRANCH_LTT(worker_id, OrFr_depth(LOCAL_top_or_fr));
|
|
LOCK_OR_FRAME(LOCAL_top_or_fr);
|
|
if (Get_OrFr_pend_prune_cp(LOCAL_top_or_fr))
|
|
prune_more = 0;
|
|
aux_qg_solutions = OrFr_qg_solutions(LOCAL_top_or_fr);
|
|
#ifdef TABLING_INNER_CUTS
|
|
aux_tg_solutions = OrFr_tg_solutions(LOCAL_top_or_fr);
|
|
#endif /* TABLING_INNER_CUTS */
|
|
if (BITMAP_alone(OrFr_members(LOCAL_top_or_fr), worker_id)) {
|
|
#ifdef TABLING
|
|
if (OrFr_suspensions(LOCAL_top_or_fr) || OrFr_owners(LOCAL_top_or_fr) != 1)
|
|
pruning_over_tabling_data_structures();
|
|
#endif /* TABLING */
|
|
FREE_OR_FRAME(LOCAL_top_or_fr);
|
|
} else {
|
|
OrFr_qg_solutions(LOCAL_top_or_fr) = NULL;
|
|
#ifdef TABLING_INNER_CUTS
|
|
OrFr_tg_solutions(LOCAL_top_or_fr) = NULL;
|
|
#endif /* TABLING_INNER_CUTS */
|
|
OrFr_alternative(LOCAL_top_or_fr) = NULL;
|
|
BITMAP_delete(OrFr_members(LOCAL_top_or_fr), worker_id);
|
|
#ifdef TABLING
|
|
OrFr_owners(LOCAL_top_or_fr)--;
|
|
#endif /* TABLING */
|
|
UNLOCK_OR_FRAME(LOCAL_top_or_fr);
|
|
}
|
|
if ((aux_qg_solutions = CUT_prune_solution_frames(aux_qg_solutions, ltt))) {
|
|
CUT_join_answers_in_an_unique_frame(aux_qg_solutions);
|
|
SolFr_next(aux_qg_solutions) = qg_solutions;
|
|
qg_solutions = aux_qg_solutions;
|
|
}
|
|
#ifdef TABLING_INNER_CUTS
|
|
if ((aux_tg_solutions = CUT_prune_tg_solution_frames(aux_tg_solutions, ltt))) {
|
|
CUT_join_tg_solutions(& tg_solutions, aux_tg_solutions);
|
|
}
|
|
#endif /* TABLING_INNER_CUTS */
|
|
SCH_update_local_or_tops();
|
|
}
|
|
|
|
#ifdef YAPOR_ERRORS
|
|
if (Get_LOCAL_prune_request() && EQUAL_OR_YOUNGER_CP(Get_LOCAL_prune_request(), Get_LOCAL_top_cp()))
|
|
YAPOR_ERROR_MESSAGE("EQUAL_OR_YOUNGER_CP(LOCAL_prune_request, Get_LOCAL_top_cp()) (prune_shared_branch)");
|
|
#endif /* YAPOR_ERRORS */
|
|
/* store answers not pruned */
|
|
if (qg_solutions)
|
|
CUT_join_answers_in_an_unique_frame(qg_solutions);
|
|
LOCK_OR_FRAME(leftmost_or_fr);
|
|
if (Get_LOCAL_prune_request()) {
|
|
UNLOCK_OR_FRAME(leftmost_or_fr);
|
|
if (qg_solutions)
|
|
CUT_free_solution_frame(qg_solutions);
|
|
#ifdef TABLING_INNER_CUTS
|
|
CUT_free_tg_solution_frames(tg_solutions);
|
|
#endif /* TABLING_INNER_CUTS */
|
|
} else {
|
|
ltt = BRANCH_LTT(worker_id, depth);
|
|
if (qg_solutions)
|
|
CUT_store_answers(leftmost_or_fr, qg_solutions);
|
|
#ifdef TABLING_INNER_CUTS
|
|
if (tg_solutions)
|
|
tg_solutions = CUT_store_tg_answers(leftmost_or_fr, tg_solutions, ltt);
|
|
#endif /* TABLING_INNER_CUTS */
|
|
if (Get_OrFr_pend_prune_cp(leftmost_or_fr))
|
|
prune_more = 0;
|
|
OrFr_alternative(leftmost_or_fr) = NULL;
|
|
Set_OrFr_pend_prune_cp(leftmost_or_fr, prune_cp);
|
|
OrFr_pend_prune_ltt(leftmost_or_fr) = ltt;
|
|
UNLOCK_OR_FRAME(leftmost_or_fr);
|
|
#ifdef TABLING_INNER_CUTS
|
|
CUT_validate_tg_answers(tg_solutions);
|
|
#endif /* TABLING_INNER_CUTS */
|
|
|
|
/* continue pruning to prune_cp */
|
|
if (prune_more) {
|
|
BITMAP_copy(members, OrFr_members(leftmost_or_fr));
|
|
leftmost_cp = leftmost_cp->cp_b;
|
|
while (leftmost_cp != prune_cp) {
|
|
leftmost_or_fr = leftmost_cp->cp_or_fr;
|
|
depth = OrFr_depth(leftmost_or_fr);
|
|
ltt = BRANCH_LTT(worker_id, depth);
|
|
LOCK_OR_FRAME(leftmost_or_fr);
|
|
BITMAP_difference(members, OrFr_members(leftmost_or_fr), members);
|
|
for (i = 0; i < number_workers; i++) {
|
|
if (BITMAP_member(members, i)) {
|
|
if (ltt > BRANCH_LTT(i, depth)) {
|
|
CUT_send_prune_request(i, leftmost_cp->cp_b);
|
|
} else if (BRANCH_CUT(i, depth)) {
|
|
UNLOCK_OR_FRAME(leftmost_or_fr);
|
|
goto end_prune_more;
|
|
}
|
|
}
|
|
}
|
|
OrFr_alternative(leftmost_or_fr) = NULL;
|
|
UNLOCK_OR_FRAME(leftmost_or_fr);
|
|
BITMAP_copy(members, OrFr_members(leftmost_or_fr));
|
|
leftmost_cp = leftmost_cp->cp_b;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
end_prune_more:
|
|
CUT_reset_prune_request();
|
|
#ifdef TABLING
|
|
Set_LOCAL_top_cp_on_stack(Get_LOCAL_top_cp());
|
|
#endif /* TABLING */
|
|
|
|
return;
|
|
}
|
|
#endif /* YAPOR */
|