db-derby-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kmars...@apache.org
Subject svn commit: r123831 - /incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXAProtocol.java /incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXid.java /incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/XADatabase.java
Date Fri, 31 Dec 2004 23:36:21 GMT
Author: kmarsden
Date: Fri Dec 31 15:36:19 2004
New Revision: 123831

URL: http://svn.apache.org/viewcvs?view=rev&rev=123831
Log:
Set eol-style native on new Network Server XA files


Modified:
   incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXAProtocol.java   (contents,
props changed)
   incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXid.java   (contents,
props changed)
   incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/XADatabase.java   (contents,
props changed)

Modified: incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXAProtocol.java
Url: http://svn.apache.org/viewcvs/incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXAProtocol.java?view=diff&rev=123831&p1=incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXAProtocol.java&r1=123830&p2=incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXAProtocol.java&r2=123831
==============================================================================
--- incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXAProtocol.java	(original)
+++ incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXAProtocol.java	Fri
Dec 31 15:36:19 2004
@@ -1,663 +1,663 @@
-/*
-
-   Derby - Class org.apache.derby.impl.drda.DRDAXAProtocol.java
-
-   Copyright 2004 The Apache Software Foundation or its licensors, as applicable.
-
-   Licensed under the Apache License, Version 2.0 (the "License");
-   you may not use this file except in compliance with the License.
-   You may obtain a copy of the License at
-
-      http://www.apache.org/licenses/LICENSE-2.0
-
-   Unless required by applicable law or agreed to in writing, software
-   distributed under the License is distributed on an "AS IS" BASIS,
-   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-   See the License for the specific language governing permissions and
-   limitations under the License.
-
- */
-
-/**
- * This class translates DRDA XA protocol from an application requester to XA
- * calls for Derby and then translates the results from Derby to DRDA
- * for return to the application requester.
- * This class requires the use of javax.transaction.xa classes from j2ee,
- * so is separated from DRDAConnThread, because of the additional
- * library requirements
- * @author kmarsden@Sourcery.Org
- */
-
-
-package org.apache.derby.impl.drda;
-import org.apache.derby.iapi.services.sanity.SanityManager;
-import javax.transaction.xa.*;
-
-
-public class DRDAXAProtocol {
-
-	private DRDAConnThread connThread;
-	private DDMReader reader;
-	private DDMWriter writer;
-
-
-	public DRDAXAProtocol(DRDAConnThread connThread)
-	{
-		this.connThread = connThread;
-		reader = connThread.getReader();
-		writer = connThread.getWriter();
-
-	}
-
-
-
-	/**
-	 * Parse SYNCCTL - Parse SYNCCTL command for XAMGR lvl 7
-	 *
-	 */
-	protected void parseSYNCCTL() throws DRDAProtocolException
-	{
-		
-		reader.markCollection();
-		
-		int codePoint = reader.getCodePoint(CodePoint.SYNCTYPE);
-		int syncType = parseSYNCTYPE();
-		
-		int xaflags = 0;
-		boolean readXAFlags = false;
-		Xid xid = null;
-
-		codePoint = reader.getCodePoint();
-		while (codePoint != -1)
-		{
-			switch(codePoint)
-			{
-				case CodePoint.XID:
-					xid = parseXID();
-					break;					
-				case CodePoint.XAFLAGS:
-					xaflags = parseXAFlags();					
-					readXAFlags =true;
-					break;
-				case CodePoint.TIMEOUT:
-					// optional/ignorable.
-					reader.skipBytes();
-					break;
-				case CodePoint.RLSCONV:
-					connThread.codePointNotSupported(codePoint);	  
-				default:
-					connThread.invalidCodePoint(codePoint);
-			}
-
-			codePoint = reader.getCodePoint();
-		}
-
-
-		{
-			connThread.trace("syncType = " + syncTypeToString(syncType));
-			connThread.trace("xid = " + xid);
-			connThread.trace("xaflags =" + xaflagsToString(xaflags));
-		}
-
-		if (syncType != CodePoint.SYNCTYPE_INDOUBT)
-		{
-			if (xid == null)
-				connThread.missingCodePoint(CodePoint.XID);
-			
-			if (! readXAFlags)
-				if (SanityManager.DEBUG)
-					connThread.missingCodePoint(CodePoint.XAFLAGS);
-		}
-
-		switch (syncType)
-		{  
-			case CodePoint.SYNCTYPE_NEW_UOW:
-				// new unit of work for XA
-				// formatId -1 is just a local connection
-				startXATransaction(xid,xaflags);
-				break;
-			case CodePoint.SYNCTYPE_END_UOW:
-				// End unit of work
-				endXA(xid,xaflags);
-				break;
-			case CodePoint.SYNCTYPE_PREPARE:
-				prepareXATransaction(xid);
-				// Prepare to commit 
-				break;
-			case CodePoint.SYNCTYPE_MIGRATE:
-				// migrate to resync server sync type
-				connThread.codePointNotSupported(codePoint);				
-				break;			
-			case CodePoint.SYNCTYPE_REQ_COMMIT:
-				// request to commit sync type
-				commitTransaction(xid,xaflags);
-				break;
-			case CodePoint.SYNCTYPE_COMMITTED:
-				// commit  sync type
-				commitTransaction(xid, xaflags);
-				break;
-			case CodePoint.SYNCTYPE_REQ_FORGET:
-				// request to forget sync type
-				forgetXATransaction(xid);
-				break;
-			case CodePoint.SYNCTYPE_ROLLBACK:
-				//rollback sync type
-				rollbackTransaction(xid);
-				break;
-			case CodePoint.SYNCTYPE_INDOUBT:
-				//recover sync type
-				recoverXA();
-				break;
-			default:
-				connThread.invalidCodePoint(codePoint);
- 		}
-
-	}
-
-	/** 
-	 * parse SYNCTYPE for XAMGR lvl 7
-	 * return synctype value 
-	 *   CodePoint.SYNCTYPE_NEW_UOW -> XAResource.start()
-	 *   CodePoint.SYNCTYPE_END_UOW -> XAResource.end()
-	 *   CodePoint.SYNCTYPE_PREPARE -> XAResource.prepare()
-	 *   CodePoint.SYNCTYPE_MIGRATE -> not supported  //SYNCPT MGR LEVEL 5
-	 *   CodePoint.SYNCTYPE_REQ_COMMIT -> not supported //SYNCPT MGR LEVEL 5
-	 *   CodePoint.SYNCTYPE_COMMITTED -> XAResource.commit()  
-	 *                                   or local commit for null XID
-	 *   CodePoint.SYNCTYPE_REQ_LOG ->  not supported
-	 *   CodePoint.SYNCTYPE_REQ_FORGET -> XAResource.forget()
-	 *   CodePoint.SYNCTYPE_ROLLBACK -> XAResource.rollback()
-	 *   CodePoint.SYNCTYPE_MIGRATED -> not supported
-	 *   CodePoint.SYNCTYPE_INDOUBT   -> XAResource.recover();
-	 * 
-	 */	 
-	protected int  parseSYNCTYPE() throws DRDAProtocolException
-	{
-		return reader.readUnsignedByte();
-		
-	}
-	
-
-	/** Parse XID
-	 *  formatId -1 translates into a null XID and a local transaction
-	 */
-	private  Xid parseXID () throws DRDAProtocolException
-	{
-		int formatId = reader.readNetworkInt();
-		byte[] gtrid = null;
-		byte[] bqual = null;
-		if (formatId != -1)
-		{
-			int gtridLen = reader.readNetworkInt();
-			int bqualLen = reader.readNetworkInt();
-			
-			gtrid = reader.readBytes(gtridLen);
-			bqual = reader.readBytes(bqualLen);
-		}
-		return new DRDAXid(formatId, gtrid, bqual);
-	}
-
-
-	/** 
-	 *  parse XIDSHR
-	 *
-	 * @return XIDSHR value
-	 * @throws DRDAProtocolException
-	 */
-	private int parseXIDSHR() throws DRDAProtocolException
-	{
-		return reader.readUnsignedByte();
-	}
-
-	/** 
-	 *  parse XAFlags 
-	 *
-	 * @return XAFlags value
-	 * @throws DRDAProtocolException
-	 */
-	private int parseXAFlags() throws DRDAProtocolException
-	{
-		return reader.readNetworkInt();
-	}
-
-
-	/**
-	 *  Start the xa transaction. Send SYNCRRD response
-	 * 
-	 *  @param xid - XID (formatId = -1 for local transaction)
-	 *  @param xaflags - xaflags
-	 *  @throws DRDAProtocolException
-	 */
-	private void startXATransaction(Xid xid, int xaflags) throws DRDAProtocolException
-	{
-		XAResource xaResource = getXAResource();
-		int xaRetVal = xaResource.XA_OK;
-
-		try {
-			if (xid.getFormatId() != -1)
-				xaResource.start(xid,xaflags);
-		} catch (XAException xe)
-		{
-			xaRetVal = processXAException(xe);
-		}
-		writeSYNCCRD(CodePoint.SYNCTYPE_NEW_UOW, 
-					 xaRetVal, null);
-		
-	}
-	
-
-	/**
-	 *  Commit  the xa transaction. Send SYNCCRD response
-	 * 
-	 *  @param xid - XID (formatId = -1 for local transaction)
-	 *  @param xaflags - xaflags
-	 *  @throws DRDAProtocolException
-	 */
-	private void commitTransaction(Xid xid, int xaflags) throws DRDAProtocolException
-	{
-		boolean local  = ( xid.getFormatId() == -1);
-		if (local)
-			commitLocalTransaction();
-		else
-			commitXATransaction(xid, xaflags);
-	}
-
-	/**
-	 *  Commit local transaction. Send SYNCCRD response.
-	 * 
-	 *  @throws DRDAProtocolException
-	 */	   
-	private void commitLocalTransaction() throws DRDAProtocolException
-	{
-		int xaRetVal = XAResource.XA_OK;
-		try {
-			connThread.getDatabase().commit();
-		}
-		catch  (Exception e)
-		{
-			xaRetVal = XAException.XAER_RMFAIL;
-			if (SanityManager.DEBUG)
-			{
-				connThread.getServer().consoleExceptionPrint(e);
-			}
-
-		}
-		writeSYNCCRD(CodePoint.SYNCTYPE_COMMITTED, 
-					 xaRetVal, null);
-
-	}
-
-	
-	/**
-	 *  Commit  the xa transaction. Send SYNCCRD response.
-	 * 
-	 *  @param xid - XID 
-	 *  @param xaflags - xaflags
-	 *  @throws DRDAProtocolException
-	 */
-	private void commitXATransaction(Xid xid, int xaflags) throws DRDAProtocolException
-	{
-		XAResource xaResource = getXAResource();
-		int xaRetVal = xaResource.XA_OK;
-		// check this
-		boolean isOnePhase = (xaflags & XAResource.TMONEPHASE) != 0;
-		try {
-			xaResource.commit(xid, isOnePhase);
-			if (SanityManager.DEBUG)
-				connThread.trace("committed XA transaction: xaRetVal=" + xaRetVal);
-
-		} catch (XAException xe)
-		{
-			xaRetVal = processXAException(xe);
-		}
-		writeSYNCCRD(CodePoint.SYNCTYPE_COMMITTED, 
-					 xaRetVal, null);
-		
-	}
-
-	/**
-	 * Rollback transaction
-	 * @param xid  Xid for rollback for global transaction.
-	 *             If xid formatid is -1 it represents a local transaction
-	 */
-	private void rollbackTransaction(Xid xid) throws DRDAProtocolException
-	{
-		boolean local  = ( xid.getFormatId() == -1);
-		if (local)
-			rollbackLocalTransaction();
-		else
-			rollbackXATransaction(xid);
-	}
-	
-	/**
-	 * Rollback a local transaction
-	 *
-	 */
-	private void rollbackLocalTransaction() throws DRDAProtocolException
-	{
-		int xaRetVal = XAResource.XA_OK;
-		try {
-			connThread.getDatabase().rollback();
-		}
-		catch  (Exception e)
-		{
-			xaRetVal = XAException.XAER_RMFAIL;
-			if (SanityManager.DEBUG)
-			{
-				connThread.getServer().consoleExceptionPrint(e);
-			}
-			
-		}
-		writeSYNCCRD(CodePoint.SYNCTYPE_COMMITTED, 
-					 xaRetVal, null);
-
-	}
-
-	/**
-	 *  Rollback the xa transaction. Send SYNCCRD response.
-	 * 
-	 *  @param xid - XID 
-	 *  @throws DRDAProtocolException
-	 */
-	private void rollbackXATransaction(Xid xid) throws DRDAProtocolException
-	{
-		XAResource xaResource = getXAResource();
-		int xaRetVal = xaResource.XA_OK;
-
-		try {
-			xaResource.rollback(xid);
-			if (SanityManager.DEBUG)
-			{
-				connThread.trace("rollback  XA transaction: xaRetVal=" + xaRetVal); 
-			}
-		} catch (XAException xe)
-		{
-			xaRetVal = processXAException(xe);
-		}
-		writeSYNCCRD(CodePoint.SYNCTYPE_ROLLBACK,
-					 xaRetVal, null);
-		
-	}
-
-	/**
-	 *  End  the xa transaction. Send SYNCRRD response
-	 * 
-	 *  @param xid - XID 
-	 *  @param xaflags - xaflags
-	 *  @throws DRDAProtocolException
-	 */
-	private void endXA(Xid xid, int xaflags) throws DRDAProtocolException
-	{
-		XAResource xaResource = getXAResource();		
-		int xaRetVal = xaResource.XA_OK;
-
-		try {
-			xaResource.end(xid,xaflags);
-			if (SanityManager.DEBUG)
-			{
-				connThread.trace("ended XA transaction. xid =  " + xid +
-							   " xaflags =" + xaflags + 
-								 "xaRetVal=" + xaRetVal); 
-			}
-		} catch (XAException xe)
-		{
-			xaRetVal = processXAException(xe);
-		}
-		writeSYNCCRD(CodePoint.SYNCTYPE_END_UOW,
-					 xaRetVal, null);		
-	}
-
-
-	/**
-	 *  Prepare the xa transaction. Send SYNCCRD response.
-	 * 
-	 *  @param xid - XID 
-	 *  @throws DRDAProtocolException
-	 */
-	private void prepareXATransaction(Xid xid) throws DRDAProtocolException
-	{
-		XAResource xaResource = getXAResource();
-		int xaRetVal = xaResource.XA_OK;
-
-		try {
-			xaResource.prepare(xid);
-			if (SanityManager.DEBUG)
-			{
-				connThread.trace("prepared xa transaction: xaRetVal=" +
-								xaRetVal); 
-			}
-		} catch (XAException xe)
-		{			
-			xaRetVal = processXAException(xe);
-		}
-		writeSYNCCRD(CodePoint.SYNCTYPE_PREPARE,
-					 xaRetVal, null);		
-	}
-
-	/**
-	 *  Forget the xa transaction. Send SYNCCRD response.
-	 * 
-	 *  @param xid - XID 
-	 *  @throws DRDAProtocolException
-	 */
-	private void forgetXATransaction(Xid xid) throws DRDAProtocolException
-	{
-		XAResource xaResource = getXAResource();
-		int xaRetVal = xaResource.XA_OK;
-
-		try {
-			xaResource.forget(xid);
-			if (SanityManager.DEBUG)
-			{
-				connThread.trace("forgot xa transaction: xaRetVal=" + xaRetVal);
-			}
-		} catch (XAException xe)
-		{
-			xaRetVal = processXAException(xe);
-		}
-		writeSYNCCRD(CodePoint.SYNCTYPE_REQ_FORGET,
-					 xaRetVal, null);		
-	}
-
-
-	/**
-	 * Call recover. Send SYNCCRD response with indoubt list
-	 * 
-	 *  @throws DRDAProtocolException
-	 */
-	private void recoverXA() throws DRDAProtocolException
-	{
-		XAResource xaResource = getXAResource();
-		int xaRetVal = xaResource.XA_OK;
-		Xid[] indoubtXids = null;
-		try {
-			indoubtXids = xaResource.recover(XAResource.TMSTARTRSCAN);
-		} catch (XAException xe)
-		{
-			xaRetVal = processXAException(xe);
-		}
-		writeSYNCCRD(CodePoint.SYNCTYPE_INDOUBT,
-					 xaRetVal, indoubtXids);		
-	}
-
-	/** Write SYNCCRD (SYNCCTL response)
-	 * @param synctype - XA Command to send response for see  parseSYNCTYPE
-	 * @param xaRetVal - return value from XA command
-	 * @param xids - list of xids to return for recover. 
-	 *               null for other commands
-	 * @throws DRDAProtocolException
-	 */
-	private void writeSYNCCRD (int synctype, int xaRetVal, Xid[] xids) throws DRDAProtocolException
-	{
-		writer.createDssReply();
-		writer.startDdm(CodePoint.SYNCCRD);
-		writer.startDdm(CodePoint.XARETVAL);
-		writer.writeInt(xaRetVal);
-		writer.endDdm();
-		if (xids != null)
-			writePRPHRCLST(xids);
-		writer.endDdmAndDss();
-	}
-
-	/** write PRPHRCLST (indoubt list)
-	 * 
-	 * @param xids - list of indoubt xa transactions obtained from recover
-	 * @throws DRDAProtocolException
-	 */
-	private void writePRPHRCLST(Xid[] xids) throws DRDAProtocolException
-	{
-		int xidcnt = (xids == null ? 0 : xids.length);
-		writer.startDdm(CodePoint.PRPHRCLST);
-		writer.writeScalar2Bytes(CodePoint.XIDCNT, xidcnt);
-		for (int i = 0; i < xidcnt; i++)
-			writeXID(xids[i]);
-		writer.endDdm();
-	}
-
-	/** write XID
-	 * 
-	 * @param xid - XID to write
-	 * @throws DRDAProtocolException
-	 */
-	
-	private void writeXID(Xid xid) throws DRDAProtocolException
-	{
-		writer.startDdm(CodePoint.XID);
-		int formatId = xid.getFormatId();
-		byte[] gtrid = xid.getGlobalTransactionId();
-		byte[] bqual = xid.getBranchQualifier();
-		
-		writer.writeInt(formatId);
-		writer.writeInt(gtrid.length);
-		writer.writeInt(bqual.length);
-		writer.writeBytes(gtrid);
-		writer.writeBytes(bqual);
-		writer.endDdm();
-	}
-	
-
-	/** get XAResource for the connection
-	 *
-	 * @return XAResource
-	 */
-	private XAResource getXAResource()
-	{
-		return ((XADatabase) connThread.getDatabase()).getXAResource();
-		
-	}
-	
-	/** printable syncType for debug output
-	 * @param syncType
-	 * @return - sync type meaning
-	 */
-	private String syncTypeToString(int syncType)
-	{
-		switch (syncType)
-		{  
-			case CodePoint.SYNCTYPE_NEW_UOW:
-				return "SYNCTYPE_NEW_UOW";
-				
-			case CodePoint.SYNCTYPE_END_UOW:
-				return "SYNCTYPE_END_UOW";
-				
-			case CodePoint.SYNCTYPE_PREPARE:
-				return "SYNCTYPE_PREPARE";
-				
-			case CodePoint.SYNCTYPE_MIGRATE:
-				return "SYNCTYPE_MIGRATE";
-							
-			case CodePoint.SYNCTYPE_REQ_COMMIT:
-				return "SYNCTYPE_REQ_COMMIT";
-				
-			case CodePoint.SYNCTYPE_COMMITTED:
-				return "SYNCTYPE_COMMITTED";
-				
-			case CodePoint.SYNCTYPE_REQ_FORGET:
-				return "SYNCTYPE_FORGET";
-				
-			case CodePoint.SYNCTYPE_ROLLBACK:
-				return "SYNCTYPE_ROLLBACK";
-				
-			case CodePoint.SYNCTYPE_REQ_LOG:
-				return "SYNCTYPE_REQ_LOG";
-				
-			case   CodePoint.SYNCTYPE_MIGRATED:
-				return "SYNCTYPE_MIGRATED";
-				
-			case CodePoint.SYNCTYPE_INDOUBT:
-				return "SYNCTYPE_INDOUBT";
-				
-			default:
-				return "UNKNOWN SYNCTYPE";
- 		}
-	}
-
-	/** 
-	 * printable xaflags
-	 * @param - xaflags
-	 * @return - printable xaflags for debug output
-	 */
-	private String xaflagsToString(int xaflags)
-	{
-		switch (xaflags)
-		{
-			case XAResource.TMENDRSCAN :
-				return "XAResource.TMENDRSCAN";
-				
-			case XAResource.TMFAIL:
-				return "XAResource.TMFAIL";
-				
-			case XAResource.TMNOFLAGS:
-				return "XAResource.TMNOFLAGS";
-				
-			case XAResource.TMJOIN:
-				return "XAResource.TMJOIN";
-				
-			case XAResource.TMONEPHASE:
-				return "XAResource.TMONEPHASE";
-				
-			case XAResource.TMRESUME:
-				return "XAResource.TMRESUME";
-				
-			case XAResource.TMSTARTRSCAN:
-				return "XAResource.TMSTARTRSCAN";
-				
-			case XAResource.TMSUCCESS:
-				return "XAResource.TMSUCCESS";
-				
-			case XAResource.TMSUSPEND:
-				return "XAResource.TMSUSPEND";
-				
-			default:
-				return "UNRECOGNIZED flags:" + xaflags;
-				
-		}
-	}
-
-	/** 
-	 * return xa exception errorCode.
-	 * print to console for debug output.
-	 * @param xe - XA Exception
-	 */
-	private int processXAException(XAException xe)
-	{
-		int xaRetVal = xe.errorCode;
-		if (SanityManager.DEBUG)
-		{
-			connThread.getServer().consoleExceptionPrint(xe);
-		}
-		return xaRetVal;
-	}
-
-}
-
-
-
-
-
-
-
-
-
-
-
+/*
+
+   Derby - Class org.apache.derby.impl.drda.DRDAXAProtocol.java
+
+   Copyright 2004 The Apache Software Foundation or its licensors, as applicable.
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
+
+ */
+
+/**
+ * This class translates DRDA XA protocol from an application requester to XA
+ * calls for Derby and then translates the results from Derby to DRDA
+ * for return to the application requester.
+ * This class requires the use of javax.transaction.xa classes from j2ee,
+ * so is separated from DRDAConnThread, because of the additional
+ * library requirements
+ * @author kmarsden@Sourcery.Org
+ */
+
+
+package org.apache.derby.impl.drda;
+import org.apache.derby.iapi.services.sanity.SanityManager;
+import javax.transaction.xa.*;
+
+
+public class DRDAXAProtocol {
+
+	private DRDAConnThread connThread;
+	private DDMReader reader;
+	private DDMWriter writer;
+
+
+	public DRDAXAProtocol(DRDAConnThread connThread)
+	{
+		this.connThread = connThread;
+		reader = connThread.getReader();
+		writer = connThread.getWriter();
+
+	}
+
+
+
+	/**
+	 * Parse SYNCCTL - Parse SYNCCTL command for XAMGR lvl 7
+	 *
+	 */
+	protected void parseSYNCCTL() throws DRDAProtocolException
+	{
+		
+		reader.markCollection();
+		
+		int codePoint = reader.getCodePoint(CodePoint.SYNCTYPE);
+		int syncType = parseSYNCTYPE();
+		
+		int xaflags = 0;
+		boolean readXAFlags = false;
+		Xid xid = null;
+
+		codePoint = reader.getCodePoint();
+		while (codePoint != -1)
+		{
+			switch(codePoint)
+			{
+				case CodePoint.XID:
+					xid = parseXID();
+					break;					
+				case CodePoint.XAFLAGS:
+					xaflags = parseXAFlags();					
+					readXAFlags =true;
+					break;
+				case CodePoint.TIMEOUT:
+					// optional/ignorable.
+					reader.skipBytes();
+					break;
+				case CodePoint.RLSCONV:
+					connThread.codePointNotSupported(codePoint);	  
+				default:
+					connThread.invalidCodePoint(codePoint);
+			}
+
+			codePoint = reader.getCodePoint();
+		}
+
+
+		{
+			connThread.trace("syncType = " + syncTypeToString(syncType));
+			connThread.trace("xid = " + xid);
+			connThread.trace("xaflags =" + xaflagsToString(xaflags));
+		}
+
+		if (syncType != CodePoint.SYNCTYPE_INDOUBT)
+		{
+			if (xid == null)
+				connThread.missingCodePoint(CodePoint.XID);
+			
+			if (! readXAFlags)
+				if (SanityManager.DEBUG)
+					connThread.missingCodePoint(CodePoint.XAFLAGS);
+		}
+
+		switch (syncType)
+		{  
+			case CodePoint.SYNCTYPE_NEW_UOW:
+				// new unit of work for XA
+				// formatId -1 is just a local connection
+				startXATransaction(xid,xaflags);
+				break;
+			case CodePoint.SYNCTYPE_END_UOW:
+				// End unit of work
+				endXA(xid,xaflags);
+				break;
+			case CodePoint.SYNCTYPE_PREPARE:
+				prepareXATransaction(xid);
+				// Prepare to commit 
+				break;
+			case CodePoint.SYNCTYPE_MIGRATE:
+				// migrate to resync server sync type
+				connThread.codePointNotSupported(codePoint);				
+				break;			
+			case CodePoint.SYNCTYPE_REQ_COMMIT:
+				// request to commit sync type
+				commitTransaction(xid,xaflags);
+				break;
+			case CodePoint.SYNCTYPE_COMMITTED:
+				// commit  sync type
+				commitTransaction(xid, xaflags);
+				break;
+			case CodePoint.SYNCTYPE_REQ_FORGET:
+				// request to forget sync type
+				forgetXATransaction(xid);
+				break;
+			case CodePoint.SYNCTYPE_ROLLBACK:
+				//rollback sync type
+				rollbackTransaction(xid);
+				break;
+			case CodePoint.SYNCTYPE_INDOUBT:
+				//recover sync type
+				recoverXA();
+				break;
+			default:
+				connThread.invalidCodePoint(codePoint);
+ 		}
+
+	}
+
+	/** 
+	 * parse SYNCTYPE for XAMGR lvl 7
+	 * return synctype value 
+	 *   CodePoint.SYNCTYPE_NEW_UOW -> XAResource.start()
+	 *   CodePoint.SYNCTYPE_END_UOW -> XAResource.end()
+	 *   CodePoint.SYNCTYPE_PREPARE -> XAResource.prepare()
+	 *   CodePoint.SYNCTYPE_MIGRATE -> not supported  //SYNCPT MGR LEVEL 5
+	 *   CodePoint.SYNCTYPE_REQ_COMMIT -> not supported //SYNCPT MGR LEVEL 5
+	 *   CodePoint.SYNCTYPE_COMMITTED -> XAResource.commit()  
+	 *                                   or local commit for null XID
+	 *   CodePoint.SYNCTYPE_REQ_LOG ->  not supported
+	 *   CodePoint.SYNCTYPE_REQ_FORGET -> XAResource.forget()
+	 *   CodePoint.SYNCTYPE_ROLLBACK -> XAResource.rollback()
+	 *   CodePoint.SYNCTYPE_MIGRATED -> not supported
+	 *   CodePoint.SYNCTYPE_INDOUBT   -> XAResource.recover();
+	 * 
+	 */	 
+	protected int  parseSYNCTYPE() throws DRDAProtocolException
+	{
+		return reader.readUnsignedByte();
+		
+	}
+	
+
+	/** Parse XID
+	 *  formatId -1 translates into a null XID and a local transaction
+	 */
+	private  Xid parseXID () throws DRDAProtocolException
+	{
+		int formatId = reader.readNetworkInt();
+		byte[] gtrid = null;
+		byte[] bqual = null;
+		if (formatId != -1)
+		{
+			int gtridLen = reader.readNetworkInt();
+			int bqualLen = reader.readNetworkInt();
+			
+			gtrid = reader.readBytes(gtridLen);
+			bqual = reader.readBytes(bqualLen);
+		}
+		return new DRDAXid(formatId, gtrid, bqual);
+	}
+
+
+	/** 
+	 *  parse XIDSHR
+	 *
+	 * @return XIDSHR value
+	 * @throws DRDAProtocolException
+	 */
+	private int parseXIDSHR() throws DRDAProtocolException
+	{
+		return reader.readUnsignedByte();
+	}
+
+	/** 
+	 *  parse XAFlags 
+	 *
+	 * @return XAFlags value
+	 * @throws DRDAProtocolException
+	 */
+	private int parseXAFlags() throws DRDAProtocolException
+	{
+		return reader.readNetworkInt();
+	}
+
+
+	/**
+	 *  Start the xa transaction. Send SYNCRRD response
+	 * 
+	 *  @param xid - XID (formatId = -1 for local transaction)
+	 *  @param xaflags - xaflags
+	 *  @throws DRDAProtocolException
+	 */
+	private void startXATransaction(Xid xid, int xaflags) throws DRDAProtocolException
+	{
+		XAResource xaResource = getXAResource();
+		int xaRetVal = xaResource.XA_OK;
+
+		try {
+			if (xid.getFormatId() != -1)
+				xaResource.start(xid,xaflags);
+		} catch (XAException xe)
+		{
+			xaRetVal = processXAException(xe);
+		}
+		writeSYNCCRD(CodePoint.SYNCTYPE_NEW_UOW, 
+					 xaRetVal, null);
+		
+	}
+	
+
+	/**
+	 *  Commit  the xa transaction. Send SYNCCRD response
+	 * 
+	 *  @param xid - XID (formatId = -1 for local transaction)
+	 *  @param xaflags - xaflags
+	 *  @throws DRDAProtocolException
+	 */
+	private void commitTransaction(Xid xid, int xaflags) throws DRDAProtocolException
+	{
+		boolean local  = ( xid.getFormatId() == -1);
+		if (local)
+			commitLocalTransaction();
+		else
+			commitXATransaction(xid, xaflags);
+	}
+
+	/**
+	 *  Commit local transaction. Send SYNCCRD response.
+	 * 
+	 *  @throws DRDAProtocolException
+	 */	   
+	private void commitLocalTransaction() throws DRDAProtocolException
+	{
+		int xaRetVal = XAResource.XA_OK;
+		try {
+			connThread.getDatabase().commit();
+		}
+		catch  (Exception e)
+		{
+			xaRetVal = XAException.XAER_RMFAIL;
+			if (SanityManager.DEBUG)
+			{
+				connThread.getServer().consoleExceptionPrint(e);
+			}
+
+		}
+		writeSYNCCRD(CodePoint.SYNCTYPE_COMMITTED, 
+					 xaRetVal, null);
+
+	}
+
+	
+	/**
+	 *  Commit  the xa transaction. Send SYNCCRD response.
+	 * 
+	 *  @param xid - XID 
+	 *  @param xaflags - xaflags
+	 *  @throws DRDAProtocolException
+	 */
+	private void commitXATransaction(Xid xid, int xaflags) throws DRDAProtocolException
+	{
+		XAResource xaResource = getXAResource();
+		int xaRetVal = xaResource.XA_OK;
+		// check this
+		boolean isOnePhase = (xaflags & XAResource.TMONEPHASE) != 0;
+		try {
+			xaResource.commit(xid, isOnePhase);
+			if (SanityManager.DEBUG)
+				connThread.trace("committed XA transaction: xaRetVal=" + xaRetVal);
+
+		} catch (XAException xe)
+		{
+			xaRetVal = processXAException(xe);
+		}
+		writeSYNCCRD(CodePoint.SYNCTYPE_COMMITTED, 
+					 xaRetVal, null);
+		
+	}
+
+	/**
+	 * Rollback transaction
+	 * @param xid  Xid for rollback for global transaction.
+	 *             If xid formatid is -1 it represents a local transaction
+	 */
+	private void rollbackTransaction(Xid xid) throws DRDAProtocolException
+	{
+		boolean local  = ( xid.getFormatId() == -1);
+		if (local)
+			rollbackLocalTransaction();
+		else
+			rollbackXATransaction(xid);
+	}
+	
+	/**
+	 * Rollback a local transaction
+	 *
+	 */
+	private void rollbackLocalTransaction() throws DRDAProtocolException
+	{
+		int xaRetVal = XAResource.XA_OK;
+		try {
+			connThread.getDatabase().rollback();
+		}
+		catch  (Exception e)
+		{
+			xaRetVal = XAException.XAER_RMFAIL;
+			if (SanityManager.DEBUG)
+			{
+				connThread.getServer().consoleExceptionPrint(e);
+			}
+			
+		}
+		writeSYNCCRD(CodePoint.SYNCTYPE_COMMITTED, 
+					 xaRetVal, null);
+
+	}
+
+	/**
+	 *  Rollback the xa transaction. Send SYNCCRD response.
+	 * 
+	 *  @param xid - XID 
+	 *  @throws DRDAProtocolException
+	 */
+	private void rollbackXATransaction(Xid xid) throws DRDAProtocolException
+	{
+		XAResource xaResource = getXAResource();
+		int xaRetVal = xaResource.XA_OK;
+
+		try {
+			xaResource.rollback(xid);
+			if (SanityManager.DEBUG)
+			{
+				connThread.trace("rollback  XA transaction: xaRetVal=" + xaRetVal); 
+			}
+		} catch (XAException xe)
+		{
+			xaRetVal = processXAException(xe);
+		}
+		writeSYNCCRD(CodePoint.SYNCTYPE_ROLLBACK,
+					 xaRetVal, null);
+		
+	}
+
+	/**
+	 *  End  the xa transaction. Send SYNCRRD response
+	 * 
+	 *  @param xid - XID 
+	 *  @param xaflags - xaflags
+	 *  @throws DRDAProtocolException
+	 */
+	private void endXA(Xid xid, int xaflags) throws DRDAProtocolException
+	{
+		XAResource xaResource = getXAResource();		
+		int xaRetVal = xaResource.XA_OK;
+
+		try {
+			xaResource.end(xid,xaflags);
+			if (SanityManager.DEBUG)
+			{
+				connThread.trace("ended XA transaction. xid =  " + xid +
+							   " xaflags =" + xaflags + 
+								 "xaRetVal=" + xaRetVal); 
+			}
+		} catch (XAException xe)
+		{
+			xaRetVal = processXAException(xe);
+		}
+		writeSYNCCRD(CodePoint.SYNCTYPE_END_UOW,
+					 xaRetVal, null);		
+	}
+
+
+	/**
+	 *  Prepare the xa transaction. Send SYNCCRD response.
+	 * 
+	 *  @param xid - XID 
+	 *  @throws DRDAProtocolException
+	 */
+	private void prepareXATransaction(Xid xid) throws DRDAProtocolException
+	{
+		XAResource xaResource = getXAResource();
+		int xaRetVal = xaResource.XA_OK;
+
+		try {
+			xaResource.prepare(xid);
+			if (SanityManager.DEBUG)
+			{
+				connThread.trace("prepared xa transaction: xaRetVal=" +
+								xaRetVal); 
+			}
+		} catch (XAException xe)
+		{			
+			xaRetVal = processXAException(xe);
+		}
+		writeSYNCCRD(CodePoint.SYNCTYPE_PREPARE,
+					 xaRetVal, null);		
+	}
+
+	/**
+	 *  Forget the xa transaction. Send SYNCCRD response.
+	 * 
+	 *  @param xid - XID 
+	 *  @throws DRDAProtocolException
+	 */
+	private void forgetXATransaction(Xid xid) throws DRDAProtocolException
+	{
+		XAResource xaResource = getXAResource();
+		int xaRetVal = xaResource.XA_OK;
+
+		try {
+			xaResource.forget(xid);
+			if (SanityManager.DEBUG)
+			{
+				connThread.trace("forgot xa transaction: xaRetVal=" + xaRetVal);
+			}
+		} catch (XAException xe)
+		{
+			xaRetVal = processXAException(xe);
+		}
+		writeSYNCCRD(CodePoint.SYNCTYPE_REQ_FORGET,
+					 xaRetVal, null);		
+	}
+
+
+	/**
+	 * Call recover. Send SYNCCRD response with indoubt list
+	 * 
+	 *  @throws DRDAProtocolException
+	 */
+	private void recoverXA() throws DRDAProtocolException
+	{
+		XAResource xaResource = getXAResource();
+		int xaRetVal = xaResource.XA_OK;
+		Xid[] indoubtXids = null;
+		try {
+			indoubtXids = xaResource.recover(XAResource.TMSTARTRSCAN);
+		} catch (XAException xe)
+		{
+			xaRetVal = processXAException(xe);
+		}
+		writeSYNCCRD(CodePoint.SYNCTYPE_INDOUBT,
+					 xaRetVal, indoubtXids);		
+	}
+
+	/** Write SYNCCRD (SYNCCTL response)
+	 * @param synctype - XA Command to send response for see  parseSYNCTYPE
+	 * @param xaRetVal - return value from XA command
+	 * @param xids - list of xids to return for recover. 
+	 *               null for other commands
+	 * @throws DRDAProtocolException
+	 */
+	private void writeSYNCCRD (int synctype, int xaRetVal, Xid[] xids) throws DRDAProtocolException
+	{
+		writer.createDssReply();
+		writer.startDdm(CodePoint.SYNCCRD);
+		writer.startDdm(CodePoint.XARETVAL);
+		writer.writeInt(xaRetVal);
+		writer.endDdm();
+		if (xids != null)
+			writePRPHRCLST(xids);
+		writer.endDdmAndDss();
+	}
+
+	/** write PRPHRCLST (indoubt list)
+	 * 
+	 * @param xids - list of indoubt xa transactions obtained from recover
+	 * @throws DRDAProtocolException
+	 */
+	private void writePRPHRCLST(Xid[] xids) throws DRDAProtocolException
+	{
+		int xidcnt = (xids == null ? 0 : xids.length);
+		writer.startDdm(CodePoint.PRPHRCLST);
+		writer.writeScalar2Bytes(CodePoint.XIDCNT, xidcnt);
+		for (int i = 0; i < xidcnt; i++)
+			writeXID(xids[i]);
+		writer.endDdm();
+	}
+
+	/** write XID
+	 * 
+	 * @param xid - XID to write
+	 * @throws DRDAProtocolException
+	 */
+	
+	private void writeXID(Xid xid) throws DRDAProtocolException
+	{
+		writer.startDdm(CodePoint.XID);
+		int formatId = xid.getFormatId();
+		byte[] gtrid = xid.getGlobalTransactionId();
+		byte[] bqual = xid.getBranchQualifier();
+		
+		writer.writeInt(formatId);
+		writer.writeInt(gtrid.length);
+		writer.writeInt(bqual.length);
+		writer.writeBytes(gtrid);
+		writer.writeBytes(bqual);
+		writer.endDdm();
+	}
+	
+
+	/** get XAResource for the connection
+	 *
+	 * @return XAResource
+	 */
+	private XAResource getXAResource()
+	{
+		return ((XADatabase) connThread.getDatabase()).getXAResource();
+		
+	}
+	
+	/** printable syncType for debug output
+	 * @param syncType
+	 * @return - sync type meaning
+	 */
+	private String syncTypeToString(int syncType)
+	{
+		switch (syncType)
+		{  
+			case CodePoint.SYNCTYPE_NEW_UOW:
+				return "SYNCTYPE_NEW_UOW";
+				
+			case CodePoint.SYNCTYPE_END_UOW:
+				return "SYNCTYPE_END_UOW";
+				
+			case CodePoint.SYNCTYPE_PREPARE:
+				return "SYNCTYPE_PREPARE";
+				
+			case CodePoint.SYNCTYPE_MIGRATE:
+				return "SYNCTYPE_MIGRATE";
+							
+			case CodePoint.SYNCTYPE_REQ_COMMIT:
+				return "SYNCTYPE_REQ_COMMIT";
+				
+			case CodePoint.SYNCTYPE_COMMITTED:
+				return "SYNCTYPE_COMMITTED";
+				
+			case CodePoint.SYNCTYPE_REQ_FORGET:
+				return "SYNCTYPE_FORGET";
+				
+			case CodePoint.SYNCTYPE_ROLLBACK:
+				return "SYNCTYPE_ROLLBACK";
+				
+			case CodePoint.SYNCTYPE_REQ_LOG:
+				return "SYNCTYPE_REQ_LOG";
+				
+			case   CodePoint.SYNCTYPE_MIGRATED:
+				return "SYNCTYPE_MIGRATED";
+				
+			case CodePoint.SYNCTYPE_INDOUBT:
+				return "SYNCTYPE_INDOUBT";
+				
+			default:
+				return "UNKNOWN SYNCTYPE";
+ 		}
+	}
+
+	/** 
+	 * printable xaflags
+	 * @param - xaflags
+	 * @return - printable xaflags for debug output
+	 */
+	private String xaflagsToString(int xaflags)
+	{
+		switch (xaflags)
+		{
+			case XAResource.TMENDRSCAN :
+				return "XAResource.TMENDRSCAN";
+				
+			case XAResource.TMFAIL:
+				return "XAResource.TMFAIL";
+				
+			case XAResource.TMNOFLAGS:
+				return "XAResource.TMNOFLAGS";
+				
+			case XAResource.TMJOIN:
+				return "XAResource.TMJOIN";
+				
+			case XAResource.TMONEPHASE:
+				return "XAResource.TMONEPHASE";
+				
+			case XAResource.TMRESUME:
+				return "XAResource.TMRESUME";
+				
+			case XAResource.TMSTARTRSCAN:
+				return "XAResource.TMSTARTRSCAN";
+				
+			case XAResource.TMSUCCESS:
+				return "XAResource.TMSUCCESS";
+				
+			case XAResource.TMSUSPEND:
+				return "XAResource.TMSUSPEND";
+				
+			default:
+				return "UNRECOGNIZED flags:" + xaflags;
+				
+		}
+	}
+
+	/** 
+	 * return xa exception errorCode.
+	 * print to console for debug output.
+	 * @param xe - XA Exception
+	 */
+	private int processXAException(XAException xe)
+	{
+		int xaRetVal = xe.errorCode;
+		if (SanityManager.DEBUG)
+		{
+			connThread.getServer().consoleExceptionPrint(xe);
+		}
+		return xaRetVal;
+	}
+
+}
+
+
+
+
+
+
+
+
+
+
+

