org.dcm4che3.net.service

Class BasicRetrieveTask<T extends InstanceLocator>

java.lang.Object

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

All Implemented Interfaces:

Runnable, Observer, CancelRQHandler, RetrieveTask

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

Author:

Gunter Zeilinger , Umberto Cappellini

Field Summary

Fields

Modifier and Type	Field and Description
protected List<T>	insts
protected static 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 Association	storeas
private CStoreSCU<T>	storescu
private ScheduledFuture<?>	writePendingRSP

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	close()
Association	getRequestAssociation()
Association	getStoreAssociation()
boolean	isCMove()
void	onCancelRQ(Association as)
protected void	releaseStoreAssociation(Association storeas)
void	run()
void	setSendPendingRSP(boolean pendingRSP)
void	setSendPendingRSPInterval(int pendingRSPInterval)
private void	startWritingAsyncRSP()
private void	stopWritingAsyncRSP()
void	update(Observable obj, Object arg)
private void	writeRSP()

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

insts

protected final List<T extends InstanceLocator> insts

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

pendingRSP

protected boolean pendingRSP

pendingRSPInterval

protected int pendingRSPInterval

outstandingRSP

protected int outstandingRSP

outstandingRSPLock

protected Object outstandingRSPLock

storescu

private CStoreSCU<T extends InstanceLocator> storescu

writePendingRSP

private ScheduledFuture<?> writePendingRSP

Constructor Detail

BasicRetrieveTask

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

Method Detail

setSendPendingRSP

public void setSendPendingRSP(boolean pendingRSP)

setSendPendingRSPInterval

public void setSendPendingRSPInterval(int pendingRSPInterval)

isCMove

public boolean isCMove()

getRequestAssociation

public Association getRequestAssociation()

getStoreAssociation

public Association getStoreAssociation()

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)

startWritingAsyncRSP

private void startWritingAsyncRSP()

stopWritingAsyncRSP

private void stopWritingAsyncRSP()

writeRSP

private void writeRSP()

close

protected void close()

update

public void update(Observable obj,
                   Object arg)

Specified by:

update in interface Observer