/* TODO: *
* - handle node departure *
* - handle objects on the network *
- * - handle neighborood in the update */
+ * - handle neighborhood in the update */
#define COMM_SIZE 10
#define COMP_SIZE 0
/* Print the node id */
static void print_node_id(node_t node) {
- int i;
- printf(" id: %i '%08x' ", node->id, node->id);
- for (i=0;i<LEVELS_COUNT;i++)
- printf(" %x", domain(node->id, i));
- printf("\n");
+ XBT_INFO(" Id: %i '%08x' ", node->id, node->id);
}
/* * Print the node neighborhood set */
static void print_node_neighborood_set(node_t node) {
- int i;
- printf(" Neighborhood:\n");
- for (i=0; i<NEIGHBORHOOD_SIZE; i++)
- printf(" %08x\n", node->neighborhood_set[i]);
+ XBT_INFO(" Neighborhood:");
+ for (int i=0; i<NEIGHBORHOOD_SIZE; i++)
+ XBT_INFO(" %08x", node->neighborhood_set[i]);
}
/* Print the routing table */
static void print_node_routing_table(node_t node) {
- printf(" routing table:\n");
+ XBT_INFO(" Routing table:");
for (int i=0; i<LEVELS_COUNT; i++){
- printf(" ");
for (int j=0; j<LEVEL_SIZE; j++)
- printf("%08x ", node->routing_table[i][j]);
- printf("\n");
+ XBT_INFO(" %08x ", node->routing_table[i][j]);
}
}
/* Print the node namespace set */
static void print_node_namespace_set(node_t node) {
- printf(" namespace:\n");
+ XBT_INFO(" Namespace:");
for (int i=0; i<NAMESPACE_SIZE; i++)
- printf(" %08x\n", node->namespace_set[i]);
- printf("\n");
+ XBT_INFO(" %08x", node->namespace_set[i]);
}
/* Print the node information */
static void print_node(node_t node) {
- printf("Node:\n");
+ XBT_INFO("Node:");
print_node_id(node);
print_node_neighborood_set(node);
print_node_routing_table(node);
XBT_DEBUG("Task update %i !!!", node->id);
/* Update namespace ses */
- printf("Task update from %i !!!\n", task_data->sender_id);
+ XBT_INFO("Task update from %i !!!", task_data->sender_id);
+ XBT_INFO("Node:");
print_node_id(node);
print_node_namespace_set(node);
int curr_namespace_set[NAMESPACE_SIZE];
int task_namespace_set[NAMESPACE_SIZE+1];
- // Copy the current namedspace
- // and the task state namespace with state->id in the middle
+ // Copy the current namespace and the task state namespace with state->id in the middle
i=0;
for (; i<NAMESPACE_SIZE/2; i++){
curr_namespace_set[i] = node->namespace_set[i];
max = -1;
for (i=0; i<=NAMESPACE_SIZE; i++) {
j = task_namespace_set[i];
- if (i<NAMESPACE_SIZE)
- printf("%08x %08x | ", j, curr_namespace_set[i]);
if (j != -1 && j < node->id) min = i;
if (j != -1 && max == -1 && j > node->id) max = i;
}
- printf("\n");
// add lower elements
j = NAMESPACE_SIZE/2-1;
for (i=NAMESPACE_SIZE/2-1; i>=0; i--) {
- printf("i:%i, j:%i, min:%i, currj:%08x, taskmin:%08x\n", i, j, min, curr_namespace_set[j],
- task_namespace_set[min]);
if (min<0) {
node->namespace_set[i] = curr_namespace_set[j];
j--;
// add greater elements
j = NAMESPACE_SIZE/2;
for (i=NAMESPACE_SIZE/2; i<NAMESPACE_SIZE; i++) {
- printf("i:%i, j:%i, max:%i, currj:%08x, taskmax:%08x\n", i, j, max, curr_namespace_set[j],
- task_namespace_set[max]);
if (min<0 || max>=NAMESPACE_SIZE) {
node->namespace_set[i] = curr_namespace_set[j];
j++;
max++;
}
}
- print_node_namespace_set(node);
/* Update routing table */
for (i=shl(node->id, task_data->state->id); i<LEVELS_COUNT; i++) {
return 1;
}
-
/**
* \brief Node Function
* Arguments:
}
}
- print_node(&node);
}
return 1;
}
#! ./tesh
-p Testing the Chord implementation with MSG
+p Testing the Pastry implementation with MSG (use the deployment file for chord in ../dht-chord)
-$ $SG_TEST_EXENV ${bindir:=.}/dht-pastry$EXEEXT -nb_bits=6 ${srcdir:=.}/../../platforms/platform.xml ${srcdir:=.}/dht-pastry_d.xml --cfg=network/crosstraffic:0 --log=msg_pastry.thres:verbose "--log=root.fmt:[%10.6r]%e(%i:%P@%h)%e%m%n"
+$ $SG_TEST_EXENV ${bindir:=.}/dht-pastry$EXEEXT -nb_bits=6 ${srcdir:=.}/cluster.xml ${srcdir:=.}/../msg/dht-chord/dht-chord_d.xml --log=msg_pastry.thres:verbose "--log=root.fmt:[%10.6r]%e(%i:%P@%h)%e%m%n"
+> [ 25.007806] (1:node@node-0.acme.org) Task update from 366680 !!!
+> [ 25.007806] (1:node@node-0.acme.org) Node:
+> [ 25.007806] (1:node@node-0.acme.org) Id: 42 '0000002a'
+> [ 25.007806] (1:node@node-0.acme.org) Namespace:
+> [ 25.007806] (1:node@node-0.acme.org) ffffffff
+> [ 25.007806] (1:node@node-0.acme.org) ffffffff
+> [ 25.007806] (1:node@node-0.acme.org) ffffffff
+> [ 25.007806] (1:node@node-0.acme.org) ffffffff
+> [ 25.007806] (1:node@node-0.acme.org) ffffffff
+> [ 25.007806] (1:node@node-0.acme.org) ffffffff
+> [ 40.015612] (1:node@node-0.acme.org) Task update from 533744 !!!
+> [ 40.015612] (1:node@node-0.acme.org) Node:
+> [ 40.015612] (1:node@node-0.acme.org) Id: 42 '0000002a'
+> [ 40.015612] (1:node@node-0.acme.org) Namespace:
+> [ 40.015612] (1:node@node-0.acme.org) ffffffff
+> [ 40.015612] (1:node@node-0.acme.org) ffffffff
+> [ 40.015612] (1:node@node-0.acme.org) ffffffff
+> [ 40.015612] (1:node@node-0.acme.org) ffffffff
+> [ 40.015612] (1:node@node-0.acme.org) ffffffff
+> [ 40.015612] (1:node@node-0.acme.org) ffffffff
+> [ 40.023418] (2:node@node-1.acme.org) Task update from 533744 !!!
+> [ 40.023418] (2:node@node-1.acme.org) Node:
+> [ 40.023418] (2:node@node-1.acme.org) Id: 366680 '00059858'
+> [ 40.023418] (2:node@node-1.acme.org) Namespace:
+> [ 40.023418] (2:node@node-1.acme.org) ffffffff
+> [ 40.023418] (2:node@node-1.acme.org) ffffffff
+> [ 40.023418] (2:node@node-1.acme.org) 0000002a
+> [ 40.023418] (2:node@node-1.acme.org) ffffffff
+> [ 40.023418] (2:node@node-1.acme.org) ffffffff
+> [ 40.023418] (2:node@node-1.acme.org) ffffffff
+> [ 45.015612] (1:node@node-0.acme.org) Task update from 1319738 !!!
+> [ 45.015612] (1:node@node-0.acme.org) Node:
+> [ 45.015612] (1:node@node-0.acme.org) Id: 42 '0000002a'
+> [ 45.015612] (1:node@node-0.acme.org) Namespace:
+> [ 45.015612] (1:node@node-0.acme.org) ffffffff
+> [ 45.015612] (1:node@node-0.acme.org) ffffffff
+> [ 45.015612] (1:node@node-0.acme.org) ffffffff
+> [ 45.015612] (1:node@node-0.acme.org) ffffffff
+> [ 45.015612] (1:node@node-0.acme.org) ffffffff
+> [ 45.015612] (1:node@node-0.acme.org) ffffffff
+> [ 55.015612] (1:node@node-0.acme.org) Task update from 16509405 !!!
+> [ 55.015612] (1:node@node-0.acme.org) Node:
+> [ 55.015612] (1:node@node-0.acme.org) Id: 42 '0000002a'
+> [ 55.015612] (1:node@node-0.acme.org) Namespace:
+> [ 55.015612] (1:node@node-0.acme.org) ffffffff
+> [ 55.015612] (1:node@node-0.acme.org) ffffffff
+> [ 55.015612] (1:node@node-0.acme.org) ffffffff
+> [ 55.015612] (1:node@node-0.acme.org) ffffffff
+> [ 55.015612] (1:node@node-0.acme.org) ffffffff
+> [ 55.015612] (1:node@node-0.acme.org) ffffffff
+> [ 55.031224] (2:node@node-1.acme.org) Task update from 16509405 !!!
+> [ 55.031224] (2:node@node-1.acme.org) Node:
+> [ 55.031224] (2:node@node-1.acme.org) Id: 366680 '00059858'
+> [ 55.031224] (2:node@node-1.acme.org) Namespace:
+> [ 55.031224] (2:node@node-1.acme.org) ffffffff
+> [ 55.031224] (2:node@node-1.acme.org) ffffffff
+> [ 55.031224] (2:node@node-1.acme.org) 0000002a
+> [ 55.031224] (2:node@node-1.acme.org) ffffffff
+> [ 55.031224] (2:node@node-1.acme.org) ffffffff
+> [ 55.031224] (2:node@node-1.acme.org) ffffffff
+> [ 60.015612] (1:node@node-0.acme.org) Task update from 10874876 !!!
+> [ 60.015612] (1:node@node-0.acme.org) Node:
+> [ 60.015612] (1:node@node-0.acme.org) Id: 42 '0000002a'
+> [ 60.015612] (1:node@node-0.acme.org) Namespace:
+> [ 60.015612] (1:node@node-0.acme.org) ffffffff
+> [ 60.015612] (1:node@node-0.acme.org) ffffffff
+> [ 60.015612] (1:node@node-0.acme.org) ffffffff
+> [ 60.015612] (1:node@node-0.acme.org) ffffffff
+> [ 60.015612] (1:node@node-0.acme.org) ffffffff
+> [ 60.015612] (1:node@node-0.acme.org) ffffffff
+> [ 60.031224] (2:node@node-1.acme.org) Task update from 10874876 !!!
+> [ 60.031224] (2:node@node-1.acme.org) Node:
+> [ 60.031224] (2:node@node-1.acme.org) Id: 366680 '00059858'
+> [ 60.031224] (2:node@node-1.acme.org) Namespace:
+> [ 60.031224] (2:node@node-1.acme.org) ffffffff
+> [ 60.031224] (2:node@node-1.acme.org) ffffffff
+> [ 60.031224] (2:node@node-1.acme.org) 0000002a
+> [ 60.031224] (2:node@node-1.acme.org) ffffffff
+> [ 60.031224] (2:node@node-1.acme.org) ffffffff
+> [ 60.031224] (2:node@node-1.acme.org) ffffffff
+> [ 60.039030] (3:node@node-2.acme.org) Task update from 10874876 !!!
+> [ 60.039030] (3:node@node-2.acme.org) Node:
+> [ 60.039030] (3:node@node-2.acme.org) Id: 533744 '000824f0'
+> [ 60.039030] (3:node@node-2.acme.org) Namespace:
+> [ 60.039030] (3:node@node-2.acme.org) ffffffff
+> [ 60.039030] (3:node@node-2.acme.org) 0000002a
+> [ 60.039030] (3:node@node-2.acme.org) 00059858
+> [ 60.039030] (3:node@node-2.acme.org) ffffffff
+> [ 60.039030] (3:node@node-2.acme.org) ffffffff
+> [ 60.039030] (3:node@node-2.acme.org) ffffffff
+> [ 65.031224] (4:node@node-3.acme.org) Task update from 16728096 !!!
+> [ 65.031224] (4:node@node-3.acme.org) Node:
+> [ 65.031224] (4:node@node-3.acme.org) Id: 1319738 '0014233a'
+> [ 65.031224] (4:node@node-3.acme.org) Namespace:
+> [ 65.031224] (4:node@node-3.acme.org) ffffffff
+> [ 65.031224] (4:node@node-3.acme.org) ffffffff
+> [ 65.031224] (4:node@node-3.acme.org) 0000002a
+> [ 65.031224] (4:node@node-3.acme.org) ffffffff
+> [ 65.031224] (4:node@node-3.acme.org) ffffffff
+> [ 65.031224] (4:node@node-3.acme.org) ffffffff
+> [ 70.015612] (1:node@node-0.acme.org) Task update from 16728096 !!!
+> [ 70.015612] (1:node@node-0.acme.org) Node:
+> [ 70.015612] (1:node@node-0.acme.org) Id: 42 '0000002a'
+> [ 70.015612] (1:node@node-0.acme.org) Namespace:
+> [ 70.015612] (1:node@node-0.acme.org) ffffffff
+> [ 70.015612] (1:node@node-0.acme.org) ffffffff
+> [ 70.015612] (1:node@node-0.acme.org) ffffffff
+> [ 70.015612] (1:node@node-0.acme.org) ffffffff
+> [ 70.015612] (1:node@node-0.acme.org) ffffffff
+> [ 70.015612] (1:node@node-0.acme.org) ffffffff
+> [ 75.031224] (2:node@node-1.acme.org) Task update from 10004760 !!!
+> [ 75.031224] (2:node@node-1.acme.org) Node:
+> [ 75.031224] (2:node@node-1.acme.org) Id: 366680 '00059858'
+> [ 75.031224] (2:node@node-1.acme.org) Namespace:
+> [ 75.031224] (2:node@node-1.acme.org) ffffffff
+> [ 75.031224] (2:node@node-1.acme.org) ffffffff
+> [ 75.031224] (2:node@node-1.acme.org) 0000002a
+> [ 75.031224] (2:node@node-1.acme.org) ffffffff
+> [ 75.031224] (2:node@node-1.acme.org) ffffffff
+> [ 75.031224] (2:node@node-1.acme.org) ffffffff
+> [ 75.054642] (5:node@node-4.acme.org) Task update from 10004760 !!!
+> [ 75.054642] (5:node@node-4.acme.org) Node:
+> [ 75.054642] (5:node@node-4.acme.org) Id: 16509405 '00fbe9dd'
+> [ 75.054642] (5:node@node-4.acme.org) Namespace:
+> [ 75.054642] (5:node@node-4.acme.org) ffffffff
+> [ 75.054642] (5:node@node-4.acme.org) 0000002a
+> [ 75.054642] (5:node@node-4.acme.org) 00059858
+> [ 75.054642] (5:node@node-4.acme.org) ffffffff
+> [ 75.054642] (5:node@node-4.acme.org) ffffffff
+> [ 75.054642] (5:node@node-4.acme.org) ffffffff
+> [ 80.015612] (1:node@node-0.acme.org) Task update from 10004760 !!!
+> [ 80.015612] (1:node@node-0.acme.org) Node:
+> [ 80.015612] (1:node@node-0.acme.org) Id: 42 '0000002a'
+> [ 80.015612] (1:node@node-0.acme.org) Namespace:
+> [ 80.015612] (1:node@node-0.acme.org) ffffffff
+> [ 80.015612] (1:node@node-0.acme.org) ffffffff
+> [ 80.015612] (1:node@node-0.acme.org) ffffffff
+> [ 80.015612] (1:node@node-0.acme.org) ffffffff
+> [ 80.015612] (1:node@node-0.acme.org) ffffffff
+> [ 80.015612] (1:node@node-0.acme.org) ffffffff
+> [ 95.023418] (1:node@node-0.acme.org) Task update from 6518808 !!!
+> [ 95.023418] (1:node@node-0.acme.org) Node:
+> [ 95.023418] (1:node@node-0.acme.org) Id: 42 '0000002a'
+> [ 95.023418] (1:node@node-0.acme.org) Namespace:
+> [ 95.023418] (1:node@node-0.acme.org) ffffffff
+> [ 95.023418] (1:node@node-0.acme.org) ffffffff
+> [ 95.023418] (1:node@node-0.acme.org) ffffffff
+> [ 95.023418] (1:node@node-0.acme.org) ffffffff
+> [ 95.023418] (1:node@node-0.acme.org) ffffffff
+> [ 95.023418] (1:node@node-0.acme.org) ffffffff
+> [100.023418] (1:node@node-0.acme.org) Task update from 2015253 !!!
+> [100.023418] (1:node@node-0.acme.org) Node:
+> [100.023418] (1:node@node-0.acme.org) Id: 42 '0000002a'
+> [100.023418] (1:node@node-0.acme.org) Namespace:
+> [100.023418] (1:node@node-0.acme.org) ffffffff
+> [100.023418] (1:node@node-0.acme.org) ffffffff
+> [100.023418] (1:node@node-0.acme.org) ffffffff
+> [100.023418] (1:node@node-0.acme.org) ffffffff
+> [100.023418] (1:node@node-0.acme.org) ffffffff
+> [100.023418] (1:node@node-0.acme.org) ffffffff
+> [100.039030] (4:node@node-3.acme.org) Task update from 2015253 !!!
+> [100.039030] (4:node@node-3.acme.org) Node:
+> [100.039030] (4:node@node-3.acme.org) Id: 1319738 '0014233a'
+> [100.039030] (4:node@node-3.acme.org) Namespace:
+> [100.039030] (4:node@node-3.acme.org) ffffffff
+> [100.039030] (4:node@node-3.acme.org) ffffffff
+> [100.039030] (4:node@node-3.acme.org) 0000002a
+> [100.039030] (4:node@node-3.acme.org) ffffffff
+> [100.039030] (4:node@node-3.acme.org) ffffffff
+> [100.039030] (4:node@node-3.acme.org) ffffffff
+> [1000.054642] (0:maestro@) Simulated time: 1000.05