long totalRequests = iterations*(long)apps;
float requestPerMsSecond = totalRequests/(float)duration;
System.out.println("totalRequests: "+totalRequests+" perMs:"+requestPerMsSecond);
}
private HTTP1xRouterStage buildRouterStage(GraphManager gm, final int apps,
<BUG>final PipeConfig<HTTPRequestSchema> appPipeConfig, Pipe<NetPayloadSchema>[] pipes, Pipe<ReleaseSchema> ack) {
</BUG>
Pipe[] routedAppPipes = new Pipe[apps];
<BUG>long[] appHeaders = new long[apps];</BUG>
int i = apps;
while (--i >= 0) {
routedAppPipes[i] = new Pipe<HTTPRequestSchema>(appPipeConfig);
<BUG>appHeaders[i] = 0;//(1<<HTTPHeaderRequestKeyDefaults.UPGRADE.ordinal());//headers needed.</BUG>
GraphManager.addNota(gm, GraphManager.SCHEDULE_RATE, 10_000,

long totalRequests = iterations*(long)apps;
float requestPerMsSecond = totalRequests/(float)duration;
System.out.println("totalRequests: "+totalRequests+" perMs:"+requestPerMsSecond);
}
private HTTP1xRouterStage buildRouterStage(GraphManager gm, final int apps,
final PipeConfig<HTTPRequestSchema> appPipeConfig, Pipe<NetPayloadSchema>[] pipes, Pipe<ReleaseSchema> ack, HTTP1xRouterStageConfig routerConfig) {
Pipe[] routedAppPipes = new Pipe[apps];
int i = apps;
while (--i >= 0) {
routedAppPipes[i] = new Pipe<HTTPRequestSchema>(appPipeConfig);
GraphManager.addNota(gm, GraphManager.SCHEDULE_RATE, 10_000,
