- xbt_host_t grid[SLAVE_COUNT]; /* The slaves */
- gras_socket_t socket[SLAVE_COUNT]; /* sockets for brodcast to slaves */
-
- /* Initialize Matrices */
-
- A = xbt_matrix_double_new_id(DATA_MATRIX_SIZE,DATA_MATRIX_SIZE);
- B = xbt_matrix_double_new_seq(DATA_MATRIX_SIZE,DATA_MATRIX_SIZE);
- C = xbt_matrix_double_new_zeros(DATA_MATRIX_SIZE,DATA_MATRIX_SIZE);
-
- /* Get arguments and create sockets */
- port=atoi(argv[1]);
- //scatter();
- //scatter_parl();
- //multiplication();
- //gather();
- /************************* Init Data Send *********************************/
- gras_os_sleep(5);
-
- for( i=1;i<argc && i<=SLAVE_COUNT;i++){
- grid[i-1]=xbt_host_from_string(argv[i]);
- socket[i-1]=gras_socket_client(grid[i-1]->name,grid[i-1]->port);
-
- INFO2("Connected to %s:%d.",grid[i-1]->name,grid[i-1]->port);
- }
- xbt_assert2(i-1==SLAVE_COUNT,
- "Not enough slaves for this setting (got %d of %d). Change the deployment file",
- i-1,SLAVE_COUNT);
- /* FIXME: let the surnumerous slave die properly */
-
- int row=0, line=0;
- INFO0("XXXXXXXXXXXXXXXXXXXXXX begin Multiplication");
- for(i=0 ; i<SLAVE_COUNT; i++){
- s_assignment_t assignment;
- int j;
+ /* Assign job to slaves */
+ int row = 0, line = 0;
+ XBT_INFO("XXXXXXXXXXXXXXXXXXXXXX begin Multiplication");
+ for (i = 0; i < SLAVE_COUNT; i++) {
+ s_pmm_assignment_t assignment;
+ int j, k;