int master (int argc,char *argv[]) {
int i;
+ double init_delay;
xbt_matrix_t A,B,C;
result_t result;
xbt_assert0(argc>1, "Usage: master <port>");
gras_socket_server(atoi(argv[1]));
peers=amok_pm_group_new("pmm");
- INFO0("Wait for peers for 10 sec");
- gras_msg_handleall(10); /* friends, we're ready. Come and play */
+
+ /* friends, we're ready. Come and play */
+ if (gras_if_RL()) {
+ init_delay = 5;
+ } else {
+ init_delay = 15; /* no idea why I have to wait that long in simulation */
+ }
+ INFO1("Wait for peers for %.0f sec",init_delay);
+ gras_msg_handleall(init_delay);
INFO1("Got %ld pals",xbt_dynar_length(peers));
for (i=0;
i++) {
xbt_dynar_get_cpy(peers,i,&grid[i]);
+ INFO2("Connecting to %s:%d.",grid[i]->name,grid[i]->port);
socket[i]=gras_socket_client(grid[i]->name,grid[i]->port);
INFO2("Connected to %s:%d.",grid[i]->name,grid[i]->port);
}
for (i=SLAVE_COUNT; i<xbt_dynar_length(peers); ) {
xbt_peer_t h;
- xbt_dynar_get_cpy(peers,i,&h);
+ xbt_dynar_remove_at(peers,i,&h);
+ INFO2("Too much slaves. Killing %s:%d", h->name, h->port);
amok_pm_kill_hp(h->name,h->port);
free(h);
}
/* Create the connexions */
mysock = gras_socket_server_range(3000,9999,0,0);
+ gras_os_sleep(1); /* let the master get ready */
INFO1("Sensor starting (on port %d)",gras_os_myport());
- gras_os_sleep(2); /* let the master get ready */
master = gras_socket_client_from_string(argv[1]);
/* Join and run the group */