Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- void receive_message(int n, vector<node> routers){
- int received;
- for(int i = 0; i < n; i++){
- char *message;
- while((received = endpoint[i].recv_protocol_message(message)) != -1){
- //Debug
- printf("i = %d\n ", i);
- printf("Routerul %d a primit mesajul: ", i);
- puts(message);
- printf("Dimensiunea mesajului: %d\n", strlen(message));
- printf("Numarul de veccini %d ", routers[i].vecini.size());
- puts("\n");
- for(int j = 0 ; j < routers[i].vecini.size(); j++){
- printf("aici");
- //Debug
- printf("Sending message from: %d to: %d at: %d\n",
- i,
- routers[i].vecini[j].first.id_node,
- get_time());
- //End debug
- /*endpoint[i].send_msg(
- &endpoint[routers[i].vecini[j].first.id_node],
- message,
- strlen(message) + 1,
- NULL);*/
- }
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment