| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/ |
| H A D | BufferingSubscriberTest.java | 265 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 D | BufferingSubscriberTest.java | 265 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 D | BufferingSubscriberTest.java | 265 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 D | BufferingSubscriberTest.java | 265 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 D | BufferingSubscriberTest.java | 265 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 D | BufferingSubscriberTest.java | 265 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 D | BufferingSubscriberTest.java | 265 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 D | BufferingSubscriberTest.java | 265 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 D | apib_reporting.cc | 81 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 D | apib_reporting.h | 49 int64_t totalBytesReceived; variable
|
| /dports/benchmarks/apib/apib-APIB_1_2_1_RC1/test/ |
| H A D | reporting_test.cc | 54 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 D | main.go | 97 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 D | main.go | 97 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 D | SendReceiveTest.cs | 94 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 D | FPGA_Mini.cpp | 179 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 D | statisticshandler.h | 30 …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 D | ProgressTracker.h | 57 long long totalBytesReceived() const { return m_totalBytesReceived; } in totalBytesReceived() function
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/state/ |
| H A D | QuicConnectionStats.h | 58 uint64_t totalBytesReceived{0};
|
| /dports/net-im/jitsi-videobridge/jitsi-videobridge-dbddd16/src/main/java/org/jitsi/videobridge/ |
| H A D | Conference.java | 577 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 D | Streamer.cpp | 828 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 D | cronet_test_base.h | 76 - (long)totalBytesReceived;
|
| /dports/math/hmat-oss/hmat-oss-1.7.1/src/common/ |
| H A D | context.hpp | 58 int totalBytesReceived; member in trace::NodeData
|
| H A D | context.cpp | 143 << "\"totalBytesReceived\": " << data.totalBytesReceived << ", " in jsonDump()
|
| /dports/comms/limesuite/LimeSuite-20.10.0/QuickTest/ |
| H A D | LimeSDRTest.cpp | 345 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 D | VideobridgeStatistics.java | 493 TOTAL_BYTES_RECEIVED, jvbStats.totalBytesReceived.get()); in generate0()
|