-
Notifications
You must be signed in to change notification settings - Fork 8
Description
Hi,
The Lux code uses BSP style of synchronization. I understood that it uses GASNET to perform inter node communication.
However, I can not clear understand from the code where the actual synchronization call is taking place for communication values among the different nodes/hosts/machines after every round of computation in a single machine.
For example: in components.cc file
if (iter >= SLIDING_WINDOW) {
fm = fms[iter % SLIDING_WINDOW];
(STEP-1) fm.wait_all_results();
bool halt = true;
for (PointInRectIterator<1> it(task_rect); it(); it++) {
(STEP-2) V_ID numNodes = fm.get_result (V_ID)(*it);
if (numNodes > 0) halt = false;
}
if (halt) break;
}
Is it the STEP-1 or STEP-2 from the above snippet where the communication taking place? If not please inform me accordingly.