org.openorb.pss.connector.file
Class TransactionalFileSession

java.lang.Object
  |
  +--org.omg.CORBA.LocalObject
        |
        +--org.openorb.pss.connector.file.FileCatalog
              |
              +--org.openorb.pss.connector.file.FileSession
                    |
                    +--org.openorb.pss.connector.file.TransactionalFileSession

All Implemented Interfaces:

CatalogBase, CatalogBaseOperations, ExtendedCatalog, FileCatalogBase, org.omg.CORBA.portable.IDLEntity, org.omg.CORBA.Object, java.io.Serializable, Session, SessionOperations, TransactionalSession, TransactionalSessionOperations

public class TransactionalFileSession

extends FileSession

implements TransactionalSession

This class is the implementation for a transactional session. In term of isolation level, we only support READ COMMITTED and SERIALIZABLE.

Author:

Jerome Daniel

See Also:

Serialized Form

Fields inherited from interface org.omg.CosPersistentState.TransactionalSession

ACTIVE, ENDING, NO_ASSOCIATION, SUSPENDED

Constructor Summary

TransactionalFileSession()

TransactionalFileSession(org.omg.PortableInterceptor.ORBInitInfo info)
Constructor

Method Summary

short	default_isolation_level() Read accessor for default_isolation_level attribute
void	end(org.omg.CosTransactions.Coordinator transaction, boolean success) Operation end
short	get_association_status() Operation get_association_status
TransactionalDataManager[]	get_data_managers() Return all data manager
DataManager	getDataManager(java.lang.String storage_home_name) This operation return the DataManager.
boolean	is_associated_to(org.omg.CosTransactions.Coordinator transaction) This operation is used to test if this transactional session is associated to a transaction coordinator.
void	remove_file_resource() Remove the transactional file resource
void	setBaseInfo(FileConnector connector, short default_isolation_level, EndOfAssociationCallback callback, short access, Parameter[] parameters) Set the base information require by a catalog
void	start(org.omg.CosTransactions.Coordinator transaction) Operation start
void	suspend(org.omg.CosTransactions.Coordinator transaction) Operation suspend
org.omg.CosTransactions.Coordinator	transaction() Operation transaction

Methods inherited from class org.openorb.pss.connector.file.FileSession

clean, close, create_embedded_object, create_empty_object, create_new_entry, create_object, createHomePID, createPID, delete, destroy, entry, entry, find_home_base, flush, free_all, getSequentialAccess, incarnate, refresh, setBaseInfo, stored, write_entry

Methods inherited from class org.openorb.pss.connector.file.FileCatalog

access_mode, connector, find_all, find_by_pid, find_ref_by_pid, find_storage_home, iterator, parameters, setCatalogInfo

Methods inherited from class org.omg.CORBA.LocalObject

_create_request, _create_request, _duplicate, _get_domain_managers, _get_interface_def, _get_interface, _get_policy, _hash, _invoke, _is_a, _is_equivalent, _is_local, _non_existent, _orb, _release, _releaseReply, _request, _request, _servant_postinvoke, _servant_preinvoke, _set_policy_override, validate_connection

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.omg.CosPersistentState.CatalogBaseOperations

access_mode, close, find_by_pid, find_storage_home, flush, free_all, refresh

Methods inherited from interface org.omg.CORBA.Object

_create_request, _create_request, _duplicate, _get_domain_managers, _get_interface_def, _get_policy, _hash, _is_a, _is_equivalent, _non_existent, _release, _request, _set_policy_override

Constructor Detail

TransactionalFileSession

public TransactionalFileSession()

TransactionalFileSession

public TransactionalFileSession(org.omg.PortableInterceptor.ORBInitInfo info)

Constructor

Method Detail

setBaseInfo

public void setBaseInfo(FileConnector connector,
                        short default_isolation_level,
                        EndOfAssociationCallback callback,
                        short access,
                        Parameter[] parameters)

Set the base information require by a catalog

getDataManager

public DataManager getDataManager(java.lang.String storage_home_name)

This operation return the DataManager. It is overloaded in order to return DataResourceManager

Overrides:

getDataManager in class FileSession

default_isolation_level

public short default_isolation_level()

Description copied from interface: TransactionalSessionOperations

Read accessor for default_isolation_level attribute

Specified by:

default_isolation_level in interface TransactionalSessionOperations

Following copied from interface: org.omg.CosPersistentState.TransactionalSessionOperations

Returns:

the attribute value

start

public void start(org.omg.CosTransactions.Coordinator transaction)

Description copied from interface: TransactionalSessionOperations

Operation start

Specified by:

start in interface TransactionalSessionOperations

suspend

public void suspend(org.omg.CosTransactions.Coordinator transaction)

Description copied from interface: TransactionalSessionOperations

Operation suspend

Specified by:

suspend in interface TransactionalSessionOperations

end

public void end(org.omg.CosTransactions.Coordinator transaction,
                boolean success)

Description copied from interface: TransactionalSessionOperations

Operation end

Specified by:

end in interface TransactionalSessionOperations

get_association_status

public short get_association_status()

Description copied from interface: TransactionalSessionOperations

Operation get_association_status

Specified by:

get_association_status in interface TransactionalSessionOperations

transaction

public org.omg.CosTransactions.Coordinator transaction()

Description copied from interface: TransactionalSessionOperations

Operation transaction

Specified by:

transaction in interface TransactionalSessionOperations

get_data_managers

public TransactionalDataManager[] get_data_managers()

Return all data manager

remove_file_resource

public void remove_file_resource()

Remove the transactional file resource

is_associated_to

public boolean is_associated_to(org.omg.CosTransactions.Coordinator transaction)

This operation is used to test if this transactional session is associated to a transaction coordinator.