small fixes with broadcast in update

This commit is contained in:
vivek-shankar 2017-01-27 12:38:20 -05:00
parent 70f2f98419
commit 42c323b21a
2 changed files with 5 additions and 2 deletions

View File

@ -269,7 +269,10 @@ buzzvm_pushs(VM, buzzvm_string_register(VM, "update_no", 1));
uint16_t update_no =*(uint16_t*)(updater->update_no); uint16_t update_no =*(uint16_t*)(updater->update_no);
*(uint16_t*)(updater->update_no) =update_no +1; *(uint16_t*)(updater->update_no) =update_no +1;
code_message_outqueue_append(); code_message_outqueue_append();
fprintf(stdout,"Update no %d\n", update_no); fprintf(stdout,"Update no %d\n", *(uint16_t*)(updater->update_no));
buzzvm_pushs(VM, buzzvm_string_register(VM, "update_no", 1));
buzzvm_pushi(VM, *(uint16_t*)updater->update_no);
buzzvm_gstore(VM);
} }
neigh=0; neigh=0;
delete_p(BO_BUF); delete_p(BO_BUF);

View File

@ -18,7 +18,7 @@ barrier_val = barrier.size()
neighbors.listen(updated, neighbors.listen(updated,
function(vid, value, rid) { function(vid, value, rid) {
print(" got from",vid," " ) print(" got from",vid," ", " value = ",value," ","rid"," " )
if(value==update_no) barrier_val=ROBOTS if(value==update_no) barrier_val=ROBOTS
} }
) )