DCMTK

storageSCP.setPort(OFstatic_cast(Uint16, opt_port));

storageSCP.setAETitle(opt_aeTitle);

storageSCP.setMaxReceivePDULength(OFstatic_cast(Uint32, opt_maxPDULength));

storageSCP.setDIMSEBlockingMode(opt_blockingMode);

storageSCP.setVerbosePCMode(opt_showPresentationContexts);

storageSCP.setRespondWithCalledAETitle(opt_useCalledAETitle);

if (cmd.findOption("--timeout"))

{

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

}

if (cmd.findOption("--acse-timeout"))

app.checkValue(cmd.getValueAndCheckMin(opt_acseTimeout, 1));

storageSCU.setPeerAETitle(opt_peerTitle);

storageSCU.setAETitle(opt_ourTitle);

storageSCU.setMaxReceivePDULength(OFstatic_cast(Uint32, opt_maxReceivePDULength));

storageSCU.setDIMSEBlockingMode(opt_blockMode);

storageSCU.setVerbosePCMode(opt_showPresentationContexts);

storageSCU.setDatasetConversionMode(opt_decompressionMode != DcmStorageSCU::DM_never);

#define PEERAPPLICATIONTITLE "ANY-SCP"

static T_DIMSE_BlockingMode opt_blockMode = DIMSE_BLOCKING;

static OFCondition cecho(T_ASC_Association * assoc, unsigned long num_repeat);

OFCmdUnsignedInt opt_numPresentationCtx = 1;

OFCmdUnsignedInt maxXferSyntaxes = OFstatic_cast(OFCmdUnsignedInt, (DIM_OF(transferSyntaxes)));

OFBool opt_secureConnection = OFFalse; /* default: no secure connection */

#ifdef WITH_OPENSSL

int opt_keyFileFormat = SSL_FILETYPE_PEM;

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

}

if (cmd.findOption("--acse-timeout"))

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

}

if (cmd.findOption("--dimse-timeout"))

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

opt_blockMode = DIMSE_NONBLOCKING;

}

OFList<OFString> fileNameList;

OFBool opt_abortAssociation = OFFalse;

const char * opt_abstractSyntax = UID_FINDModalityWorklistInformationModel;

T_DIMSE_BlockingMode opt_blockMode = DIMSE_BLOCKING;

OFCmdSignedInt opt_cancelAfterNResponses = -1;

int opt_outputResponsesToLogger = 0;

OFBool opt_extractResponsesToFile = OFFalse;

OFString opt_outputDirectory = ".";

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

}

if (cmd.findOption("--acse-timeout"))

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

}

if (cmd.findOption("--dimse-timeout"))

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

opt_blockMode = DIMSE_NONBLOCKING;

}

OFCmdUnsignedInt opt_repeatCount = 1;

QueryModel opt_queryModel = QMPatientRoot;

T_DIMSE_BlockingMode opt_blockMode = DIMSE_BLOCKING;

OFString opt_outputDirectory = ".";

static OFList<OFString> overrideKeys;

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

}

if (cmd.findOption("--acse-timeout"))

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

}

if (cmd.findOption("--dimse-timeout"))

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

opt_blockMode = DIMSE_NONBLOCKING;

}

OFCmdSignedInt opt_cancelAfterNResponses = -1;

QueryModel opt_queryModel = QMPatientRoot;

T_DIMSE_BlockingMode opt_blockMode = DIMSE_BLOCKING;

OFBool opt_ignorePendingDatasets = OFTrue;

OFString opt_outputDirectory = ".";

int cmove_status_code = EXITCODE_NO_ERROR;

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

}

if (cmd.findOption("--acse-timeout"))

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

}

if (cmd.findOption("--dimse-timeout"))

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

opt_blockMode = DIMSE_NONBLOCKING;

}

OFString lastStudySubdirectoryPathAndName;

static OFBool opt_renameOnEndOfStudy = OFFalse; // default: don't rename any files on end of study

static OFBool endOfStudyThroughTimeoutEvent = OFFalse;

static const char *opt_configFile = NULL;

static const char *opt_profileName = NULL;

T_DIMSE_BlockingMode opt_blockMode = DIMSE_BLOCKING;

