edu.sc.seis.cormorant.seismogram

Class BudLightCachingDC

java.lang.Object

org.omg.PortableServer.Servant

edu.iris.Fissures.IfSeismogramDC.DataCenterPOA

edu.sc.seis.cormorant.seismogram.BudLightCachingDC

All Implemented Interfaces:

edu.iris.Fissures.IfSeismogramDC.DataCenterOperations, org.omg.CORBA.portable.InvokeHandler

public class BudLightCachingDC
extends edu.iris.Fissures.IfSeismogramDC.DataCenterPOA

Field Summary

Fields

Modifier and Type	Field and Description
static edu.iris.Fissures.model.TimeInterval	MAX_GAP
static edu.iris.Fissures.model.TimeInterval	MIN_REQUEST_SIZE
protected edu.sc.seis.fissuresUtil.cache.WorkerThreadPool	pool

Constructor Summary

Constructors

Constructor and Description
BudLightCachingDC(BudLightWriter writer, CacheableDataCenter localOps)
BudLightCachingDC(BudLightWriter writer, CacheableDataCenter localOps, edu.iris.Fissures.IfSeismogramDC.DataCenterOperations remoteOps)

Method Summary

Modifier and Type	Method and Description
edu.iris.Fissures.IfSeismogramDC.RequestFilter[]	available_data(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] request)
java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter>	availableData(java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> request)
void	cancel_request(java.lang.String a_request)
edu.iris.Fissures.model.TimeInterval	getMaxDataLag()
java.lang.String	queue_seismograms(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] a_filterseq)
java.lang.String	request_seismograms(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] a_filterseq, edu.iris.Fissures.IfSeismogramDC.DataCenterCallBack a_client, boolean long_lived, edu.iris.Fissures.Time expiration_time)
java.lang.String	request_status(java.lang.String a_request)
edu.iris.Fissures.IfSeismogramDC.LocalSeismogram[]	retrieve_queue(java.lang.String a_request)
edu.iris.Fissures.IfSeismogramDC.LocalSeismogram[]	retrieve_seismograms(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] request)
protected void	sendToCache(edu.iris.Fissures.IfSeismogramDC.LocalSeismogram[] seis)
void	setMaxDataLag(edu.iris.Fissures.model.TimeInterval maxDataLag)

Methods inherited from class edu.iris.Fissures.IfSeismogramDC.DataCenterPOA

_all_interfaces, _invoke, _this, _this

Methods inherited from class org.omg.PortableServer.Servant

_default_POA, _get_delegate, _get_interface_def, _is_a, _non_existent, _object_id, _orb, _poa, _set_delegate, _this_object, _this_object

Methods inherited from class java.lang.Object

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

Field Detail

pool

protected edu.sc.seis.fissuresUtil.cache.WorkerThreadPool pool

MAX_GAP

public static final edu.iris.Fissures.model.TimeInterval MAX_GAP

MIN_REQUEST_SIZE

public static final edu.iris.Fissures.model.TimeInterval MIN_REQUEST_SIZE

Constructor Detail

BudLightCachingDC

public BudLightCachingDC(BudLightWriter writer,
                         CacheableDataCenter localOps)

BudLightCachingDC

public BudLightCachingDC(BudLightWriter writer,
                         CacheableDataCenter localOps,
                         edu.iris.Fissures.IfSeismogramDC.DataCenterOperations remoteOps)

Method Detail

available_data

public edu.iris.Fissures.IfSeismogramDC.RequestFilter[] available_data(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] request)

availableData

public java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> availableData(java.util.List<edu.iris.Fissures.IfSeismogramDC.RequestFilter> request)

retrieve_seismograms

public edu.iris.Fissures.IfSeismogramDC.LocalSeismogram[] retrieve_seismograms(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] request)
                                                                        throws edu.iris.Fissures.FissuresException

Throws:

edu.iris.Fissures.FissuresException

request_seismograms

public java.lang.String request_seismograms(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] a_filterseq,
                                            edu.iris.Fissures.IfSeismogramDC.DataCenterCallBack a_client,
                                            boolean long_lived,
                                            edu.iris.Fissures.Time expiration_time)
                                     throws edu.iris.Fissures.FissuresException

Throws:

edu.iris.Fissures.FissuresException

queue_seismograms

public java.lang.String queue_seismograms(edu.iris.Fissures.IfSeismogramDC.RequestFilter[] a_filterseq)
                                   throws edu.iris.Fissures.FissuresException

Throws:

edu.iris.Fissures.FissuresException

retrieve_queue

public edu.iris.Fissures.IfSeismogramDC.LocalSeismogram[] retrieve_queue(java.lang.String a_request)
                                                                  throws edu.iris.Fissures.FissuresException

Throws:

edu.iris.Fissures.FissuresException

cancel_request

public void cancel_request(java.lang.String a_request)
                    throws edu.iris.Fissures.FissuresException

Throws:

edu.iris.Fissures.FissuresException

request_status

public java.lang.String request_status(java.lang.String a_request)
                                throws edu.iris.Fissures.FissuresException

Throws:

edu.iris.Fissures.FissuresException

sendToCache

protected void sendToCache(edu.iris.Fissures.IfSeismogramDC.LocalSeismogram[] seis)

getMaxDataLag

public edu.iris.Fissures.model.TimeInterval getMaxDataLag()

setMaxDataLag

public void setMaxDataLag(edu.iris.Fissures.model.TimeInterval maxDataLag)