private int shutCountDown;
private long start;
private long totalBytes=0;
private static final boolean enableWriteBatching = true;
private final boolean debugWithSlowWrites = false;
<BUG>private final int     debugMaxBlockSize = 50;
private StringBuilder[] accumulators;//for testing only</BUG>
public static ClientSocketWriterStage newInstance(GraphManager graphManager, ClientCoordinator ccm, Pipe<NetPayloadSchema>[] input) {
return new ClientSocketWriterStage(graphManager, ccm, input);
}

private int shutCountDown;
private long start;
private long totalBytes=0;
private static final boolean enableWriteBatching = true;
private final boolean debugWithSlowWrites = false;
private final int     debugMaxBlockSize = 50;
private final int BUF_MULTIPLER = 20; 	//some of these accumulations are small, TODO: apply same fix as we did on the server?
private StringBuilder[] accumulators;//for testing only
public static ClientSocketWriterStage newInstance(GraphManager graphManager, ClientCoordinator ccm, Pipe<NetPayloadSchema>[] input) {
return new ClientSocketWriterStage(graphManager, ccm, input);
}
