aboutsummaryrefslogtreecommitdiff
path: root/src/setu/gnunet-service-setu.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/setu/gnunet-service-setu.c')
-rw-r--r--src/setu/gnunet-service-setu.c30
1 files changed, 29 insertions, 1 deletions
diff --git a/src/setu/gnunet-service-setu.c b/src/setu/gnunet-service-setu.c
index 5799908ba..58717909e 100644
--- a/src/setu/gnunet-service-setu.c
+++ b/src/setu/gnunet-service-setu.c
@@ -666,15 +666,21 @@ struct perf_rtt_struct
666struct perf_rtt_struct perf_rtt; 666struct perf_rtt_struct perf_rtt;
667 667
668 668
669static int
670sum_sent_received_bytes(int size, struct perf_num_send_resived_msg perf_rtt_struct) {
671 return (size * perf_rtt_struct.sent) + (size * perf_rtt_struct.received);
672}
673
669static float 674static float
670calculate_perf_rtt() { 675calculate_perf_rtt() {
671 /** 676 /**
672 * Calculate RTT of init phase normally always 1 677 * Calculate RTT of init phase normally always 1
673 */ 678 */
674 float rtt = 1; 679 float rtt = 1;
680 int bytes_transmitted = 0;
675 681
676 /** 682 /**
677 * Calculate RRT of Fullsync normaly 1 or 1.5 depending 683 * Calculate RGNUNET_SETU_AcceptMessageRT of Fullsync normaly 1 or 1.5 depending
678 */ 684 */
679 if (( perf_rtt.element_full.received != 0 ) || 685 if (( perf_rtt.element_full.received != 0 ) ||
680 ( perf_rtt.element_full.sent != 0) 686 ( perf_rtt.element_full.sent != 0)
@@ -694,6 +700,24 @@ calculate_perf_rtt() {
694 rtt += (iterations - 1 ) * 0.5; 700 rtt += (iterations - 1 ) * 0.5;
695 rtt += 3 * iterations; 701 rtt += 3 * iterations;
696 702
703 /**
704 * Calculate data sended size
705 */
706 bytes_transmitted += sum_sent_received_bytes(sizeof(GNUNET_MESSAGE_TYPE_SETU_P2P_REQUEST_FULL), perf_rtt.request_full);
707 bytes_transmitted += sum_sent_received_bytes(sizeof(GNUNET_MESSAGE_TYPE_SETU_P2P_FULL_ELEMENT), perf_rtt.element_full);
708 bytes_transmitted += sum_sent_received_bytes(sizeof(GNUNET_MESSAGE_TYPE_SETU_P2P_ELEMENTS), perf_rtt.element);
709 bytes_transmitted += sum_sent_received_bytes(sizeof(GNUNET_MESSAGE_TYPE_SETU_P2P_OPERATION_REQUEST), perf_rtt.operation_request);
710 bytes_transmitted += sum_sent_received_bytes(sizeof(GNUNET_MESSAGE_TYPE_SETU_P2P_SE), perf_rtt.se);
711 bytes_transmitted += sum_sent_received_bytes(sizeof(GNUNET_MESSAGE_TYPE_SETU_P2P_FULL_DONE), perf_rtt.full_done);
712 bytes_transmitted += sum_sent_received_bytes(sizeof(GNUNET_MESSAGE_TYPE_SETU_P2P_IBF), perf_rtt.ibf);
713 bytes_transmitted += sum_sent_received_bytes(sizeof(GNUNET_MESSAGE_TYPE_SETU_P2P_INQUIRY), perf_rtt.inquery);
714 bytes_transmitted += sum_sent_received_bytes(sizeof(GNUNET_MESSAGE_TYPE_SETU_P2P_DEMAND), perf_rtt.demand);
715 bytes_transmitted += sum_sent_received_bytes(sizeof(GNUNET_MESSAGE_TYPE_SETU_P2P_OFFER), perf_rtt.offer);
716 bytes_transmitted += sum_sent_received_bytes(sizeof(GNUNET_MESSAGE_TYPE_SETU_P2P_DONE), perf_rtt.done);
717
718 LOG(GNUNET_ERROR_TYPE_ERROR,"Bytes Transmitted: %d\n", bytes_transmitted);
719
720
697 return rtt; 721 return rtt;
698} 722}
699 723
@@ -1513,6 +1537,10 @@ handle_union_p2p_strata_estimator (void *cls,
1513 return; 1537 return;
1514 } 1538 }
1515 1539
1540 LOG (GNUNET_ERROR_TYPE_ERROR,
1541 "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx: %f\n", op->rtt_bandwidth_tradeoff);
1542
1543
1516 /** 1544 /**
1517 * Added rtt_bandwidth_tradeoff directly need future improvements 1545 * Added rtt_bandwidth_tradeoff directly need future improvements
1518 */ 1546 */