Modified: incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXid.java
Url: http://svn.apache.org/viewcvs/incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXid.java?view=diff&rev=123831&p1=incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXid.java&r1=123830&p2=incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXid.java&r2=123831
==============================================================================
--- incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXid.java	(original)
+++ incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/DRDAXid.java	Fri Dec 31
15:36:19 2004
@@ -1,123 +1,123 @@
-/*
-
-   Derby - Class org.apache.derby.impl.drda.DRDAXid.java
-
-   Copyright 2004 The Apache Software Foundation or its licensors, as applicable.
-
-   Licensed under the Apache License, Version 2.0 (the "License");
-   you may not use this file except in compliance with the License.
-   You may obtain a copy of the License at
-
-      http://www.apache.org/licenses/LICENSE-2.0
-
-   Unless required by applicable law or agreed to in writing, software
-   distributed under the License is distributed on an "AS IS" BASIS,
-   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-   See the License for the specific language governing permissions and
-   limitations under the License.
-
- */
-
-/**
- * This class provides an Xid implementation for Network Server XA
- */
-
-package org.apache.derby.impl.drda;
-import javax.transaction.xa.Xid;
-
-class DRDAXid implements Xid
-{
-
-	private final int format_id;
-	private final byte[] global_id;
-	private final byte[] branch_id;
-
-
-	DRDAXid(int formatid, byte[] globalid, byte[] branchid)
-	{
-
-		format_id = formatid;
-		global_id = globalid;
-		branch_id = branchid;
-		
-	}
-
-    /**
-     * Obtain the format id part of the Xid.
-     * <p>
-     *
-     * @return Format identifier. O means the OSI CCR format.
-     **/
-    public int getFormatId()
-    {
-        return(format_id);
-    }
-
-    /**
-     * Obtain the global transaction identifier part of XID as an array of 
-     * bytes.
-     * <p>
-     *
-	 * @return A byte array containing the global transaction identifier.
-     **/
-    public byte[] getGlobalTransactionId()
-    {
-        return(global_id);
-    }
-
-    /**
-     * Obtain the transaction branch qualifier part of the Xid in a byte array.
-     * <p>
-     *
-	 * @return A byte array containing the branch qualifier of the transaction.
-     **/
-    public byte[] getBranchQualifier()
-    {
-        return(branch_id);
-    }
-
-	public String toString()
-	{
-		
-	   String s =  "{DRDAXid: " +
-		   "formatId("     + format_id   + "), " +
-		   "globalTransactionId(" +  convertToHexString(global_id) + ")" +
-		   "branchQualifier(" +  convertToHexString(branch_id) + ")";
-	   return s;
-	}
-
-
-	/**
-	 * convert byte array to a Hex string
-	 * 
-	 * @param buf buffer to  convert
-	 * @return hex string representation of byte array
-	 */
-	private static String convertToHexString(byte [] buf)
-	{
-		if (buf == null)
-			return null;
-		StringBuffer str = new StringBuffer();
-		str.append("0x");
-		String val;
-		int byteVal;
-		for (int i = 0; i < buf.length; i++)
-		{
-			byteVal = buf[i] & 0xff;
-			val = Integer.toHexString(byteVal);
-			if (val.length() < 2)
-				str.append("0");
-			str.append(val);
-		}
-		return str.toString();
-	}
-}
-
-
-
-
-
-
-
-
-
+/*
+
+   Derby - Class org.apache.derby.impl.drda.DRDAXid.java
+
+   Copyright 2004 The Apache Software Foundation or its licensors, as applicable.
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
+
+ */
+
+/**
+ * This class provides an Xid implementation for Network Server XA
+ */
+
+package org.apache.derby.impl.drda;
+import javax.transaction.xa.Xid;
+
+class DRDAXid implements Xid
+{
+
+	private final int format_id;
+	private final byte[] global_id;
+	private final byte[] branch_id;
+
+
+	DRDAXid(int formatid, byte[] globalid, byte[] branchid)
+	{
+
+		format_id = formatid;
+		global_id = globalid;
+		branch_id = branchid;
+		
+	}
+
+    /**
+     * Obtain the format id part of the Xid.
+     * <p>
+     *
+     * @return Format identifier. O means the OSI CCR format.
+     **/
+    public int getFormatId()
+    {
+        return(format_id);
+    }
+
+    /**
+     * Obtain the global transaction identifier part of XID as an array of 
+     * bytes.
+     * <p>
+     *
+	 * @return A byte array containing the global transaction identifier.
+     **/
+    public byte[] getGlobalTransactionId()
+    {
+        return(global_id);
+    }
+
+    /**
+     * Obtain the transaction branch qualifier part of the Xid in a byte array.
+     * <p>
+     *
+	 * @return A byte array containing the branch qualifier of the transaction.
+     **/
+    public byte[] getBranchQualifier()
+    {
+        return(branch_id);
+    }
+
+	public String toString()
+	{
+		
+	   String s =  "{DRDAXid: " +
+		   "formatId("     + format_id   + "), " +
+		   "globalTransactionId(" +  convertToHexString(global_id) + ")" +
+		   "branchQualifier(" +  convertToHexString(branch_id) + ")";
+	   return s;
+	}
+
+
+	/**
+	 * convert byte array to a Hex string
+	 * 
+	 * @param buf buffer to  convert
+	 * @return hex string representation of byte array
+	 */
+	private static String convertToHexString(byte [] buf)
+	{
+		if (buf == null)
+			return null;
+		StringBuffer str = new StringBuffer();
+		str.append("0x");
+		String val;
+		int byteVal;
+		for (int i = 0; i < buf.length; i++)
+		{
+			byteVal = buf[i] & 0xff;
+			val = Integer.toHexString(byteVal);
+			if (val.length() < 2)
+				str.append("0");
+			str.append(val);
+		}
+		return str.toString();
+	}
+}
+
+
+
+
+
+
+
+
+

