Java/Ema/PerfTools/src/main/java/com/refinitiv/ema/perftools/emajconsperf/ConsumerThread.java
protected boolean sendBursts(int currentTicks) 
	{
    	//send item requests until all sent
    	if (_consThreadInfo.stats().requestCount().getTotal() < _requestListSize)
        {
			int requestBurstCount;

			requestBurstCount = _consPerfConfig.requestsPerTick();
			if (currentTicks > _consPerfConfig.requestsPerTickRemainder())
				++requestBurstCount;

			if (_consThreadInfo.stats().imageRetrievalStartTime() == 0)
			{
				if (!_consPerfConfig.primeJVM())
				{
					_consThreadInfo.stats().imageRetrievalStartTime(System.nanoTime());
				}
                else
                {
                    if (_JVMPrimingRefreshCount == _requestListSize)
                    {
                        _consThreadInfo.stats().imageRetrievalStartTime(System.nanoTime());
                    }
                }
			}

			return sendItemRequestBurst(requestBurstCount); 
		}

		// send bursts of posts and or generic msgs
		if (_consThreadInfo.stats().imageRetrievalEndTime() > 0) 
		{
			if (_consPerfConfig.postsPerSec() > 0 && _postItemCount > 0) 
				return sendPostBurst((int) (_postsPerTick + ((currentTicks < _postsPerTickRemainder) ? 1 : 0)));

			if (_consPerfConfig.genMsgsPerSec() > 0 && _genMsgItemCount > 0) 
				return sendGenMsgBurst((int) (_genMsgsPerTick + ((currentTicks < _genMsgsPerTickRemainder) ? 1 : 0))); 
		}

		return true;
	}
// send item requests, post bursts and or generic msg bursts.

send item requests, post bursts and or generic msg bursts.
send item requests post bursts and or generic msg bursts .
protected boolean sendBursts(int currentTicks) 
	{
    	if (_consThreadInfo.stats().requestCount().getTotal() < _requestListSize)
        {
			int requestBurstCount;
			requestBurstCount = _consPerfConfig.requestsPerTick();
			if (currentTicks > _consPerfConfig.requestsPerTickRemainder())
				++requestBurstCount;
			if (_consThreadInfo.stats().imageRetrievalStartTime() == 0)
			{
				if (!_consPerfConfig.primeJVM())
				{
					_consThreadInfo.stats().imageRetrievalStartTime(System.nanoTime());
				}
                else
                {
                    if (_JVMPrimingRefreshCount == _requestListSize)
                    {
                        _consThreadInfo.stats().imageRetrievalStartTime(System.nanoTime());
                    }
                }
			}
			return sendItemRequestBurst(requestBurstCount); 
		}
		if (_consThreadInfo.stats().imageRetrievalEndTime() > 0) 
		{
			if (_consPerfConfig.postsPerSec() > 0 && _postItemCount > 0) 
				return sendPostBurst((int) (_postsPerTick + ((currentTicks < _postsPerTickRemainder) ? 1 : 0)));
			if (_consPerfConfig.genMsgsPerSec() > 0 && _genMsgItemCount > 0) 
				return sendGenMsgBurst((int) (_genMsgsPerTick + ((currentTicks < _genMsgsPerTickRemainder) ? 1 : 0))); 
		}
		return true;
	}
protected boolean sendBursts ( int currentTicks ) { if ( _consThreadInfo . stats ( ) . requestCount ( ) . getTotal ( ) < _requestListSize ) { int requestBurstCount ; requestBurstCount = _consPerfConfig . requestsPerTick ( ) ; if ( currentTicks > _consPerfConfig . requestsPerTickRemainder ( ) ) ++ requestBurstCount ; if ( _consThreadInfo . stats ( ) . imageRetrievalStartTime ( ) == 0 ) { if ( ! _consPerfConfig . primeJVM ( ) ) { _consThreadInfo . stats ( ) . imageRetrievalStartTime ( System . nanoTime ( ) ) ; } else { if ( _JVMPrimingRefreshCount == _requestListSize ) { _consThreadInfo . stats ( ) . imageRetrievalStartTime ( System . nanoTime ( ) ) ; } } } return sendItemRequestBurst ( requestBurstCount ) ; } if ( _consThreadInfo . stats ( ) . imageRetrievalEndTime ( ) > 0 ) { if ( _consPerfConfig . postsPerSec ( ) > 0 && _postItemCount > 0 ) return sendPostBurst ( ( int ) ( _postsPerTick + ( ( currentTicks < _postsPerTickRemainder ) ? 1 : 0 ) ) ) ; if ( _consPerfConfig . genMsgsPerSec ( ) > 0 && _genMsgItemCount > 0 ) return sendGenMsgBurst ( ( int ) ( _genMsgsPerTick + ( ( currentTicks < _genMsgsPerTickRemainder ) ? 1 : 0 ) ) ) ; } return true ; }
send item requests, post bursts and or generic msg bursts.
send item requests post bursts and or generic msg bursts .
//send item requests until all sent
 // send bursts of posts and or generic msgs
