org.dcm4che3.net.service

Class BasicRetrieveTask<T extends InstanceLocator>

java.lang.Object

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

All Implemented Interfaces:

Runnable, CancelRQHandler, RetrieveTask

public class BasicRetrieveTask<T extends InstanceLocator>
extends Object
implements RetrieveTask

Author:

Gunter Zeilinger

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	canceled
protected List<T>	completed
protected List<T>	failed
protected List<T>	insts
protected static org.slf4j.Logger	LOG
protected int	msgId
protected int	outstandingRSP
protected Object	outstandingRSPLock
protected PresentationContext	pc
protected boolean	pendingRSP
protected int	pendingRSPInterval
protected int	priority
protected Dimse	rq
protected Association	rqas
protected Attributes	rqCmd
protected int	status
protected Association	storeas
protected List<T>	warning

Constructor Summary

Constructors

Constructor and Description
BasicRetrieveTask(Dimse rq, Association rqas, PresentationContext pc, Attributes rqCmd, List<T> insts, Association storeas)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	close()
protected DataWriter	createDataWriter(T inst, String tsuid)
protected void	cstore(Association storeas, T inst)
List<T>	getCompleted()
List<T>	getFailed()
Association	getRequestAssociation()
int	getStatus()
Association	getStoreAssociation()
List<T>	getWarning()
boolean	isCanceled()
boolean	isCMove()
void	onCancelRQ(Association as)
protected void	releaseStoreAssociation(Association storeas)
void	run()
protected String	selectTransferSyntaxFor(Association storeas, T inst)
void	setSendPendingRSP(boolean pendingRSP)
void	setSendPendingRSPInterval(int pendingRSPInterval)
void	writePendingRSP()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

rq

protected final Dimse rq

rqas

protected final Association rqas

storeas

protected final Association storeas

pc

protected final PresentationContext pc

rqCmd

protected final Attributes rqCmd

msgId

protected final int msgId

priority

protected final int priority

status

protected int status

pendingRSP

protected boolean pendingRSP

pendingRSPInterval

protected int pendingRSPInterval

canceled

protected boolean canceled

insts

protected final List<T extends InstanceLocator> insts

completed

protected final List<T extends InstanceLocator> completed

warning

protected final List<T extends InstanceLocator> warning

failed

protected final List<T extends InstanceLocator> failed

outstandingRSP

protected int outstandingRSP

outstandingRSPLock

protected Object outstandingRSPLock

Constructor Detail

BasicRetrieveTask

public BasicRetrieveTask(Dimse rq,
                 Association rqas,
                 PresentationContext pc,
                 Attributes rqCmd,
                 List<T> insts,
                 Association storeas)

Method Detail

setSendPendingRSP

public void setSendPendingRSP(boolean pendingRSP)

setSendPendingRSPInterval

public void setSendPendingRSPInterval(int pendingRSPInterval)

isCMove

public boolean isCMove()

isCanceled

public boolean isCanceled()

getStatus

public int getStatus()

getRequestAssociation

public Association getRequestAssociation()

getStoreAssociation

public Association getStoreAssociation()

getCompleted

public List<T> getCompleted()

getWarning

public List<T> getWarning()

getFailed

public List<T> getFailed()

onCancelRQ

public void onCancelRQ(Association as)

Specified by:

onCancelRQ in interface CancelRQHandler

run

public void run()

Specified by:

run in interface Runnable

releaseStoreAssociation

protected void releaseStoreAssociation(Association storeas)

cstore

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

Throws:

IOException

InterruptedException

selectTransferSyntaxFor

protected String selectTransferSyntaxFor(Association storeas,
                             T inst)

createDataWriter

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

Throws:

IOException

writePendingRSP

public void writePendingRSP()

close

protected void close()