- for (l=1;l < MATRIX_SIZE ;l++){
- gras_msg_send(socket_row[l], gras_msgtype_by_name("data"), &mydataB);
- bB=mydataB;
- INFO1("send my data B (%.3f) to my (horizontal) neighbors",bB);
- }
- }
- else
- {
- TRY {
- gras_msg_wait(600,gras_msgtype_by_name("data"),
- &from,&bB);
- } CATCH(e) {
- RETHROW0("I Can't get a data message from row : %s");
- }
- INFO1("Recive data B (%.3f) from my neighbors",bB);
+ INFO2("step(%d) = Myrow(%d)",step,myrow);
+ for (l=1;l < MATRIX_SIZE ;l++){
+ gras_msg_send(socket_column[l-1], gras_msgtype_by_name("dataB"), &mydataB);
+ bB=mydataB;
+ INFO1("send my data B (%.3g) to my (vertical) neighbors",bB);
+ }
+ }
+ if(myrow != step){
+ INFO2("step(%d) <> Myrow(%d)",step,myrow);
+ TRY {
+ gras_msg_wait(600,gras_msgtype_by_name("dataB"),
+ &from,&bB);
+ } CATCH(e) {
+ RETHROW0("I Can't get a data message from row : %s");
+ }
+ INFO2("Recive data B (%.3g) from my neighbor: %s",bB,gras_socket_peer_name(from));