hep.wired.glast

Class GleamRecordSource

java.lang.Object

org.freehep.record.source.AbstractRecordSource

hep.wired.corbaheprep.CORBARecordSource

hep.wired.glast.GleamRecordSource

All Implemented Interfaces:

org.freehep.record.source.RecordSource

public final class GleamRecordSource
extends CORBARecordSource

GLEAM-specific RecordSource implementation.

Version:

$Id: $

Author:

Dmitry Onoprienko

Nested Class Summary

Nested classes/interfaces inherited from class hep.wired.corbaheprep.CORBARecordSource

CORBARecordSource.Move

Field Summary

Fields inherited from class hep.wired.corbaheprep.CORBARecordSource

_hasNext, _hasPrevious, _heprep, _index, _isHepRep2, _server, _size, _supports, _tag, UNKNOWN

Fields inherited from class org.freehep.record.source.AbstractRecordSource

_name

Constructor Summary

Constructors

Constructor and Description
GleamRecordSource(String name, HepEventServer server, Properties serverInfo)
GleamRecordSource(String name, HepEventServer server, Properties serverInfo, Properties datasetProperties)

Method Summary

Methods

Modifier and Type	Method and Description
protected String	getServerCommand(CORBARecordSource.Move move, long par, org.freehep.record.source.RecordTag tag) Returns the command that needs to be send to the CORBA server to position it for reading the specified record.
boolean	hasRewind() Returns true if this source in its current state can be rewound.
void	jump(org.freehep.record.source.RecordTag tag) Loads the record specified by the tag.
org.freehep.record.source.RecordTag	parseTag(String s) Returns a tag corresponding to the specified string.
protected void	positionServer(CORBARecordSource.Move move, long par, org.freehep.record.source.RecordTag tag)
void	rewind() Positions the cursor of this source before the first record.
protected void	sendCommand(String command)
boolean	sendStop() Sends "stop" command to the CORBA server, returns true if the server indicates this source needs to be closed.
protected void	setCurrentIndex() Sets _index to the index of the record for which the CORBA server is currently positioned.
protected void	setCurrentTag() Sets _tag to the tag of the record for which the CORBA server is currently positioned.
void	shift(long numberOfRecords) Loads the record specified by the offset with respect to the current cursor position.
boolean	supportsRewind() Returns true if this source supports rewind operation.

Methods inherited from class hep.wired.corbaheprep.CORBARecordSource

close, current, determineSize, getCurrentIndex, getCurrentRecord, getCurrentTag, getEstimatedSize, getHepRep, getRecordClass, hasCurrent, hasIndex, hasNext, hasPrevious, hasShift, jump, next, previous, releaseRecord, restorePosition, size, supportsCurrent, supportsIndex, supportsNext, supportsPrevious, supportsShift, supportsTag

Methods inherited from class org.freehep.record.source.AbstractRecordSource

getName, getTags, hasTag, jump, setName

Methods inherited from class java.lang.Object

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

Constructor Detail

GleamRecordSource

public GleamRecordSource(String name,
                 HepEventServer server,
                 Properties serverInfo)

GleamRecordSource

public GleamRecordSource(String name,
                 HepEventServer server,
                 Properties serverInfo,
                 Properties datasetProperties)

Method Detail

jump

public void jump(org.freehep.record.source.RecordTag tag)
          throws IOException,
                 org.freehep.record.source.NoSuchRecordException

Loads the record specified by the tag.

Specified by:

jump in interface org.freehep.record.source.RecordSource

Overrides:

jump in class CORBARecordSource

Throws:

org.freehep.record.source.NoSuchRecordException - if this source does not have a record with the specified tag.

IOException - if loading of the requested record fails.

UnsupportedOperationException - if this source does not support access by tag.

shift

public void shift(long numberOfRecords)
           throws IOException,
                  org.freehep.record.source.NoSuchRecordException

Loads the record specified by the offset with respect to the current cursor position. The offset can be negative or positive. Skipping is guaranteed to be at least as fast as numberOfRecords consecutive calls to next() or previous(), and will be faster if this source implementation permits it.

Specified by:

shift in interface org.freehep.record.source.RecordSource

Overrides:

shift in class CORBARecordSource

Throws:

org.freehep.record.source.NoSuchRecordException - if this source does not have a record with the specified offset.

IOException - if loading of the requested record fails.

UnsupportedOperationException - if this source does not support access by offset.

getServerCommand

protected String getServerCommand(CORBARecordSource.Move move,
                      long par,
                      org.freehep.record.source.RecordTag tag)

Returns the command that needs to be send to the CORBA server to position it for reading the specified record.

Overrides:

getServerCommand in class CORBARecordSource

setCurrentIndex

protected void setCurrentIndex()

Description copied from class: CORBARecordSource

Sets _index to the index of the record for which the CORBA server is currently positioned.

Overrides:

setCurrentIndex in class CORBARecordSource

setCurrentTag

protected void setCurrentTag()

Description copied from class: CORBARecordSource

Sets _tag to the tag of the record for which the CORBA server is currently positioned.

Overrides:

setCurrentTag in class CORBARecordSource

positionServer

protected void positionServer(CORBARecordSource.Move move,
                  long par,
                  org.freehep.record.source.RecordTag tag)
                       throws IOException,
                              org.freehep.record.source.NoSuchRecordException

Overrides:

positionServer in class CORBARecordSource

Throws:

IOException

org.freehep.record.source.NoSuchRecordException

sendCommand

protected void sendCommand(String command)
                    throws org.freehep.record.source.NoSuchRecordException,
                           IOException

Overrides:

sendCommand in class CORBARecordSource

Throws:

org.freehep.record.source.NoSuchRecordException

IOException

sendStop

public boolean sendStop()

Sends "stop" command to the CORBA server, returns true if the server indicates this source needs to be closed.

supportsRewind

public boolean supportsRewind()

Returns true if this source supports rewind operation.

Specified by:

supportsRewind in interface org.freehep.record.source.RecordSource

Overrides:

supportsRewind in class CORBARecordSource

hasRewind

public boolean hasRewind()

Returns true if this source in its current state can be rewound.

Specified by:

hasRewind in interface org.freehep.record.source.RecordSource

Overrides:

hasRewind in class CORBARecordSource

rewind

public void rewind()
            throws IOException

Positions the cursor of this source before the first record.

Specified by:

rewind in interface org.freehep.record.source.RecordSource

Overrides:

rewind in class CORBARecordSource

Throws:

UnsupportedOperationException - if this source does not support rewind.

IOException - if rewinding fails for any reason.

parseTag

public org.freehep.record.source.RecordTag parseTag(String s)

Returns a tag corresponding to the specified string.

Specified by:

parseTag in interface org.freehep.record.source.RecordSource

Overrides:

parseTag in class org.freehep.record.source.AbstractRecordSource