Modified: incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/XADatabase.java
Url: http://svn.apache.org/viewcvs/incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/XADatabase.java?view=diff&rev=123831&p1=incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/XADatabase.java&r1=123830&p2=incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/XADatabase.java&r2=123831
==============================================================================
--- incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/XADatabase.java	(original)
+++ incubator/derby/code/trunk/java/drda/org/apache/derby/impl/drda/XADatabase.java	Fri Dec
31 15:36:19 2004
@@ -1,144 +1,144 @@
-/*
-
-   Derby - Class org.apache.derby.impl.drda.XADatabase.java
-
-   Copyright 2004 The Apache Software Foundation or its licensors, as applicable.
-
-   Licensed under the Apache License, Version 2.0 (the "License");
-   you may not use this file except in compliance with the License.
-   You may obtain a copy of the License at
-
-      http://www.apache.org/licenses/LICENSE-2.0
-
-   Unless required by applicable law or agreed to in writing, software
-   distributed under the License is distributed on an "AS IS" BASIS,
-   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-   See the License for the specific language governing permissions and
-   limitations under the License.
-
- */
-
-/**
- * This class contains database state specific to XA,
- * specifically the XAResource that will be used for XA commands.
- * @author kmarsden@Sourcery.Org
- */
-
-package org.apache.derby.impl.drda;
-
-import java.sql.Connection;
-import java.sql.SQLException;
-
-import javax.transaction.xa.XAResource;
-import javax.sql.XADataSource;
-import javax.sql.XAConnection;
-
-import java.util.Hashtable;
-import java.util.Properties;
-import java.util.Enumeration;
-
-
-import org.apache.derby.jdbc.EmbeddedXADataSource;
-import org.apache.derby.impl.drda.DRDAXid;
-import  org.apache.derby.iapi.jdbc.BrokeredConnection;
-
-class XADatabase extends Database {
-
-
-	// XA Datasource used by all the XA connection requests
-	private EmbeddedXADataSource xaDataSource;
-
-	private XAResource xaResource;
-	private XAConnection xaConnection;
-
-	
-	protected XADatabase (String dbName)
-	{
-		super(dbName);
-		forXA = true;
-	}
-
-	/**
-	 * Make a new connection using the database name and set 
-	 * the connection in the database
-	 **/
-	protected synchronized Connection makeConnection(Properties p) throws
- SQLException
-	{
-		if (xaDataSource == null)
-		{
-			xaDataSource = new EmbeddedXADataSource();
-		}
-
-		xaDataSource.setDatabaseName(shortDbName);
-		appendAttrString(p);
-		if (attrString != null)
-			xaDataSource.setConnectionAttributes(attrString);
-		xaConnection = xaDataSource.getXAConnection(userId,password);
-		xaResource = xaConnection.getXAResource();
-
-		Connection conn = xaConnection.getConnection();
-		setConnection(conn);
-		return conn;
-		
-	}
-
-	/** SetXAResource
-	 * @param resource XAResource for this connection
-	 */
-	protected void setXAResource (XAResource resource)
-	{
-		this.xaResource = resource;
-	}
-
-	/** Set DRDA id for this connection
-	 * @param drdaId
-	 */
-	protected void setDrdaID(String drdaID)
-	{
-		if (getConnection() != null)
-			((BrokeredConnection) getConnection()).setDrdaID(drdaID);
-	}
-
-
-	/**
-	 *  Set the internal isolation level to use for preparing statements.
-	 *  Subsequent prepares will use this isoalation level
-	 * @param level internal isolation level 
-	 *
-	 * @throws SQLException
-	 * @see BrokeredConnection#setPrepareIsolation
-	 * 
-	 */
-	protected void setPrepareIsolation(int level) throws SQLException
-	{
-		((BrokeredConnection) getConnection()).setPrepareIsolation(level);
-	}
-
-	/** get prepare isolation level for this connection.
-	 * 
-	 */
-	protected int getPrepareIsolation() throws SQLException
-	{
-		return ((BrokeredConnection) getConnection()).getPrepareIsolation();
-	}
-
-	/**
-	 * get XA Resource for this connection
-	 */
-	protected XAResource getXAResource ()
-	{
-		return this.xaResource;
-	}
-
-
-}
-
-
-
-
-
-
-
-
-
+/*
+
+   Derby - Class org.apache.derby.impl.drda.XADatabase.java
+
+   Copyright 2004 The Apache Software Foundation or its licensors, as applicable.
+
+   Licensed under the Apache License, Version 2.0 (the "License");
+   you may not use this file except in compliance with the License.
+   You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
+
+ */
+
+/**
+ * This class contains database state specific to XA,
+ * specifically the XAResource that will be used for XA commands.
+ * @author kmarsden@Sourcery.Org
+ */
+
+package org.apache.derby.impl.drda;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+
+import javax.transaction.xa.XAResource;
+import javax.sql.XADataSource;
+import javax.sql.XAConnection;
+
+import java.util.Hashtable;
+import java.util.Properties;
+import java.util.Enumeration;
+
+
+import org.apache.derby.jdbc.EmbeddedXADataSource;
+import org.apache.derby.impl.drda.DRDAXid;
+import  org.apache.derby.iapi.jdbc.BrokeredConnection;
+
+class XADatabase extends Database {
+
+
+	// XA Datasource used by all the XA connection requests
+	private EmbeddedXADataSource xaDataSource;
+
+	private XAResource xaResource;
+	private XAConnection xaConnection;
+
+	
+	protected XADatabase (String dbName)
+	{
+		super(dbName);
+		forXA = true;
+	}
+
+	/**
+	 * Make a new connection using the database name and set 
+	 * the connection in the database
+	 **/
+	protected synchronized Connection makeConnection(Properties p) throws
+ SQLException
+	{
+		if (xaDataSource == null)
+		{
+			xaDataSource = new EmbeddedXADataSource();
+		}
+
+		xaDataSource.setDatabaseName(shortDbName);
+		appendAttrString(p);
+		if (attrString != null)
+			xaDataSource.setConnectionAttributes(attrString);
+		xaConnection = xaDataSource.getXAConnection(userId,password);
+		xaResource = xaConnection.getXAResource();
+
+		Connection conn = xaConnection.getConnection();
+		setConnection(conn);
+		return conn;
+		
+	}
+
+	/** SetXAResource
+	 * @param resource XAResource for this connection
+	 */
+	protected void setXAResource (XAResource resource)
+	{
+		this.xaResource = resource;
+	}
+
+	/** Set DRDA id for this connection
+	 * @param drdaId
+	 */
+	protected void setDrdaID(String drdaID)
+	{
+		if (getConnection() != null)
+			((BrokeredConnection) getConnection()).setDrdaID(drdaID);
+	}
+
+
+	/**
+	 *  Set the internal isolation level to use for preparing statements.
+	 *  Subsequent prepares will use this isoalation level
+	 * @param level internal isolation level 
+	 *
+	 * @throws SQLException
+	 * @see BrokeredConnection#setPrepareIsolation
+	 * 
+	 */
+	protected void setPrepareIsolation(int level) throws SQLException
+	{
+		((BrokeredConnection) getConnection()).setPrepareIsolation(level);
+	}
+
+	/** get prepare isolation level for this connection.
+	 * 
+	 */
+	protected int getPrepareIsolation() throws SQLException
+	{
+		return ((BrokeredConnection) getConnection()).getPrepareIsolation();
+	}
+
+	/**
+	 * get XA Resource for this connection
+	 */
+	protected XAResource getXAResource ()
+	{
+		return this.xaResource;
+	}
+
+
+}
+
+
+
+
+
+
+
+
+

Mime
View raw message