org.eclipse.jdt.debug/jdi/org/eclipse/jdi/internal/event/EventQueueImpl.java

package org.eclipse.jdi.internal.event;

/*
 * (c) Copyright IBM Corp. 2000, 2001.
 * All Rights Reserved.
 */

import com.sun.jdi.*;
import com.sun.jdi.event.*;
import com.sun.jdi.connect.*;
import com.sun.jdi.request.*;
import org.eclipse.jdi.TimeoutException;
import org.eclipse.jdi.internal.*;
import org.eclipse.jdi.internal.connect.*;
import org.eclipse.jdi.internal.jdwp.*;
import org.eclipse.jdi.internal.request.*;
import java.io.*;

/**
 * this class implements the corresponding interfaces
 * declared by the JDI specification. See the com.sun.jdi package
 * for more information.
 *
 */
public class EventQueueImpl extends MirrorImpl implements EventQueue {
	/** Flag used to see if a VMDisconnectEvent has already been generated. */
	private boolean genereatedVMDisconnectEvent = false;
	
	/**
	 * Creates new EventQueueImpl.
	 */
	public EventQueueImpl(VirtualMachineImpl vmImpl) {
		super("EventQueue", vmImpl);
	}

	/*
	 * @return Returns next EventSet from Virtual Machine.
	 */
	public EventSet remove() throws InterruptedException {
		return remove(PacketReceiveManager.TIMEOUT_INFINITE);
	}

	/*
	 * @return Returns next EventSet from Virtual Machine, returns null if times out.
	 */
	public EventSet remove(long timeout) throws InterruptedException {
		// Return a received EventSet or null if no EventSet is received in time.
		// Note that handledJdwpEventSet() is not don in a 'finally' clause because
		// it must also be done when an 'empty' set is read (i.e. a set composed of internal
		// events only).
	 	try {
	 		// We remove elements from event sets that are generated from inside, therefore the set may become empty.
	 		EventSetImpl set;
	 		do {
	 			JdwpCommandPacket packet = getCommandVM(JdwpCommandPacket.E_COMPOSITE, timeout);
	 			initJdwpEventSet(packet);
	 			set = EventSetImpl.read(this, packet.dataInStream());
				handledJdwpEventSet();
	 		} while (set.isEmpty());
	 		return set;
		} catch (TimeoutException e) {
			// Timeout in getCommand, JDI spec says return null.
			handledJdwpEventSet();
			return null;
		} catch (IOException e) {
			// This means the already received data is invalid.
			handledJdwpEventSet();
			defaultIOExceptionHandler(e);
			return null;
		} catch(VMDisconnectedException e) {
			// JDI spec says that a VMDisconnectedException must always be preceeded by a VMDisconnectEvent.
			handledJdwpEventSet();
			if (!genereatedVMDisconnectEvent) {
				genereatedVMDisconnectEvent = true;
				return new EventSetImpl(virtualMachineImpl(), new VMDisconnectEventImpl(virtualMachineImpl(), RequestID.nullID));
			} else {
				throw e;
			}
	 	}
	}
}