org.dcm4che3.net.service

Class BasicCStoreSCU<T extends InstanceLocator>

java.lang.Object

java.util.Observable

org.dcm4che3.net.service.BasicCStoreSCU<T>

Type Parameters:

T - instance locator type

All Implemented Interfaces:

CStoreSCU<T>

Direct Known Subclasses:

CStoreSCUImpl

public class BasicCStoreSCU<T extends InstanceLocator>
extends Observable
implements CStoreSCU<T>

Author:

Umberto Cappellini

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	BasicCStoreSCU.CStoreRSPHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected List<T>	completed
protected List<T>	failed
protected static Logger	LOG
protected int	nr_instances
protected int	outstandingRSP
protected Object	outstandingRSPLock
protected int	priority
protected int	status
protected List<T>	warning

Constructor Summary

Constructors

Constructor and Description
BasicCStoreSCU()

Method Summary

Modifier and Type	Method and Description
boolean	cancel()
protected void	close()
protected DataWriter	createDataWriter(T inst, String tsuid)
protected int	cstore(Association storeas, T inst, String tsuid, DataWriter dataWriter)
BasicCStoreSCUResp	cstore(List<T> instances, Association storeas, int priority)
List<T>	getCompleted()
List<T>	getFailed()
int	getPriority()
int	getRemaining()
int	getStatus()
List<T>	getWarning()
private BasicCStoreSCUResp	makeRSP(int status) returns an aggregated store rsp
protected void	releaseStoreAssociation(Association storeas)
protected String	selectTransferSyntaxFor(Association storeas, T inst)
private void	setFinalStatus()
protected void	storeInstance(Association storeas, T inst)
private void	waitForOutstandingCStoreRSP(Association storeas)

Methods inherited from class java.util.Observable

addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Logger LOG

status

protected volatile int status

priority

protected int priority

nr_instances

protected int nr_instances

completed

protected List<T extends InstanceLocator> completed

warning

protected List<T extends InstanceLocator> warning

failed

protected List<T extends InstanceLocator> failed

outstandingRSP

protected int outstandingRSP

outstandingRSPLock

protected Object outstandingRSPLock

Constructor Detail

BasicCStoreSCU

public BasicCStoreSCU()

Method Detail

getStatus

public int getStatus()

Specified by:

getStatus in interface CStoreSCU<T extends InstanceLocator>

cancel

public boolean cancel()

Specified by:

cancel in interface CStoreSCU<T extends InstanceLocator>

getPriority

public int getPriority()

Specified by:

getPriority in interface CStoreSCU<T extends InstanceLocator>

getCompleted

public List<T> getCompleted()

Specified by:

getCompleted in interface CStoreSCU<T extends InstanceLocator>

getWarning

public List<T> getWarning()

Specified by:

getWarning in interface CStoreSCU<T extends InstanceLocator>

getFailed

public List<T> getFailed()

Specified by:

getFailed in interface CStoreSCU<T extends InstanceLocator>

getRemaining

public int getRemaining()

Specified by:

getRemaining in interface CStoreSCU<T extends InstanceLocator>

cstore

public BasicCStoreSCUResp cstore(List<T> instances,
                                 Association storeas,
                                 int priority)

Specified by:

cstore in interface CStoreSCU<T extends InstanceLocator>

storeInstance

protected void storeInstance(Association storeas,
                             T inst)
                      throws IOException,
                             InterruptedException

Throws:

IOException

InterruptedException

setFinalStatus

private void setFinalStatus()

waitForOutstandingCStoreRSP

private void waitForOutstandingCStoreRSP(Association storeas)

releaseStoreAssociation

protected void releaseStoreAssociation(Association storeas)

cstore

protected int cstore(Association storeas,
                     T inst,
                     String tsuid,
                     DataWriter dataWriter)
              throws IOException,
                     InterruptedException

Throws:

IOException

InterruptedException

selectTransferSyntaxFor

protected String selectTransferSyntaxFor(Association storeas,
                                         T inst)
                                  throws Exception

Throws:

Exception

createDataWriter

protected DataWriter createDataWriter(T inst,
                                      String tsuid)
                               throws Exception

Throws:

Exception

makeRSP

private BasicCStoreSCUResp makeRSP(int status)

returns an aggregated store rsp

close

protected void close()