Home
last modified time | relevance | path

Searched refs:totalBytesReceived (Results 1 – 25 of 33) sorted by relevance

12

/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/
H A DBufferingSubscriberTest.java265 volatile int totalBytesReceived; field in BufferingSubscriberTest.TestSubscriber
281 count, sz, (totalBytesReceived + sz)); in onNext()
297 sz, totalBytesReceived, totalBytesReceived + sz); in onNext()
311 totalBytesReceived += sz; in onNext()
312 assertEquals(totalBytesReceived, index); in onNext()
313 if (delayMillis > 0 && ((expectedTotalSize - totalBytesReceived) > bufferSize)) in onNext()
333 if (totalBytesReceived != expectedTotalSize) { in onComplete()
337 completion.complete(totalBytesReceived); in onComplete()
352 sb.append(", totalBytesReceived=").append(totalBytesReceived); in toString()
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/java/net/httpclient/
H A DBufferingSubscriberTest.java265 volatile int totalBytesReceived; field in BufferingSubscriberTest.TestSubscriber
281 count, sz, (totalBytesReceived + sz)); in onNext()
297 sz, totalBytesReceived, totalBytesReceived + sz); in onNext()
311 totalBytesReceived += sz; in onNext()
312 assertEquals(totalBytesReceived, index); in onNext()
313 if (delayMillis > 0 && ((expectedTotalSize - totalBytesReceived) > bufferSize)) in onNext()
333 if (totalBytesReceived != expectedTotalSize) { in onComplete()
337 completion.complete(totalBytesReceived); in onComplete()
352 sb.append(", totalBytesReceived=").append(totalBytesReceived); in toString()
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/
H A DBufferingSubscriberTest.java265 volatile int totalBytesReceived; field in BufferingSubscriberTest.TestSubscriber
281 count, sz, (totalBytesReceived + sz)); in onNext()
297 sz, totalBytesReceived, totalBytesReceived + sz); in onNext()
311 totalBytesReceived += sz; in onNext()
312 assertEquals(totalBytesReceived, index); in onNext()
313 if (delayMillis > 0 && ((expectedTotalSize - totalBytesReceived) > bufferSize)) in onNext()
333 if (totalBytesReceived != expectedTotalSize) { in onComplete()
337 completion.complete(totalBytesReceived); in onComplete()
352 sb.append(", totalBytesReceived=").append(totalBytesReceived); in toString()
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/java/net/httpclient/
H A DBufferingSubscriberTest.java265 volatile int totalBytesReceived; field in BufferingSubscriberTest.TestSubscriber
281 count, sz, (totalBytesReceived + sz)); in onNext()
297 sz, totalBytesReceived, totalBytesReceived + sz); in onNext()
311 totalBytesReceived += sz; in onNext()
312 assertEquals(totalBytesReceived, index); in onNext()
313 if (delayMillis > 0 && ((expectedTotalSize - totalBytesReceived) > bufferSize)) in onNext()
333 if (totalBytesReceived != expectedTotalSize) { in onComplete()
337 completion.complete(totalBytesReceived); in onComplete()
352 sb.append(", totalBytesReceived=").append(totalBytesReceived); in toString()
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/net/httpclient/
H A DBufferingSubscriberTest.java265 volatile int totalBytesReceived; field in BufferingSubscriberTest.TestSubscriber
281 count, sz, (totalBytesReceived + sz)); in onNext()
297 sz, totalBytesReceived, totalBytesReceived + sz); in onNext()
311 totalBytesReceived += sz; in onNext()
312 assertEquals(totalBytesReceived, index); in onNext()
313 if (delayMillis > 0 && ((expectedTotalSize - totalBytesReceived) > bufferSize)) in onNext()
333 if (totalBytesReceived != expectedTotalSize) { in onComplete()
337 completion.complete(totalBytesReceived); in onComplete()
352 sb.append(", totalBytesReceived=").append(totalBytesReceived); in toString()
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/net/httpclient/
H A DBufferingSubscriberTest.java265 volatile int totalBytesReceived; field in BufferingSubscriberTest.TestSubscriber
281 count, sz, (totalBytesReceived + sz)); in onNext()
297 sz, totalBytesReceived, totalBytesReceived + sz); in onNext()
311 totalBytesReceived += sz; in onNext()
312 assertEquals(totalBytesReceived, index); in onNext()
313 if (delayMillis > 0 && ((expectedTotalSize - totalBytesReceived) > bufferSize)) in onNext()
333 if (totalBytesReceived != expectedTotalSize) { in onComplete()
337 completion.complete(totalBytesReceived); in onComplete()
352 sb.append(", totalBytesReceived=").append(totalBytesReceived); in toString()
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/net/httpclient/
H A DBufferingSubscriberTest.java265 volatile int totalBytesReceived; field in BufferingSubscriberTest.TestSubscriber
281 count, sz, (totalBytesReceived + sz)); in onNext()
297 sz, totalBytesReceived, totalBytesReceived + sz); in onNext()
311 totalBytesReceived += sz; in onNext()
312 assertEquals(totalBytesReceived, index); in onNext()
313 if (delayMillis > 0 && ((expectedTotalSize - totalBytesReceived) > bufferSize)) in onNext()
333 if (totalBytesReceived != expectedTotalSize) { in onComplete()
337 completion.complete(totalBytesReceived); in onComplete()
352 sb.append(", totalBytesReceived=").append(totalBytesReceived); in toString()
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/net/httpclient/
H A DBufferingSubscriberTest.java265 volatile int totalBytesReceived; field in BufferingSubscriberTest.TestSubscriber
281 count, sz, (totalBytesReceived + sz)); in onNext()
297 sz, totalBytesReceived, totalBytesReceived + sz); in onNext()
311 totalBytesReceived += sz; in onNext()
312 assertEquals(totalBytesReceived, index); in onNext()
313 if (delayMillis > 0 && ((expectedTotalSize - totalBytesReceived) > bufferSize)) in onNext()
333 if (totalBytesReceived != expectedTotalSize) { in onComplete()
337 completion.complete(totalBytesReceived); in onComplete()
352 sb.append(", totalBytesReceived=").append(totalBytesReceived); in toString()
/dports/benchmarks/apib/apib-APIB_1_2_1_RC1/apib/
H A Dapib_reporting.cc81 static int64_t totalBytesReceived = 0LL; variable
177 totalBytesReceived += received; in RecordByteCounts()
195 totalBytesReceived = 0; in RecordStart()
246 totalBytesReceived += c->bytesRead; in RecordStop()
262 totalBytesReceived += c->bytesRead; in ReportIntervalResults()
398 r.totalBytesReceived = totalBytesReceived; in ReportResults()
410 (totalBytesReceived * 8.0 / 1048576.0) / r.elapsedTime; in ReportResults()
467 r.totalBytesReceived / 1048576.0); in PrintFullResults()
H A Dapib_reporting.h49 int64_t totalBytesReceived; variable
/dports/benchmarks/apib/apib-APIB_1_2_1_RC1/test/
H A Dreporting_test.cc54 EXPECT_EQ(0, r.totalBytesReceived); in TEST_F()
82 EXPECT_EQ(200, r.totalBytesReceived); in TEST_F()
118 EXPECT_EQ(0, r.totalBytesReceived); in TEST_F()
/dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/pion/webrtc/v2/examples/data-channels-flow-control/
H A Dmain.go97 var totalBytesReceived uint64
106 bps := float64(atomic.LoadUint64(&totalBytesReceived)*8) / time.Since(since).Seconds()
114 atomic.AddUint64(&totalBytesReceived, uint64(n))
/dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/vendor/github.com/pion/webrtc/v3/examples/data-channels-flow-control/
H A Dmain.go97 var totalBytesReceived uint64
106 bps := float64(atomic.LoadUint64(&totalBytesReceived)*8) / time.Since(since).Seconds()
114 atomic.AddUint64(&totalBytesReceived, uint64(n))
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.WebSockets.Client/tests/
H A DSendReceiveTest.cs94 int totalBytesReceived = 0; in SendReceive_PartialMessageBeforeCompleteMessageArrives_Success()
96 while (totalBytesReceived < receiveBuffer.Length) in SendReceive_PartialMessageBeforeCompleteMessageArrives_Success()
100 …new ArraySegment<byte>(receiveBuffer, totalBytesReceived, receiveBuffer.Length - totalBytesReceive… in SendReceive_PartialMessageBeforeCompleteMessageArrives_Success()
104 Assert.InRange(recvResult.Count, 0, receiveBuffer.Length - totalBytesReceived); in SendReceive_PartialMessageBeforeCompleteMessageArrives_Success()
105 totalBytesReceived += recvResult.Count; in SendReceive_PartialMessageBeforeCompleteMessageArrives_Success()
108 Assert.Equal(receiveBuffer.Length, totalBytesReceived); in SendReceive_PartialMessageBeforeCompleteMessageArrives_Success()
/dports/comms/limesuite/LimeSuite-20.10.0/src/FPGA_common/
H A DFPGA_Mini.cpp179 int totalBytesReceived = 0; in ReadRawStreamData() local
191 totalBytesReceived = connection->FinishDataReading(buffer, length, handle); in ReadRawStreamData()
196 return totalBytesReceived; in ReadRawStreamData()
/dports/net-im/gloox/gloox-1.0.24/src/
H A Dstatisticshandler.h30 …long int totalBytesReceived; /**< The total number of bytes received over the wire. This d… member
/dports/converters/wkhtmltopdf/qt-5db36ec/src/3rdparty/webkit/Source/WebCore/loader/
H A DProgressTracker.h57 long long totalBytesReceived() const { return m_totalBytesReceived; } in totalBytesReceived() function
/dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/state/
H A DQuicConnectionStats.h58 uint64_t totalBytesReceived{0};
/dports/net-im/jitsi-videobridge/jitsi-videobridge-dbddd16/src/main/java/org/jitsi/videobridge/
H A DConference.java577 videobridgeStatistics.totalBytesReceived.addAndGet( in updateStatisticsOnExpire()
578 statistics.totalBytesReceived.get()); in updateStatisticsOnExpire()
1372 AtomicLong totalBytesReceived = new AtomicLong(); field in Conference.Statistics
1410 jsonObject.put("total_bytes_received", totalBytesReceived.get()); in getJson()
/dports/comms/limesuite/LimeSuite-20.10.0/src/protocols/
H A DStreamer.cpp828 unsigned long totalBytesReceived = 0; //for data rate calculation in ReceivePacketsLoop() local
843 totalBytesReceived += bytesReceived; in ReceivePacketsLoop()
847 rxDataRate_Bps.store(totalBytesReceived, std::memory_order_relaxed); in ReceivePacketsLoop()
848 totalBytesReceived = 0; in ReceivePacketsLoop()
905 double dataRate = 1000.0*totalBytesReceived / timePeriod; in ReceivePacketsLoop()
909 totalBytesReceived = 0; in ReceivePacketsLoop()
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/cronet/ios/test/
H A Dcronet_test_base.h76 - (long)totalBytesReceived;
/dports/math/hmat-oss/hmat-oss-1.7.1/src/common/
H A Dcontext.hpp58 int totalBytesReceived; member in trace::NodeData
H A Dcontext.cpp143 << "\"totalBytesReceived\": " << data.totalBytesReceived << ", " in jsonDump()
/dports/comms/limesuite/LimeSuite-20.10.0/QuickTest/
H A DLimeSDRTest.cpp345 long totalBytesReceived = 0; in RunTest() local
362 if (( totalBytesReceived = conn->FinishDataReading(data_buffer, buffer_size, handle))<=0) in RunTest()
/dports/net-im/jitsi-videobridge/jitsi-videobridge-dbddd16/src/main/java/org/jitsi/videobridge/stats/
H A DVideobridgeStatistics.java493 TOTAL_BYTES_RECEIVED, jvbStats.totalBytesReceived.get()); in generate0()

12