edu.umass.cs.txn

Class TXUtils

java.lang.Object

edu.umass.cs.txn.TXUtils

All Implemented Interfaces:

Transactor

public class TXUtils
extends java.lang.Object
implements Transactor

Author:

arun A class with static utility methods related to transactions.

Constructor Summary

Constructors

Constructor and Description
TXUtils()

Method Summary

Modifier and Type	Method and Description
protected static GigaPaxosClient<Request>	getGPClient(AppRequestParser app) Creates an async gigapaxos client without checking connectivity (because the reconfigurators may not yet have been initialized.
protected TxStateRequest.State	getTxState(GigaPaxosClient<Request> gpClient, Transaction tx)
protected static java.util.Set<java.net.InetSocketAddress>	requestActiveReplicas(GigaPaxosClient<Request> gpClient, Transaction tx) This method fetches the union set of the set of active replica addresses for all participant groups in a transaction by issuing an async task for the lock list of the transaction.
void	transact(TXRequest request)
protected static Request[]	tryFinishAsyncTasks(GigaPaxosClient<Request> gpClient, java.util.ArrayList<Request> txRequests)
protected static Request[]	tryFinishAsyncTasks(GigaPaxosClient<Request> gpClient, java.util.ArrayList<Request> txRequests, int numAttempts) Blocks and retries in parallel until all of a set of transaction steps have successfully completed.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TXUtils

public TXUtils()

Method Detail

tryFinishAsyncTasks

protected static Request[] tryFinishAsyncTasks(GigaPaxosClient<Request> gpClient,
                                               java.util.ArrayList<Request> txRequests)

tryFinishAsyncTasks

protected static Request[] tryFinishAsyncTasks(GigaPaxosClient<Request> gpClient,
                                               java.util.ArrayList<Request> txRequests,
                                               int numAttempts)

Blocks and retries in parallel until all of a set of transaction steps have successfully completed. The steps have to be idempotent, i.e., executing them multiple times should have the same effect as executing them exactly once.

Parameters:

gpClient -

txRequests - The list of operations comprising the transaction.

numAttempts - Maximum number of times each task will be retransmitted before timing out.

Returns:

An array of responses where the i'th element of the array is the response for the i'th element in txRequests.

requestActiveReplicas

protected static java.util.Set<java.net.InetSocketAddress> requestActiveReplicas(GigaPaxosClient<Request> gpClient,
                                                                                 Transaction tx)

This method fetches the union set of the set of active replica addresses for all participant groups in a transaction by issuing an async task for the lock list of the transaction.

Parameters:

gpClient -

tx -

Returns:

getTxState

protected TxStateRequest.State getTxState(GigaPaxosClient<Request> gpClient,
                                          Transaction tx)
                                   throws java.io.IOException

Throws:

java.io.IOException

getGPClient

protected static GigaPaxosClient<Request> getGPClient(AppRequestParser app)
                                               throws java.io.IOException

Creates an async gigapaxos client without checking connectivity (because the reconfigurators may not yet have been initialized.

Parameters:

app -

Returns:

The created client.

Throws:

java.io.IOException

transact

public void transact(TXRequest request)

Specified by:

transact in interface Transactor