sendMsgToAllEdges(
new BytesWritable(workerContext.getMessageBytes()));
long bytesSent = workerContext.getMessageBytes().length *
getNumOutEdges();
superstepBytesAggregator.aggregate(bytesSent);
superstepMessagesAggregator.aggregate(getNumOutEdges());
}
} else {
voteToHalt();
}
}