#if defined(HAVE_FORK) || defined(_WIN32)

OFBool opt_forkMode = OFFalse;

if (opt_networkTransferSyntax != EXS_Unknown) opt_acceptAllXfers = OFFalse;

if (cmd.findOption("--socket-timeout"))

// always set the timeout values since the global default might be different

if (cmd.findOption("--acse-timeout"))

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

}

if (cmd.findOption("--dimse-timeout"))

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

opt_blockMode = DIMSE_NONBLOCKING;

}

if (cmd.findOption("--eostudy-timeout"))

{

app.checkDependence("--eostudy-timeout", "--sort-conc-studies, --sort-on-study-uid, --sort-on-patientname, --exec-on-eostudy or --rename-on-eostudy",

(opt_sortStudyMode != ESM_None) || (opt_execOnEndOfStudy != NULL) || opt_renameOnEndOfStudy);

}

if (cmd.findOption("--exec-sync")) opt_execSync = OFTrue;

static const char *opt_configFile = NULL;

static const char *opt_profileName = NULL;

T_DIMSE_BlockingMode opt_blockMode = DIMSE_BLOCKING;

#ifdef WITH_ZLIB

static OFCmdUnsignedInt opt_compressionLevel = 0;

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

}

if (cmd.findOption("--socket-timeout"))

// always set the timeout values since the global default might be different

if (cmd.findOption("--acse-timeout"))

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

}

if (cmd.findOption("--dimse-timeout"))

{

OFCmdSignedInt opt_timeout = 0;

app.checkValue(cmd.getValueAndCheckMin(opt_timeout, 1));

opt_blockMode = DIMSE_NONBLOCKING;

}

static int

secondsSince1970()

{

}

static OFString

DCMTK_DCMNET_EXPORT OFCondition ASC_initializeNetwork(

T_ASC_NetworkRole role,

int acceptorPort,

T_ASC_Network ** network,

unsigned long options = 0);

*/

DCMTK_DCMNET_EXPORT OFBool

DCMTK_DCMNET_EXPORT OFBool

DCMTK_DCMNET_EXPORT OFBool

ASC_selectReadableAssociation(

T_ASC_Association* assocs[],

/*

* Association Messages

void **associatePDU=NULL,

unsigned long *associatePDUlength=NULL,

DUL_BLOCKOPTIONS block=DUL_BLOCK,

DCMTK_DCMNET_EXPORT OFCondition

ASC_receiveAssociation(

unsigned long *associatePDUlength=NULL,

OFBool useSecureLayer=OFFalse,

DUL_BLOCKOPTIONS block=DUL_BLOCK,

DCMTK_DCMNET_EXPORT OFCondition

ASC_acknowledgeAssociation(

ASC_abortAssociation(T_ASC_Association * association);

DCMTK_DCMNET_EXPORT OFCondition

DCMTK_DCMNET_EXPORT OFCondition

ASC_dropAssociation(T_ASC_Association * association);

* disables the call of the corresponding setsockopt() function, so that the

* system's default behavior remains unchanged.

*/

/** Global timeout in seconds for receiving data on a socket from a remote host.

* The default value is 60, which is useful in cases where the receiver (e.g.

* disables the call of the corresponding setsockopt() function, so that the

* system's default behavior remains unchanged.

*/

/** this class represents a TCP/IP based transport connection

* which can be a transparent TCP/IP socket communication or a

* If this parameter is 0, the function does not block.

* @returns OFTrue if data is available, OFFalse otherwise.

*/

/** returns OFTrue if this connection is a transparent TCP connection,

* OFFalse if the connection is a secure connection.

* @return OFTrue if one or more connections are readable upon return from

* this method, OFFalse if no connection is ready for reading.

*/

protected:

* @return OFTrue if one or more connections are readable upon return from

* this method, OFFalse if no connection is ready for reading.

*/

/** indicates which of the specified transport connections is ready for

* reading. If none of the specified transport connections is ready

* @return OFTrue if one or more connections are readable upon return from

* this method, OFFalse if no connection is ready for reading.

*/

/// the socket file descriptor/handle used by the transport connection.

DcmNativeSocketType theSocket;

* If this parameter is 0, the function does not block.

* @returns OFTrue if data is available, OFFalse otherwise.

*/

/** returns OFTrue if this connection is a transparent TCP connection,

* OFFalse if the connection is a secure connection.

* @param acse_timeout timeout for ACSE operations, in seconds

* @return EC_Normal if successful, an error code otherwise

*/

/** enable user-defined transport layer. This method is needed when

* the network association should use a non-default transport layer

const char *abstractSyntax,

E_TransferSyntax preferredTransferSyntax,

T_DIMSE_BlockingMode blockMode,

Uint32 maxReceivePDULength,

OFBool secureConnection,

OFBool abortAssociation,

int repeatCount,

const char *abstractSyntax,

T_DIMSE_BlockingMode blockMode,

OFBool extractResponsesToFile,

int cancelAfterNResponses,

OFList<OFString> *overrideKeys,

/* in */

T_ASC_Association *assoc, DIC_US msgId,

/* blocking info for response */

/* out */

DIC_US *status, DcmDataset **statusDetail);

