/dports/devel/spark/spark-2.1.1/streaming/src/test/scala/org/apache/spark/streaming/scheduler/ |
H A D | ExecutorAllocationManagerSuite.scala | 153 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 D | Object.cpp | 318 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 D | ReceiverSchedulingPolicy.scala | 125 val (leastScheduledExecutor, numReceivers) = numReceiversOnExecutor.minBy(_._2) 127 numReceiversOnExecutor(leastScheduledExecutor) = numReceivers + 1
|
H A D | ExecutorAllocationManager.scala | 63 math.max(1, receiverTracker.numReceivers))
|
H A D | ReceiverTracker.scala | 262 def numReceivers(): Int = { method
|
/dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/ |
H A D | StreamingSource.scala | 47 registerGauge("receivers", _.numReceivers, 0)
|
/dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/ui/ |
H A D | StreamingPage.scala | 304 val numReceivers = listener.numInactiveReceivers + listener.numActiveReceivers constant 333 if (numReceivers > 0) { 334 <div>Receivers: {listener.numActiveReceivers} / {numReceivers} active</div>
|
H A D | StreamingJobProgressListener.scala | 155 def numReceivers: Int = synchronized { method
|
/dports/net/liveMedia/live/liveMedia/include/ |
H A D | RTPSink.hh | 139 unsigned numReceivers() const { return fNumReceivers; } in numReceivers() function in RTPTransmissionStatsDB
|
/dports/graphics/dcmtk/dcmtk-DCMTK-3.6.6/dcmpstat/apps/ |
H A D | dcmpsrcv.cc | 740 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 D | MIR.cpp | 4533 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 D | CodeGenerator.cpp | 2416 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 D | MIR.h | 10490 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 D | MIR.cpp | 5100 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 D | MIR.h | 8710 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 D | CodeGenerator.cpp | 4357 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 D | MIR.cpp | 5355 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 D | MIR.h | 10815 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 D | CodeGenerator.cpp | 3042 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 D | MIR.cpp | 4974 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 D | MIR.h | 9381 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 D | CodeGenerator.cpp | 3390 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()
|