175 |
|
if (false && batchLimit <= 0) |
176 |
|
batchLimit = (2 * nClients + 1) / 3; |
177 |
|
|
178 |
< |
ExThreads = nServers * nClients ; // expected # of threads |
178 |
> |
ExThreads = nServers * nClients ; // expected # of threads |
179 |
|
HoldLimit = ExThreads ; |
180 |
|
|
181 |
|
// start up all threads |
241 |
|
numMsgs += servers[i].msgsReceived; |
242 |
|
long deltaMsgs = numMsgs - lastNumMsgs; |
243 |
|
long deltaT = sampleEnd - sampleStart; |
244 |
< |
if (true || j != 2) { // Don't report results if we issued a hold ... |
244 |
> |
if (true || j != 2) { // Don't report results if we issued a hold ... |
245 |
|
System.out.print( |
246 |
|
"Sample period = " + deltaT + " ms; " |
247 |
|
+ "New msgs rcvd = " + deltaMsgs + "; " |