public final class GleamRecordSource
extends hep.wired.corbaheprep.CORBARecordSource
RecordSource
implementation.Constructor and Description |
---|
GleamRecordSource(String name,
hep.wired.hepeventserver.idl.HepEventServer server,
Properties serverInfo) |
GleamRecordSource(String name,
hep.wired.hepeventserver.idl.HepEventServer server,
Properties serverInfo,
Properties datasetProperties) |
Modifier and Type | Method and Description |
---|---|
protected String |
getServerCommand(hep.wired.corbaheprep.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(hep.wired.corbaheprep.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() |
protected void |
setCurrentTag() |
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.
|
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
public GleamRecordSource(String name, hep.wired.hepeventserver.idl.HepEventServer server, Properties serverInfo)
public GleamRecordSource(String name, hep.wired.hepeventserver.idl.HepEventServer server, Properties serverInfo, Properties datasetProperties)
public void jump(org.freehep.record.source.RecordTag tag) throws IOException, org.freehep.record.source.NoSuchRecordException
jump
in interface org.freehep.record.source.RecordSource
jump
in class hep.wired.corbaheprep.CORBARecordSource
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.public void shift(long numberOfRecords) throws IOException, org.freehep.record.source.NoSuchRecordException
shift
in interface org.freehep.record.source.RecordSource
shift
in class hep.wired.corbaheprep.CORBARecordSource
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.protected String getServerCommand(hep.wired.corbaheprep.CORBARecordSource.Move move, long par, org.freehep.record.source.RecordTag tag)
getServerCommand
in class hep.wired.corbaheprep.CORBARecordSource
protected void setCurrentIndex()
setCurrentIndex
in class hep.wired.corbaheprep.CORBARecordSource
protected void setCurrentTag()
setCurrentTag
in class hep.wired.corbaheprep.CORBARecordSource
protected void positionServer(hep.wired.corbaheprep.CORBARecordSource.Move move, long par, org.freehep.record.source.RecordTag tag) throws IOException, org.freehep.record.source.NoSuchRecordException
positionServer
in class hep.wired.corbaheprep.CORBARecordSource
IOException
org.freehep.record.source.NoSuchRecordException
protected void sendCommand(String command) throws org.freehep.record.source.NoSuchRecordException, IOException
sendCommand
in class hep.wired.corbaheprep.CORBARecordSource
org.freehep.record.source.NoSuchRecordException
IOException
public boolean sendStop()
public boolean supportsRewind()
supportsRewind
in interface org.freehep.record.source.RecordSource
supportsRewind
in class hep.wired.corbaheprep.CORBARecordSource
public boolean hasRewind()
hasRewind
in interface org.freehep.record.source.RecordSource
hasRewind
in class hep.wired.corbaheprep.CORBARecordSource
public void rewind() throws IOException
rewind
in interface org.freehep.record.source.RecordSource
rewind
in class hep.wired.corbaheprep.CORBARecordSource
UnsupportedOperationException
- if this source does not support rewind.IOException
- if rewinding fails for any reason.public org.freehep.record.source.RecordTag parseTag(String s)
parseTag
in interface org.freehep.record.source.RecordSource
parseTag
in class org.freehep.record.source.AbstractRecordSource
Copyright © 1996-2014 FreeHEP. All Rights Reserved.