Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- void beacon(int n, vector<node> routers){
- //Debug
- printf("Initial flooding of the network\n");
- //End debug
- for(int i = 0; i < n; i++){
- for(int j = 0; j < routers[i].vecini.size(); j++){
- //Creez mesajul
- char * mesaj = create_message(routers[i]);
- //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],
- (char *) mesaj,
- strlen(mesaj),
- NULL);
- //Debug
- printf("Am trimis mesajul: ");
- puts(mesaj);
- puts("\n");
- //End debug
- }
- }
- }
- void receive_message(int n, vector<node> routers){
- char* message;
- int received;
- for(int i = 0; i < n; i++){
- received = endpoint[i].recv_protocol_message(message);
- //memset(message,'\0', strlen(message));
- printf("Am trimis mesajul: ");
- puts(message);
- puts("\n");
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement