Home
last modified time | relevance | path

Searched refs:numReceivers (Results 1 – 22 of 22) sorted by relevance

/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/scheduler/
H A DExecutorAllocationManagerSuite.scala153 withAllocationManager(numReceivers = 2) { case(_, allocationManager) =>
236 numReceivers: Int = 1,
242 require(numReceivers > 0)
244 when(receiverTracker.numReceivers()).thenReturn(numReceivers)
269 validateParams(numReceivers = 1)
270 validateParams(numReceivers = 2, minExecs = Some(1))
271 validateParams(numReceivers = 2, minExecs = Some(3))
272 validateParams(numReceivers = 2, maxExecs = Some(3))
273 validateParams(numReceivers = 2, maxExecs = Some(1))
347 numReceivers: Int = 1
[all …]
/dports/graphics/urho3d/Urho3D-1.7.1/Source/Urho3D/Core/
H A DObject.cpp318 const unsigned numReceivers = group->receivers_.Size(); in SendEvent() local
319 for (unsigned i = 0; i < numReceivers; ++i) in SendEvent()
350 const unsigned numReceivers = group->receivers_.Size(); in SendEvent() local
351 for (unsigned i = 0; i < numReceivers; ++i) in SendEvent()
370 const unsigned numReceivers = group->receivers_.Size(); in SendEvent() local
371 for (unsigned i = 0; i < numReceivers; ++i) in SendEvent()
/dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/scheduler/
H A DReceiverSchedulingPolicy.scala125 val (leastScheduledExecutor, numReceivers) = numReceiversOnExecutor.minBy(_._2)
127 numReceiversOnExecutor(leastScheduledExecutor) = numReceivers + 1
H A DExecutorAllocationManager.scala63 math.max(1, receiverTracker.numReceivers))
H A DReceiverTracker.scala262 def numReceivers(): Int = { method
/dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/
H A DStreamingSource.scala47 registerGauge("receivers", _.numReceivers, 0)
/dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/ui/
H A DStreamingPage.scala304 val numReceivers = listener.numInactiveReceivers + listener.numActiveReceivers constant
333 if (numReceivers > 0) {
334 <div>Receivers: {listener.numActiveReceivers} / {numReceivers} active</div>
H A DStreamingJobProgressListener.scala155 def numReceivers: Int = synchronized { method
/dports/net/liveMedia/live/liveMedia/include/
H A DRTPSink.hh139 unsigned numReceivers() const { return fNumReceivers; } in numReceivers() function in RTPTransmissionStatsDB
/dports/graphics/dcmtk/dcmtk-DCMTK-3.6.6/dcmpstat/apps/
H A Ddcmpsrcv.cc740 Uint32 numReceivers = dvi.getNumberOfTargets(DVPSE_receiver); in terminateAllReceivers() local
741 for (Uint32 i=0; i<numReceivers; i++) in terminateAllReceivers()
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/third_party/mozjs-45/extract/js/src/jit/
H A DMIR.cpp4533 if (numReceivers() != other->numReceivers()) in congruentTo()
4535 for (size_t i = 0; i < numReceivers(); i++) { in congruentTo()
4682 for (size_t i = 0; i < numReceivers(); i++) { in mightAlias()
H A DCodeGenerator.cpp2416 for (size_t i = 0; i < mir->numReceivers(); i++) { in emitGetPropertyPolymorphic()
2446 if (i == mir->numReceivers() - 1) { in emitGetPropertyPolymorphic()
2495 for (size_t i = 0; i < mir->numReceivers(); i++) { in emitSetPropertyPolymorphic()
2530 if (i == mir->numReceivers() - 1) { in emitSetPropertyPolymorphic()
2673 for (size_t i = 0; i < mir->numReceivers(); i++) { in visitGuardReceiverPolymorphic()
2679 if (i == mir->numReceivers() - 1) { in visitGuardReceiverPolymorphic()
H A DMIR.h10490 size_t numReceivers() const { in numReceivers() function
10507 for (size_t i = 0; i < numReceivers(); i++) { in getAliasSet()
10563 size_t numReceivers() const { in numReceivers() function
10589 for (size_t i = 0; i < numReceivers(); i++) { in getAliasSet()
10882 size_t numReceivers() const { in numReceivers() function
/dports/lang/spidermonkey78/firefox-78.9.0/js/src/jit/
H A DMIR.cpp5100 if (numReceivers() != other->numReceivers()) { in congruentTo()
5103 for (size_t i = 0; i < numReceivers(); i++) { in congruentTo()
5216 for (size_t i = 0; i < numReceivers(); i++) { in mightAlias()
H A DMIR.h8710 size_t numReceivers() const { return receivers_.length(); } in numReceivers() function
8718 for (size_t i = 0; i < numReceivers(); i++) { in getAliasSet()
8765 size_t numReceivers() const { return receivers_.length(); } in numReceivers() function
8775 for (size_t i = 0; i < numReceivers(); i++) { in getAliasSet()
9080 size_t numReceivers() const { return receivers_.length(); } in numReceivers() function
H A DCodeGenerator.cpp4357 for (size_t i = 0; i < mir->numReceivers(); i++) { in emitGetPropertyPolymorphic()
4383 if (i == mir->numReceivers() - 1) { in emitGetPropertyPolymorphic()
4416 for (size_t i = 0; i < mir->numReceivers(); i++) { in emitSetPropertyPolymorphic()
4445 if (i == mir->numReceivers() - 1) { in emitSetPropertyPolymorphic()
4668 for (size_t i = 0; i < mir->numReceivers(); i++) { in visitGuardReceiverPolymorphic()
4674 if (i == mir->numReceivers() - 1) { in visitGuardReceiverPolymorphic()
/dports/www/firefox-legacy/firefox-52.8.0esr/js/src/jit/
H A DMIR.cpp5355 if (numReceivers() != other->numReceivers()) in congruentTo()
5357 for (size_t i = 0; i < numReceivers(); i++) { in congruentTo()
5514 for (size_t i = 0; i < numReceivers(); i++) { in mightAlias()
H A DMIR.h10815 size_t numReceivers() const { in numReceivers() function
10829 for (size_t i = 0; i < numReceivers(); i++) { in getAliasSet()
10880 size_t numReceivers() const { in numReceivers() function
10900 for (size_t i = 0; i < numReceivers(); i++) { in getAliasSet()
11213 size_t numReceivers() const { in numReceivers() function
H A DCodeGenerator.cpp3042 for (size_t i = 0; i < mir->numReceivers(); i++) { in emitGetPropertyPolymorphic()
3075 if (i == mir->numReceivers() - 1) { in emitGetPropertyPolymorphic()
3124 for (size_t i = 0; i < mir->numReceivers(); i++) { in emitSetPropertyPolymorphic()
3159 if (i == mir->numReceivers() - 1) { in emitSetPropertyPolymorphic()
3304 for (size_t i = 0; i < mir->numReceivers(); i++) { in visitGuardReceiverPolymorphic()
3310 if (i == mir->numReceivers() - 1) { in visitGuardReceiverPolymorphic()
/dports/lang/spidermonkey60/firefox-60.9.0/js/src/jit/
H A DMIR.cpp4974 if (numReceivers() != other->numReceivers()) return false; in congruentTo()
4975 for (size_t i = 0; i < numReceivers(); i++) { in congruentTo()
5076 for (size_t i = 0; i < numReceivers(); i++) { in mightAlias()
H A DMIR.h9381 size_t numReceivers() const { return receivers_.length(); } in numReceivers() function
9389 for (size_t i = 0; i < numReceivers(); i++) { in getAliasSet()
9436 size_t numReceivers() const { return receivers_.length(); } in numReceivers() function
9446 for (size_t i = 0; i < numReceivers(); i++) { in getAliasSet()
9713 size_t numReceivers() const { return receivers_.length(); } in numReceivers() function
H A DCodeGenerator.cpp3390 for (size_t i = 0; i < mir->numReceivers(); i++) { in emitGetPropertyPolymorphic()
3427 if (i == mir->numReceivers() - 1) { in emitGetPropertyPolymorphic()
3473 for (size_t i = 0; i < mir->numReceivers(); i++) { in emitSetPropertyPolymorphic()
3509 if (i == mir->numReceivers() - 1) { in emitSetPropertyPolymorphic()
3717 for (size_t i = 0; i < mir->numReceivers(); i++) { in visitGuardReceiverPolymorphic()
3724 if (i == mir->numReceivers() - 1) { in visitGuardReceiverPolymorphic()