const char *imageFileName, DcmDataset *imageDataSet,

DIMSE_StoreUserCallback callback, void *callbackData,

/* blocking info for response */

/* out */

T_DIMSE_C_StoreRSP *response,

DcmDataset **statusDetail,

DcmDataset **imageDataSet,

DIMSE_StoreProviderCallback callback, void *callbackData,

/* blocking info for data set */

DCMTK_DCMNET_EXPORT OFCondition

DIMSE_sendStoreResponse(T_ASC_Association * assoc,

T_DIMSE_C_FindRQ *request, DcmDataset *requestIdentifiers,

DIMSE_FindUserCallback callback, void *callbackData,

/* blocking info for response */

/* out */

T_DIMSE_C_FindRSP *response, DcmDataset **statusDetail);

T_DIMSE_C_FindRQ *request,

DIMSE_FindProviderCallback callback, void *callbackData,

/* blocking info for data set */

DCMTK_DCMNET_EXPORT OFCondition

DIMSE_sendFindResponse(T_ASC_Association * assoc,

DcmDataset *requestIdentifiers,

DIMSE_MoveUserCallback callback, void *callbackData,

/* blocking info for response */

/* sub-operation provider callback */

T_ASC_Network *net,

DIMSE_SubOpProviderCallback subOpCallback, void *subOpCallbackData,

T_DIMSE_C_MoveRQ *request,

DIMSE_MoveProviderCallback callback, void *callbackData,

/* blocking info for data set */

DCMTK_DCMNET_EXPORT OFCondition

DIMSE_sendMoveResponse(T_ASC_Association * assoc,

DcmDataset *requestIdentifiers,

DIMSE_GetUserCallback callback, void *callbackData,

/* blocking info for response */

/* sub-operation provider callback */

T_ASC_Network *net,

DIMSE_SubOpProviderCallback subOpCallback, void *subOpCallbackData,

T_DIMSE_C_GetRQ *request,

DIMSE_GetProviderCallback callback, void *callbackData,

/* blocking info for data set */

DCMTK_DCMNET_EXPORT OFCondition

DIMSE_sendGetResponse(T_ASC_Association * assoc,

DCMTK_DCMNET_EXPORT OFCondition

DIMSE_receiveCommand(T_ASC_Association *association,

T_DIMSE_BlockingMode blocking,

T_ASC_PresentationContextID *presID,

T_DIMSE_Message *msg,

DcmDataset **statusDetail,

DCMTK_DCMNET_EXPORT OFCondition

DIMSE_receiveDataSetInMemory(T_ASC_Association *association,

T_DIMSE_BlockingMode blocking,

T_ASC_PresentationContextID *presID,

DcmDataset **dataObject,

DIMSE_ProgressCallback callback,

DCMTK_DCMNET_EXPORT OFCondition

DIMSE_receiveDataSetInFile(T_ASC_Association *assoc,

T_ASC_PresentationContextID *presID,

DcmOutputStream *filestream,

DIMSE_ProgressCallback callback, void *callbackData);

DCMTK_DCMNET_EXPORT OFCondition

DIMSE_ignoreDataSet( T_ASC_Association * assoc,

T_DIMSE_BlockingMode blocking,

DIC_UL * bytesRead,

DIC_UL * pdvCount);

/** Global timeout in seconds for connecting to remote hosts.

* Default value is -1, which selects infinite timeout, i.e. blocking connect().

*/

/** This global flag allows to set an already opened socket file descriptor which

* will be used by dcmnet the next time receiveTransportConnectionTCP() is called.

DUL_InitializeNetwork(

const char *mode,

void *param,

unsigned long

options,

DUL_NETWORKKEY ** network);

DUL_ReceiveAssociationRQ(

DUL_NETWORKKEY ** network,

DUL_BLOCKOPTIONS block,

DUL_ASSOCIATESERVICEPARAMETERS * parameters,

DUL_ASSOCIATIONKEY ** association,

int activatePDUStorage);

DUL_RequestAssociation(

DUL_NETWORKKEY ** network,

DUL_BLOCKOPTIONS block,

DUL_ASSOCIATESERVICEPARAMETERS * params,

DUL_ASSOCIATIONKEY ** association,

int activatePDUStorage);

*/

DCMTK_DCMNET_EXPORT OFCondition

DUL_ReadPDVs(DUL_ASSOCIATIONKEY ** association,

DCMTK_DCMNET_EXPORT OFCondition

DUL_WritePDVs(DUL_ASSOCIATIONKEY ** association,

DUL_PDVLIST * pdvList);

*/

DCMTK_DCMNET_EXPORT OFBool

DCMTK_DCMNET_EXPORT DcmNativeSocketType DUL_networkSocket(DUL_NETWORKKEY * callerNet);

DCMTK_DCMNET_EXPORT OFBool

/*

* functions allowing to retrieve raw A-ASSOCIATE PDUs from the DUL layer

* for DIMSE blocking mode messaging (see also setDIMSEBlockingMode().

* @param dimseTimeout [in] DIMSE receive timeout in seconds

*/

/** Set the timeout used during ACSE messaging protocol.

* @param acseTimeout [in] ACSE timeout in seconds.

*/

/** Set the timeout that should be waited for connection requests.

* Only relevant in non-blocking mode (default).

* @param timeout [in] TCP/IP connection timeout in seconds.

*/

/** Set whether to show presentation contexts in verbose or debug mode

* @param mode [in] Show presentation contexts in verbose mode if OFTrue. By default, the

/** Returns DIMSE timeout (only applicable in blocking mode)

* @return DIMSE timeout in seconds

*/

/** Returns ACSE timeout

* @return ACSE timeout in seconds

*/

/** Returns connection timeout

* @return TCP/IP connection timeout in seconds

*/

/** Returns the verbose presentation context mode configured specifying whether details on

* the presentation contexts (negotiated during association setup) should be shown in

/// Timeout for DIMSE operations in seconds. Maximum time in DIMSE non-blocking mode to

/// wait for incoming DIMSE data.

/// Timeout for ACSE operations in seconds. Maximum time during association negotiation

/// which is given for the SCU to follow the ACSE protocol.

/// Verbose PC mode. Flags specifying whether details on the presentation contexts

/// (negotiated during association setup) should be shown in verbose or debug mode.

/// Timeout in seconds that should be waited for an incoming TCP/IP connection until

/// the call returns. It is only relevant if the the SCP is set to non-blocking

/// connection mode. Otherwise, the timeout is ignored. Default is 1000 seconds.

/// If set, the AE title as received in the request (called AE title) is used in response

/// (default: OFTrue).

/// Process ID

int processId;

/// Start time

/// Indicator if process has storage ability

OFBool hasStorageAbility;

};

* for DIMSE blocking mode messaging (see also setDIMSEBlockingMode()).

* @param dimseTimeout [in] DIMSE receive timeout in seconds

*/

/** Set the timeout used during ACSE messaging protocol.

* @param acseTimeout [in] ACSE timeout in seconds.

*/

/** Set the timeout that should be waited for connection requests.

* Only relevant in non-blocking mode (default).

* @param timeout [in] TCP/IP connection timeout in seconds.

*/

/** Set whether to show presentation contexts in verbose or debug mode

* @param mode [in] Show presentation contexts in verbose mode if OFTrue. By default, the

/** Returns DIMSE timeout (only applicable in blocking mode)

* @return DIMSE timeout in seconds

*/

/** Returns ACSE timeout

* @return ACSE timeout in seconds

*/

/** Returns connection timeout

* @return TCP/IP connection timeout in seconds

*/

/** Returns the verbose presentation context mode configured specifying whether details on

* the presentation contexts (negotiated during association setup) should be shown in

T_DIMSE_Message *message,

DcmDataset **statusDetail,

DcmDataset **commandSet = NULL,

/** Receive one dataset (of instance data) via network from another DICOM application

* @param presID [out] Contains in the end the ID of the presentation context

*/

virtual OFCondition handleEVENTREPORTRequest(DcmDataset *&reqDataset,

Uint16 &eventTypeID,

/** Closes the association created by this SCU. Also resets the current association.

* @deprecated The use of this method is deprecated. Please use releaseAssociation()

* will try to read data from the incoming socket stream

* for the number of seconds configured.

*/

/** Set timeout for receiving ACSE messages

* @param acseTimeout [in] ACSE timeout in seconds used by timer for message timeouts

* during association negotiation

*/

/** Set global timeout for connecting to the SCP. Note that this is a global

* DCMTK setting i.e. it affects all code that uses dcmnet to start a DICOM

* @param connectionTimeout [in] Connection Timeout in seconds when connecting

* to SCPs. -1 will wait forever (blocking mode).

*/

/** Set an association configuration file and profile to be used

* the incoming socket stream for the number of seconds configured.

* @return The DIMSE timeout (in seconds) configured

*/

/** Returns ACSE timeout in seconds used by timer for message timeouts during

* association negotiation.

* @return The ACSE timeout (in seconds) configured

*/

/** Returns the timeout configured defining how long SCU will wait for the

* SCP when requesting an association. -1 means infinite waiting (blocking),

* 0 means no waiting at all. Note that this is currently a global DCMTK setting.

* @return The connection timeout (in seconds)

*/

/** Returns the storage directory used for storing objects received with C-STORE requests

* in the context of C-GET sessions. Default is empty string which refers to the current

T_DIMSE_Message *msg,

DcmDataset **statusDetail,

DcmDataset **commandSet = NULL,

/** Receives one dataset (of instance data) via network from another DICOM application

* @param presID [out] Contains in the end the ID of the presentation context which

Uint16 m_peerPort;

/// DIMSE timeout (default: unlimited)

/// ACSE timeout (default: 30 seconds)

/// Storage directory for objects received with C-STORE due to a running

/// C-GET session. By default, the received objects are stored in the current

OFCondition

ASC_initializeNetwork(T_ASC_NetworkRole role,

int acceptorPort,

T_ASC_Network ** network,

unsigned long options)

{

OFBool

ASC_selectReadableAssociation(T_ASC_Association* assocs[],

{

if (assocCount <= 0) return OFFalse;

}

OFBool

{

return DUL_dataWaiting(association->DULassociation, timeout);

}

OFBool

{

#ifdef _WIN32

SOCKET s;

unsigned long *associatePDUlength,

OFBool useSecureLayer,

DUL_BLOCKOPTIONS block,

{

T_ASC_Parameters *params;

DUL_ASSOCIATIONKEY *DULassociation;

void **associatePDU,

unsigned long *associatePDUlength,

DUL_BLOCKOPTIONS block,

{

OFCondition cond = EC_Normal;

long sendLen;

OFCondition

{

/* if already dead don't worry */

if (association == NULL) return EC_Normal;

#endif

};

DcmTransportConnection::DcmTransportConnection(DcmNativeSocketType openSocket)

: theSocket(openSocket)

#warning The macro DISABLE_SEND_TIMEOUT is not supported anymore. See "macros.txt" for details.

#endif

/* get global timeout for the send() function */

if (sendTimeout >= 0)

{

if (sendTimeout == 0)

DCMNET_DEBUG("setting network send timeout to " << sendTimeout << " seconds");

#ifdef HAVE_WINSOCK_H

// for Windows, specify send timeout in milliseconds

if (setsockopt(theSocket, SOL_SOCKET, SO_SNDTIMEO, (char *) &timeoutVal, sizeof(timeoutVal)) < 0)

#else

// for other systems, specify send timeout as timeval struct

#warning The macro DISABLE_RECV_TIMEOUT is not supported anymore. See "macros.txt" for details.

#endif

/* get global timeout for the recv() function */

if (recvTimeout >= 0)

{

if (recvTimeout == 0)

DCMNET_DEBUG("setting network receive timeout to " << recvTimeout << " seconds");

#ifdef HAVE_WINSOCK_H

// for Windows, specify receive timeout in milliseconds

if (setsockopt(theSocket, SOL_SOCKET, SO_RCVTIMEO, (char *) &timeoutVal, sizeof(timeoutVal)) < 0)

#else

// for other systems, specify receive timeout as timeval struct

{

}

{

int numberOfRounds = timeout+1;

if (numberOfRounds < 0) numberOfRounds = 0xFFFF; /* a long time */

return found;

}

{

#ifdef _WIN32

fd_set fdset;

FD_ZERO(&fdset);

OFTimer timer;

for (i=0; i<connCount; i++)

{

// check for interrupt call

if (OFStandard::getLastNetworkErrorCode().value() == DCMNET_EINTR)

{

if (diff < timeout)

{

lTimeout = timeout - diff;

return OFTrue;

}

{

OFBool canUseFastMode = OFTrue;

for (int i=0; i<connCount; i++)

return 0;

}

{

struct timeval t;

fd_set fdset;

int nfound;

OFTimer timer;

FD_ZERO(&fdset);

dropNetwork();

}

{

return ASC_initializeNetwork(NET_REQUESTOR, 0, acse_timeout, &net_);

}

const char *abstractSyntax,

E_TransferSyntax preferredTransferSyntax,

T_DIMSE_BlockingMode blockMode,

Uint32 maxReceivePDULength,

OFBool secureConnection,

OFBool abortAssociation,

int repeatCount,

const char *abstractSyntax,

T_DIMSE_BlockingMode blockMode,

OFBool extractResponsesToFile,

int cancelAfterNResponses,

OFList<OFString> *overrideKeys,

/* in */

T_ASC_Association *assoc, DIC_US msgId,

/* blocking info for response */

/* out */

DIC_US *status, DcmDataset **statusDetail)

{

T_ASC_PresentationContextID presID,

T_DIMSE_C_FindRQ *request, DcmDataset *requestIdentifiers,

DIMSE_FindUserCallback callback, void *callbackData,

T_DIMSE_C_FindRSP *response, DcmDataset **statusDetail)

/*

* This function sends a C-FIND-RQ message and data set information containing the given

T_ASC_PresentationContextID presIdCmd,

T_DIMSE_C_FindRQ *request,

DIMSE_FindProviderCallback callback, void *callbackData,

/*

* This function receives a data set which represents the search mask over the network and

* stores this data in memory. Then, it tries to select corresponding records which match the

static int

selectReadable(T_ASC_Association *assoc,

T_ASC_Network *net, T_ASC_Association *subAssoc,

{

T_ASC_Association *assocList[2];

int assocCount = 0;

DcmDataset *requestIdentifiers,

DIMSE_GetUserCallback callback, void *callbackData,

/* blocking info for response */

/* sub-operation provider callback */

T_ASC_Network *net,

DIMSE_SubOpProviderCallback subOpCallback, void *subOpCallbackData,

T_DIMSE_C_GetRQ *request,

DIMSE_GetProviderCallback callback, void *callbackData,

/* blocking info for data set */

{

T_ASC_PresentationContextID presIdData;

DcmDataset *statusDetail = NULL;

T_ASC_Association *assoc,

T_ASC_Network *net,

T_ASC_Association *subAssoc,

{

T_ASC_Association *assocList[2];

int assocCount = 0;

DcmDataset *requestIdentifiers,

DIMSE_MoveUserCallback callback, void *callbackData,

/* blocking info for response */

/* sub-operation provider callback */

T_ASC_Network *net,

DIMSE_SubOpProviderCallback subOpCallback, void *subOpCallbackData,

T_DIMSE_C_MoveRQ *request,

DIMSE_MoveProviderCallback callback, void *callbackData,

/* blocking info for data set */

{

OFCondition cond = EC_Normal;

T_ASC_PresentationContextID presIdData;

DIMSE_readNextPDV(

T_ASC_Association *assoc,

T_DIMSE_BlockingMode blocking,

DUL_PDV *pdv)

/*

* This function returns the next PDV which was (earlier or just now) received on the incoming

OFCondition DIMSE_ignoreDataSet(

T_ASC_Association *assoc,

T_DIMSE_BlockingMode blocking,

DIC_UL *bytesRead,

DIC_UL *pdvCount)

{

DIMSE_receiveCommand(

T_ASC_Association *assoc,

T_DIMSE_BlockingMode blocking,

T_ASC_PresentationContextID*presID,

T_DIMSE_Message *msg,

DcmDataset **statusDetail,

DIMSE_receiveDataSetInFile(

T_ASC_Association *assoc,

T_DIMSE_BlockingMode blocking,

T_ASC_PresentationContextID *presID,

DcmOutputStream *filestream,

DIMSE_ProgressCallback callback,

DIMSE_receiveDataSetInMemory(

T_ASC_Association *assoc,

T_DIMSE_BlockingMode blocking,

T_ASC_PresentationContextID *presID,

DcmDataset **dataObject,

DIMSE_ProgressCallback callback,

T_DIMSE_C_StoreRQ *request,

const char *imageFileName, DcmDataset *imageDataSet,

DIMSE_StoreUserCallback callback, void *callbackData,

T_DIMSE_C_StoreRSP *response,

DcmDataset **statusDetail,

T_DIMSE_DetectedCancelParameters *checkForCancelParams,

const char* imageFileName, int writeMetaheader,

DcmDataset **imageDataSet,

DIMSE_StoreProviderCallback callback, void *callbackData,

/*

* This function receives a data set over the network and either stores this data in a file (exactly as it was

* received) or it stores this data in memory. Before, during and after the process of receiving data, the callback

#include "dcmtk/ofstd/ofnetdb.h"

OFGlobal<OFBool> dcmDisableGethostbyaddr(OFFalse);

OFGlobal<DcmNativeSocketType> dcmExternalSocketHandle(DCMNET_INVALID_SOCKET);

OFGlobal<const char *> dcmTCPWrapperDaemonName((const char *)NULL);

OFGlobal<unsigned long> dcmEnableBackwardCompatibility(0);

static int networkInitialized = 0;

static OFCondition

PRIVATE_NETWORKKEY ** k);

static OFCondition

createAssociationKey(PRIVATE_NETWORKKEY ** network, const char *node,

static OFCondition

receiveTransportConnection(PRIVATE_NETWORKKEY ** network,

DUL_BLOCKOPTIONS block,

DUL_ASSOCIATESERVICEPARAMETERS * params,

PRIVATE_ASSOCIATIONKEY ** association);

static OFCondition

receiveTransportConnectionTCP(PRIVATE_NETWORKKEY ** network,

DUL_BLOCKOPTIONS block,

DUL_ASSOCIATESERVICEPARAMETERS * params,

PRIVATE_ASSOCIATIONKEY ** association);

*/

OFCondition

DUL_InitializeNetwork(const char *mode,

DUL_NETWORKKEY ** networkKey)

{

// default return value if something goes wrong

DUL_RequestAssociation(

DUL_NETWORKKEY ** callerNetworkKey,

DUL_BLOCKOPTIONS block,

DUL_ASSOCIATESERVICEPARAMETERS * params,

DUL_ASSOCIATIONKEY ** callerAssociation,

int activatePDUStorage)

DUL_ReceiveAssociationRQ(

DUL_NETWORKKEY ** callerNetworkKey,

DUL_BLOCKOPTIONS block,

DUL_ASSOCIATESERVICEPARAMETERS * params,

DUL_ASSOCIATIONKEY ** callerAssociation,

int activatePDUStorage)

*/

OFCondition

DUL_ReadPDVs(DUL_ASSOCIATIONKEY ** callerAssociation,

{

PRIVATE_ASSOCIATIONKEY

** association;

static OFCondition

receiveTransportConnection(PRIVATE_NETWORKKEY ** network,

DUL_BLOCKOPTIONS block,

DUL_ASSOCIATESERVICEPARAMETERS * params,

PRIVATE_ASSOCIATIONKEY ** association)

{

static OFCondition

receiveTransportConnectionTCP(PRIVATE_NETWORKKEY ** network,

DUL_BLOCKOPTIONS block,

DUL_ASSOCIATESERVICEPARAMETERS * params,

PRIVATE_ASSOCIATIONKEY ** association)

{

*/

static OFCondition

createNetworkKey(const char *mode,

{

if (strcmp(mode, AE_REQUESTOR) != 0 &&

strcmp(mode, AE_ACCEPTOR) != 0 &&

#include "dcmtk/dcmnet/diutil.h"

OFBool

{

PRIVATE_ASSOCIATIONKEY * association = (PRIVATE_ASSOCIATIONKEY *)callerAssociation;

if ((association==NULL)||(association->connection == NULL)) return OFFalse;

}

OFBool

{

PRIVATE_NETWORKKEY *net;

DcmNativeSocketType s;

static OFCondition

readPDUHead(PRIVATE_ASSOCIATIONKEY ** association,

unsigned char *buffer, unsigned long maxlength,

unsigned char *PDUtype, unsigned char *PDUreserved,

unsigned long *PDULength);

static OFCondition

readPDU(PRIVATE_ASSOCIATIONKEY ** association, DUL_BLOCKOPTIONS block,

unsigned char *pduType, unsigned char *pduReserved,

unsigned long *pduLength);

static OFCondition

readPDUBody(PRIVATE_ASSOCIATIONKEY ** association,

unsigned char *buffer, unsigned long maxLength,

unsigned char *pduType, unsigned char *pduReserved,

unsigned long *pduLength);

static OFCondition

readPDUHeadTCP(PRIVATE_ASSOCIATIONKEY ** association,

unsigned char *buffer, unsigned long maxLength,

unsigned char *PDUtype, unsigned char *PDUreserved,

unsigned long *PDULength);

static OFCondition

readPDUBodyTCP(PRIVATE_ASSOCIATIONKEY ** association,

unsigned char *buffer, unsigned long maxLength,

unsigned char *pduType, unsigned char *pduReserved,

unsigned long *pduLength);

static OFCondition

static OFString dump_pdu(const char *type, void *buffer, unsigned long length);

server.sin_port = (unsigned short) htons(port);

// get global connection timeout

#ifdef HAVE_WINSOCK_H

u_long arg = TRUE;

OFCondition

PRV_NextPDUType(PRIVATE_ASSOCIATIONKEY ** association, DUL_BLOCKOPTIONS block,

{

OFCondition cond = EC_Normal;

static OFCondition

readPDU(PRIVATE_ASSOCIATIONKEY ** association, DUL_BLOCKOPTIONS block,

unsigned char *pduType, unsigned char *pduReserved,

unsigned long *pduLength)

{

static OFCondition

readPDUHead(PRIVATE_ASSOCIATIONKEY ** association,

unsigned char *buffer, unsigned long maxLength,

unsigned char *PDUType, unsigned char *PDUReserved,

unsigned long *PDULength)

{

static OFCondition

readPDUBody(PRIVATE_ASSOCIATIONKEY ** association,

unsigned char *buffer, unsigned long maxLength,

unsigned char *pduType, unsigned char *pduReserved,

unsigned long *pduLength)

static OFCondition

readPDUHeadTCP(PRIVATE_ASSOCIATIONKEY ** association,

unsigned char *buffer, unsigned long maxLength,

unsigned char *type, unsigned char *reserved, unsigned long *pduLength)

{

unsigned long

static OFCondition

readPDUBodyTCP(PRIVATE_ASSOCIATIONKEY ** association,

unsigned char *buffer, unsigned long maxLength,

unsigned char *pduType, unsigned char *pduReserved,

unsigned long *pduLength)

static OFCondition

{

unsigned char *b;

int bytesRead;

if (block == DUL_NOBLOCK)

{

/* determine remaining time to wait */