| /dports/net-mgmt/promscale/promscale-0.6.2/pkg/ha/ |
| H A D | filter.go | 138 numAccepted := 0
144 t.Samples[numAccepted] = sample
145 numAccepted++
147 for j := numAccepted; j < len(t.Samples); j++ {
150 t.Samples = t.Samples[:numAccepted]
159 numAccepted := 0
165 wr.Timeseries[numAccepted] = *t
166 numAccepted++
177 for j := numAccepted; j < len(wr.Timeseries); j++ {
180 wr.Timeseries = wr.Timeseries[:numAccepted]
|
| /dports/net-mgmt/promscale/promscale-0.6.2/pkg/api/parser/ |
| H A D | parser_test.go | 29 numAccepted := 0
35 wr.Timeseries[i].Samples[numAccepted] = sample
36 numAccepted++
38 wr.Timeseries[i].Samples = wr.Timeseries[i].Samples[:numAccepted]
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/util/random/ |
| H A D | StratifiedSamplingUtils.scala | 109 acceptResult.numAccepted += copiesAccepted
126 acceptResult.numAccepted += 1
184 if (acceptResult.numAccepted > sampleSize) {
188 val numWaitListAccepted = (sampleSize - acceptResult.numAccepted).toInt
316 private[random] class AcceptanceResult(var numItems: Long = 0L, var numAccepted: Long = 0L)
328 numAccepted += other.get.numAccepted
|
| /dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/collector/obsreport/ |
| H A D | obsreport_receiver.go | 154 numAccepted := numReceivedItems
157 numAccepted = 0
179 acceptedMeasure.M(int64(numAccepted)),
200 attribute.Int64(acceptedItemsKey, int64(numAccepted)),
|
| /dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/lib/aSocket/ |
| H A D | ListenEventHandler.java | 55 int numAccepted = 0; in processAccept() local
58 while (numAccepted++ < aSocketConst.MAX_ACCEPTS_AT_ONCE) { in processAccept()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/thrift/lib/cpp/test/ |
| H A D | TServerIntegrationTest.cpp | 191 void blockUntilAccepted(uint64_t numAccepted) { in blockUntilAccepted() argument
193 while (pEventHandler->acceptedCount() < numAccepted) { in blockUntilAccepted()
197 BOOST_TEST_MESSAGE(boost::format(" server has accepted %1%") % numAccepted); in blockUntilAccepted()
|
| /dports/net/storj/storj-1.45.3/vendor/github.com/apache/thrift/lib/cpp/test/ |
| H A D | TServerIntegrationTest.cpp | 191 void blockUntilAccepted(uint64_t numAccepted) { in blockUntilAccepted() argument
193 while (pEventHandler->acceptedCount() < numAccepted) { in blockUntilAccepted()
197 BOOST_TEST_MESSAGE(boost::format(" server has accepted %1%") % numAccepted); in blockUntilAccepted()
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/apache/thrift/thrift-da1169d75b15/lib/cpp/test/ |
| H A D | TServerIntegrationTest.cpp | 191 void blockUntilAccepted(uint64_t numAccepted) { in blockUntilAccepted() argument
193 while (pEventHandler->acceptedCount() < numAccepted) { in blockUntilAccepted()
197 BOOST_TEST_MESSAGE(boost::format(" server has accepted %1%") % numAccepted); in blockUntilAccepted()
|
| /dports/devel/thrift-c_glib/thrift-0.14.0/lib/cpp/test/ |
| H A D | TServerIntegrationTest.cpp | 191 void blockUntilAccepted(uint64_t numAccepted) { in blockUntilAccepted() argument
193 while (pEventHandler->acceptedCount() < numAccepted) { in blockUntilAccepted()
197 BOOST_TEST_MESSAGE(boost::format(" server has accepted %1%") % numAccepted); in blockUntilAccepted()
|
| /dports/devel/thrift-cpp/thrift-0.14.0/lib/cpp/test/ |
| H A D | TServerIntegrationTest.cpp | 191 void blockUntilAccepted(uint64_t numAccepted) { in blockUntilAccepted() argument
193 while (pEventHandler->acceptedCount() < numAccepted) { in blockUntilAccepted()
197 BOOST_TEST_MESSAGE(boost::format(" server has accepted %1%") % numAccepted); in blockUntilAccepted()
|
| /dports/devel/thrift/thrift-0.14.0/lib/cpp/test/ |
| H A D | TServerIntegrationTest.cpp | 191 void blockUntilAccepted(uint64_t numAccepted) { in blockUntilAccepted() argument
193 while (pEventHandler->acceptedCount() < numAccepted) { in blockUntilAccepted()
197 BOOST_TEST_MESSAGE(boost::format(" server has accepted %1%") % numAccepted); in blockUntilAccepted()
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/apache/thrift/lib/cpp/test/ |
| H A D | TServerIntegrationTest.cpp | 191 void blockUntilAccepted(uint64_t numAccepted) { in blockUntilAccepted() argument
193 while (pEventHandler->acceptedCount() < numAccepted) { in blockUntilAccepted()
197 BOOST_TEST_MESSAGE(boost::format(" server has accepted %1%") % numAccepted); in blockUntilAccepted()
|
| /dports/devel/node-thrift/thrift-0.14.0/lib/cpp/test/ |
| H A D | TServerIntegrationTest.cpp | 191 void blockUntilAccepted(uint64_t numAccepted) { in blockUntilAccepted() argument
193 while (pEventHandler->acceptedCount() < numAccepted) { in blockUntilAccepted()
197 BOOST_TEST_MESSAGE(boost::format(" server has accepted %1%") % numAccepted); in blockUntilAccepted()
|
| /dports/devel/py-thrift/thrift-0.14.0/lib/cpp/test/ |
| H A D | TServerIntegrationTest.cpp | 191 void blockUntilAccepted(uint64_t numAccepted) { in blockUntilAccepted() argument
193 while (pEventHandler->acceptedCount() < numAccepted) { in blockUntilAccepted()
197 BOOST_TEST_MESSAGE(boost::format(" server has accepted %1%") % numAccepted); in blockUntilAccepted()
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/media/webrtc/signaling/test/ |
| H A D | jsep_session_unittest.cpp | 3688 size_t numAccepted = types.size() - numRejected; in TEST_P() local
3690 ASSERT_EQ(numAccepted, mSessionOff.GetNegotiatedTrackPairs().size()); in TEST_P()
3691 ASSERT_EQ(numAccepted, mSessionAns.GetNegotiatedTrackPairs().size()); in TEST_P()
3695 ASSERT_EQ(numAccepted, mSessionOff.GetRemoteTracks().size()); in TEST_P()
|
| /dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/signaling/gtest/ |
| H A D | jsep_session_unittest.cpp | 3969 size_t numAccepted = types.size() - numRejected; in TEST_P() local
3980 ASSERT_EQ(numAccepted, GetRemoteTracks(*mSessionOff).size()); in TEST_P()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/media/webrtc/signaling/gtest/ |
| H A D | jsep_session_unittest.cpp | 4160 size_t numAccepted = types.size() - numRejected; in TEST_P() local
4171 ASSERT_EQ(numAccepted, GetRemoteTracks(*mSessionOff).size()); in TEST_P()
|
| /dports/www/firefox-esr/firefox-91.8.0/media/webrtc/signaling/gtest/ |
| H A D | jsep_session_unittest.cpp | 4180 size_t numAccepted = types.size() - numRejected; in TEST_P() local
4191 ASSERT_EQ(numAccepted, GetRemoteTracks(*mSessionOff).size()); in TEST_P()
|
| /dports/www/firefox/firefox-99.0/media/webrtc/signaling/gtest/ |
| H A D | jsep_session_unittest.cpp | 4180 size_t numAccepted = types.size() - numRejected; in TEST_P() local
4191 ASSERT_EQ(numAccepted, GetRemoteTracks(*mSessionOff).size()); in TEST_P()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/media/webrtc/signaling/gtest/ |
| H A D | jsep_session_unittest.cpp | 4180 size_t numAccepted = types.size() - numRejected; in TEST_P() local
4191 ASSERT_EQ(numAccepted, GetRemoteTracks(*mSessionOff).size()); in TEST_P()
|