This repository has been archived on 2023-08-20. You can view files and clone it, but cannot push or open issues or pull requests.
yap-6.3/OPTYap/or.insts.i
vsc 3759aa571b misc changes
git-svn-id: https://yap.svn.sf.net/svnroot/yap/trunk@136 b08c6af1-5177-4d33-ba66-4b1c6b8b522a
2001-08-09 14:01:20 +00:00

93 lines
2.9 KiB
OpenEdge ABL

/* -------------------------------- **
** Scheduler instructions **
** -------------------------------- */
PBOp(getwork_first_time,e)
/* wait for a new parallel goal */
while (BITMAP_same(GLOBAL_bm_present_workers, GLOBAL_bm_finished_workers));
make_root_choice_point();
PUT_IN_EXECUTING(worker_id);
/* wait until everyone else is executing! */
while (! BITMAP_same(GLOBAL_bm_present_workers, GLOBAL_bm_executing_workers));
SCHEDULER_GET_WORK();
shared_end:
PUT_IN_FINISHED(worker_id);
/* wait until everyone else is finished! */
while (! BITMAP_same(GLOBAL_bm_present_workers, GLOBAL_bm_finished_workers));
PUT_OUT_EXECUTING(worker_id);
if (worker_id == 0) {
finish_yapor();
free_root_choice_point();
/* wait until no one is executing */
while (! BITMAP_empty(GLOBAL_bm_executing_workers));
goto fail;
} else {
PREG = GETWORK_FIRST_TIME;
PREFETCH_OP(PREG);
GONext();
}
ENDPBOp();
PBOp(getwork,ld)
#ifdef TABLING
if (DepFr_leader_cp(LOCAL_top_dep_fr) == LOCAL_top_cp) {
/* the current top node is a leader node with consumer nodes below */
if (DepFr_leader_dep_is_on_stack(LOCAL_top_dep_fr)) {
/* the frozen branch depends on the current top node **
** this means that the current top node is a generator node */
LOCK_OR_FRAME(LOCAL_top_or_fr);
#ifdef TABLING_BATCHED_SCHEDULING
if (OrFr_alternative(LOCAL_top_or_fr) != GEN_CP_NULL_ALT) {
#else /* TABLING_LOCAL_SCHEDULING */
if (OrFr_alternative(LOCAL_top_or_fr) != GEN_CP_NULL_ALT || B_FZ == LOCAL_top_cp) {
#endif /* TABLING_SCHEDULING */
/* the current top node has unexploited alternatives ---> we should **
** exploit all the available alternatives before execute completion */
PREG = OrFr_alternative(LOCAL_top_or_fr);
PREFETCH_OP(PREG);
GONext();
}
UNLOCK_OR_FRAME(LOCAL_top_or_fr);
}
goto completion;
}
#endif /* TABLING */
LOCK_OR_FRAME(LOCAL_top_or_fr);
if (OrFr_alternative(LOCAL_top_or_fr)) {
PREG = OrFr_alternative(LOCAL_top_or_fr);
PREFETCH_OP(PREG);
GONext();
} else {
UNLOCK_OR_FRAME(LOCAL_top_or_fr);
SCHEDULER_GET_WORK();
}
ENDPBOp();
/* The idea is to check whether we are the last worker in the node.
If we are, we can go ahead, otherwise we should call the scheduler. */
PBOp(getwork_seq,ld)
LOCK_OR_FRAME(LOCAL_top_or_fr);
if (OrFr_alternative(LOCAL_top_or_fr) &&
BITMAP_alone(OrFr_members(LOCAL_top_or_fr), worker_id)) {
PREG = OrFr_alternative(LOCAL_top_or_fr);
PREFETCH_OP(PREG);
GONext();
} else {
UNLOCK_OR_FRAME(LOCAL_top_or_fr);
SCHEDULER_GET_WORK();
}
ENDPBOp();
PBOp(sync,ld)
CUT_wait_leftmost();
PREG = NEXTOP(PREG, ld);
PREFETCH_OP(PREG);
GONext();
ENDPBOp();