totalData += throughput[i];
if (duplicateSplitter) { totalData = MAX(throughput[i], totalData); } else { totalData += throughput[i]; }
    public void prepareToWork() {	if (!Stream.scheduledRun) {	    // for the day when splitters can ever receive messages,	    // make sure that all inputs are ready before starting	    // execution, so that messages can be delivered in time	    // get output weights	    int throughput[] =		(sjIter != null		 ? sjIter.getSplitPushWeights(nWork)		 : flIter.getSplitPushWeights(nWork));	    // sum output weights to get input weights	    int totalData = 0;	    for (int i=0; i<throughput.length; i++) {		totalData += throughput[i];	    }	    // ensure data	    input.ensureData(totalData);	}	super.prepareToWork();    }