You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by da...@apache.org on 2005/12/31 04:57:09 UTC

svn commit: r360229 - /webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/at/BasicParticipant.java

Author: dasarath
Date: Fri Dec 30 19:57:08 2005
New Revision: 360229

URL: http://svn.apache.org/viewcvs?rev=360229&view=rev
Log: (empty)

Added:
    webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/at/BasicParticipant.java

Added: webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/at/BasicParticipant.java
URL: http://svn.apache.org/viewcvs/webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/at/BasicParticipant.java?rev=360229&view=auto
==============================================================================
--- webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/at/BasicParticipant.java (added)
+++ webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/coordinator/at/BasicParticipant.java Fri Dec 30 19:57:08 2005
@@ -0,0 +1,202 @@
+/*
+ * Created on Dec 30, 2005
+ *
+ */
+package org.apache.ws.transaction.coordinator.at;
+
+import java.rmi.RemoteException;
+import java.util.Timer;
+import java.util.TimerTask;
+
+import javax.transaction.xa.XAException;
+import javax.transaction.xa.XAResource;
+
+import org.apache.axis.message.addressing.EndpointReference;
+import org.apache.ws.transaction.coordinator.CoordinationContext;
+import org.apache.ws.transaction.coordinator.ParticipantService;
+import org.apache.ws.transaction.coordinator.TimedOutException;
+import org.apache.ws.transaction.utility.Callback;
+import org.apache.ws.transaction.wsat.CoordinatorPortType;
+import org.apache.ws.transaction.wsat.Notification;
+import org.apache.ws.transaction.wsat.ParticipantPortType;
+import org.apache.ws.transaction.wscoor.Expires;
+
+/**
+ * @author Dasarath Weeratunge
+ *  
+ */
+public abstract class BasicParticipant implements ParticipantPortType, Callback {
+	private static Timer timer = new Timer();
+
+	public static final int RETRY_DELAY_MILLIS = 10 * 1000;
+
+	private EndpointReference c;
+
+	protected BasicParticipant(boolean durable, CoordinationContext ctx)
+			throws RemoteException {
+		long timeout = 0;
+		Expires ex = ctx.getExpires();
+		if (ex != null)
+			timeout = ex.get_value().longValue();
+		EndpointReference epr = ParticipantService.getInstance().getParticipantService(
+			this, timeout);
+		c = ctx.register(durable ? ATCoordinator.PROTOCOL_ID_DURABLE_2PC
+				: ATCoordinator.PROTOCOL_ID_VOLATILE_2PC, epr);
+	}
+
+	protected CoordinatorPortType getCoordinator() {
+		try {
+			return new CoordinatorStub(c);
+		} catch (Exception e) {
+			e.printStackTrace();
+			throw new RuntimeException(e);
+		}
+	}
+
+	protected abstract int prepare() throws XAException;
+
+	protected abstract void commit() throws XAException;
+
+	protected abstract void rollback() throws XAException;
+
+	protected abstract void forget();
+
+	protected abstract int getStatus();
+
+	public synchronized void prepareOperation(Notification parameters)
+			throws RemoteException {
+		switch (getStatus()) {
+		case AT2PCStatus.NONE:
+			getCoordinator().abortedOperation(null);
+			return;
+
+		case AT2PCStatus.ACTIVE:
+			final CoordinatorPortType p = getCoordinator();
+			try {
+				if (prepare() == XAResource.XA_RDONLY) {
+					forget();
+					p.readOnlyOperation(null);
+				} else {
+					p.preparedOperation(null);
+					timer.schedule(new TimerTask() {
+						public void run() {
+							switch (getStatus()) {
+							case AT2PCStatus.NONE:
+							case AT2PCStatus.ACTIVE:
+							case AT2PCStatus.PREPARING:
+							case AT2PCStatus.ABORTING:
+							case AT2PCStatus.COMMITTING:
+								cancel();
+								return;
+
+							case AT2PCStatus.PREPARED:
+								try {
+									p.preparedOperation(null);
+								} catch (RemoteException e) {
+									e.printStackTrace();
+								}
+							}
+						}
+					}, RETRY_DELAY_MILLIS, RETRY_DELAY_MILLIS);
+				}
+			} catch (XAException e) {
+				forget();
+				p.abortedOperation(null);
+			}
+			return;
+
+		case AT2PCStatus.PREPARING:
+			return;
+
+		case AT2PCStatus.PREPARED:
+			getCoordinator().preparedOperation(null);
+			return;
+
+		case AT2PCStatus.ABORTING:
+			forget();
+			getCoordinator().abortedOperation(null);
+			return;
+
+		case AT2PCStatus.COMMITTING:
+		}
+	}
+
+	public synchronized void commitOperation(Notification parameters)
+			throws RemoteException {
+		switch (getStatus()) {
+		case AT2PCStatus.NONE:
+			getCoordinator().committedOperation(null);
+			return;
+
+		case AT2PCStatus.ACTIVE:
+		case AT2PCStatus.PREPARING:
+			try {
+				rollback();
+				forget();
+				getCoordinator().abortedOperation(null);
+			} catch (XAException e) {
+				e.printStackTrace();
+			}
+			return;
+
+		case AT2PCStatus.PREPARED:
+			try {
+				commit();
+				forget();
+				getCoordinator().committedOperation(null);
+			} catch (XAException e) {
+				e.printStackTrace();
+			}
+			return;
+
+		case AT2PCStatus.ABORTING:
+			throw new IllegalStateException();
+
+		case AT2PCStatus.COMMITTING:
+		}
+	}
+
+	public synchronized void rollbackOperation(Notification parameters)
+			throws RemoteException {
+		switch (getStatus()) {
+		case AT2PCStatus.NONE:
+			getCoordinator().abortedOperation(null);
+			return;
+
+		case AT2PCStatus.ACTIVE:
+		case AT2PCStatus.PREPARING:
+		case AT2PCStatus.PREPARED:
+			try {
+				rollback();
+				forget();
+				getCoordinator().abortedOperation(null);
+			} catch (XAException e) {
+				e.printStackTrace();
+			}
+			return;
+
+		case AT2PCStatus.ABORTING:
+			forget();
+			getCoordinator().abortedOperation(null);
+			return;
+
+		case AT2PCStatus.COMMITTING:
+			throw new IllegalStateException();
+		}
+	}
+
+	public void timeout() {
+		System.out.println("[BasicParticipant] timeout "
+				+ AT2PCStatus.getStatusName(getStatus()));
+		if (getStatus() == AT2PCStatus.NONE)
+			return;
+		try {
+			rollback();
+			forget();
+			getCoordinator().abortedOperation(null);
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+		throw new TimedOutException();
+	}
+}
\ No newline at end of file



---------------------------------------------------------------------
To unsubscribe, e-mail: kandula-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: kandula-dev-help@ws.apache.org