This commit is contained in:
parent
38ae9f71b3
commit
c1ce429b7b
2 changed files with 2 additions and 1 deletions
|
@ -38,7 +38,7 @@ int main(int argc, char ** argv){
|
||||||
printf("Test mode!\n");
|
printf("Test mode!\n");
|
||||||
break;
|
break;
|
||||||
case Protocol::TYPE_ABCAST:
|
case Protocol::TYPE_ABCAST:
|
||||||
clk = new ClockAb(1);
|
clk = new ClockAb(config.getIndex());
|
||||||
printf("AbCast mode!\n");
|
printf("AbCast mode!\n");
|
||||||
break;
|
break;
|
||||||
case Protocol::TYPE_CBCAST:
|
case Protocol::TYPE_CBCAST:
|
||||||
|
|
|
@ -123,6 +123,7 @@ void LowReceiver::manage_abcast(Message * mesg) {
|
||||||
//FIXME: faire la gestion du abcast/send ici, c'est plus simple que
|
//FIXME: faire la gestion du abcast/send ici, c'est plus simple que
|
||||||
//de partager une variable+mutex avec le sender
|
//de partager une variable+mutex avec le sender
|
||||||
} else {
|
} else {
|
||||||
|
printf("LowReceiver::manage_abcast - Received a message from a friend\n");
|
||||||
for (iter = fifo.begin(); iter != fifo.end(); iter++){
|
for (iter = fifo.begin(); iter != fifo.end(); iter++){
|
||||||
MessageCellAb * cur = *iter;
|
MessageCellAb * cur = *iter;
|
||||||
if (cur->message == mesg) {
|
if (cur->message == mesg) {
|
||||||
|
|
Loading…
Add table
Reference in a new issue