Class StandardEventsReader

input/StandardEventsReader.java:45–235

External events reader for standard-format events (created e.g by the dtnsim2parser). Syntax: <time> <actionId> <msgId> <hostId> [<host2Id> [<size>] [<respSize>]] All actions (except CONNECTION) must have first four fields

 * </P>
 */
public class StandardEventsReader implements ExternalEventsReader {
	/** Identifier of message creation event ({@value}) */
	public static final String CREATE = "C";
	/** Identifier of message transfer start event ({@value}) */
	public static final String SEND = "S";
	/** Identifier of message delivered event ({@value}) */
	public static final String DELIVERED = "DE";
	/** Identifier of message transfer aborted event ({@value}) */
	public static final String ABORT = "A";
	/** Identifier of message dropped event ({@value}) */
	public static final String DROP = "DR";
	/** Identifier of message removed event ({@value}) */
	public static final String REMOVE = "R";
	/** Identifier of connection event ({@value}) */
	public static final String CONNECTION = "CONN";
	/** Value identifier of connection down event ({@value}) */
	public static final String CONNECTION_DOWN = "down";
	/** Value identifier of connection up event ({@value}) */
	public static final String CONNECTION_UP = "up";
	/** Message identifier to use to refer to all messages ({@value}) */ 
	public static final String ALL_MESSAGES_ID = "*";
	
	//private Scanner scanner;
	private BufferedReader reader;
	
	public StandardEventsReader(File eventsFile){
		try {
			//this.scanner = new Scanner(eventsFile);
			this.reader = new BufferedReader(new FileReader(eventsFile));
		} catch (FileNotFoundException e) {
			throw new SimError(e.getMessage(),e);
		}
	}
	
	
	public List<ExternalEvent> readEvents(int nrof) {
		ArrayList<ExternalEvent> events = new ArrayList<ExternalEvent>(nrof);
		int eventsRead = 0;
		// skip empty and comment lines
		Pattern skipPattern = Pattern.compile("(#.*)|(^\\s*$)");
		
		String line;
		try {
			line = this.reader.readLine();
		} catch (IOException e1) {
			throw new SimError("Reading from external event file failed.");
		}
		while (eventsRead < nrof && line != null) {
			Scanner lineScan = new Scanner(line);
			if (skipPattern.matcher(line).matches()) {
				// skip empty and comment lines
				try {
					line = this.reader.readLine();
				} catch (IOException e) {
					throw new SimError("Reading from external event file " +
							"failed.");
				}
				continue;