@@ -570,14 +570,6 @@ TEST_F(RpcStressTest, SmallPayloadStress) {
570570
571571 StressTestStats stats;
572572 std::atomic<bool > running{true };
573- std::atomic<int > packet_counter{0 };
574-
575- // Helper to get current timestamp in microseconds since epoch
576- auto get_timestamp_us = []() {
577- return std::chrono::duration_cast<std::chrono::microseconds>(
578- std::chrono::system_clock::now ().time_since_epoch ())
579- .count ();
580- };
581573
582574 auto start_time = std::chrono::steady_clock::now ();
583575 auto duration = std::chrono::seconds (config_.duration_seconds );
@@ -587,8 +579,6 @@ TEST_F(RpcStressTest, SmallPayloadStress) {
587579 for (int t = 0 ; t < config_.num_caller_threads ; ++t) {
588580 caller_threads.emplace_back ([&, thread_id = t]() {
589581 while (running.load ()) {
590- int pkt_id = packet_counter.fetch_add (1 );
591-
592582 // Use small payload that fits in single SCTP chunk
593583 std::string payload = generateRandomPayload (kSmallPayloadSize );
594584
@@ -599,25 +589,16 @@ TEST_F(RpcStressTest, SmallPayloadStress) {
599589 }
600590
601591 auto call_start = std::chrono::high_resolution_clock::now ();
602- auto send_ts = get_timestamp_us ();
603-
604- std::cerr << " [LATENCY] SENDER pkt=" << pkt_id
605- << " SEND_START ts=" << send_ts << std::endl;
606592
607593 try {
608594 std::string response = caller_room->localParticipant ()->performRpc (
609595 receiver_identity, " small-payload-stress" , payload, 60.0 );
610596
611597 auto call_end = std::chrono::high_resolution_clock::now ();
612- auto recv_ts = get_timestamp_us ();
613598 double latency_ms =
614599 std::chrono::duration<double , std::milli>(call_end - call_start)
615600 .count ();
616601
617- std::cerr << " [LATENCY] SENDER pkt=" << pkt_id
618- << " RESPONSE_RECEIVED ts=" << recv_ts
619- << " latency_ms=" << latency_ms << std::endl;
620-
621602 // Verify response by comparing checksum
622603 size_t response_checksum = 0 ;
623604 for (char c : response) {
0 commit comments