- // Re-run experiment but now with A1 message type when
- // ping responds
- pong_xapp.StartThread(pong_a1);
- sleep(1);
-
- failed_tx = 0;
- num_ping_pkts = 0;
- num_pong_pkts = 0;
-
-
- for(i = 0; i < NumPkts; i++){
- clock_gettime(CLOCK_REALTIME, &(my_message.ts));
- snprintf(my_message.payload, MESSAGE_SIZE, "hello world %d", i);
- bool res = ping_xapp.Send(101, sizeof(Test_message), (void *) (&my_message));
- if (!res){
- failed_tx ++;
- }
- }
-
- sleep(1);