1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180
|
/*
*
* Copyright (C) 1994-2024, OFFIS e.V.
* All rights reserved. See COPYRIGHT file for details.
*
* This software and supporting documentation were partly developed by
*
* OFFIS e.V.
* R&D Division Health
* Escherweg 2
* D-26121 Oldenburg, Germany
*
* For further copyrights, see the following paragraphs.
*
*/
/*
** Copyright (C) 1993/1994, OFFIS, Oldenburg University and CERIUM
**
** This software and supporting documentation were
** developed by
**
** Institut OFFIS
** Bereich Kommunikationssysteme
** Westerstr. 10-12
** 26121 Oldenburg, Germany
**
** Fachbereich Informatik
** Abteilung Prozessinformatik
** Carl von Ossietzky Universitaet Oldenburg
** Ammerlaender Heerstr. 114-118
** 26111 Oldenburg, Germany
**
** CERIUM
** Laboratoire SIM
** Faculte de Medecine
** 2 Avenue du Pr. Leon Bernard
** 35043 Rennes Cedex, France
**
** for CEN/TC251/WG4 as a contribution to the Radiological
** Society of North America (RSNA) 1993 Digital Imaging and
** Communications in Medicine (DICOM) Demonstration.
**
** THIS SOFTWARE IS MADE AVAILABLE, AS IS, AND NEITHER OFFIS,
** OLDENBURG UNIVERSITY NOR CERIUM MAKE ANY WARRANTY REGARDING
** THE SOFTWARE, ITS PERFORMANCE, ITS MERCHANTABILITY OR
** FITNESS FOR ANY PARTICULAR USE, FREEDOM FROM ANY COMPUTER
** DISEASES OR ITS CONFORMITY TO ANY SPECIFICATION. THE
** ENTIRE RISK AS TO QUALITY AND PERFORMANCE OF THE SOFTWARE
** IS WITH THE USER.
**
** Copyright of the software and supporting documentation
** is, unless otherwise stated, jointly owned by OFFIS,
** Oldenburg University and CERIUM and free access is hereby
** granted as a license to use this software, copy this
** software and prepare derivative works based upon this
** software. However, any distribution of this software
** source code or supporting documentation or derivative
** works (source code and supporting documentation) must
** include the three paragraphs of this copyright notice.
**
*/
/*
**
** Author: Andrew Hewett Created: 03-08-93
**
** Module: dulextra
**
** Purpose:
** Supplementary DUL functions.
**
*/
#include "dcmtk/config/osconfig.h" /* make sure OS specific configuration is included first */
#ifdef HAVE_WINDOWS_H
// on Windows, we need Winsock2 for network functions
#include <winsock2.h>
#endif
#ifdef HAVE_SYS_TIME_H
#include <sys/time.h>
#endif
#ifdef HAVE_SYS_TYPES_H
#include <sys/types.h>
#endif
#ifdef HAVE_SYS_SELECT_H
#include <sys/select.h>
#endif
#ifdef DCMTK_HAVE_POLL
#include <poll.h>
#endif
#include "dcmtk/dcmnet/dicom.h"
#include "dcmtk/dcmnet/lst.h"
#include "dcmtk/dcmnet/cond.h"
#include "dcmtk/dcmnet/dul.h"
#include "dcmtk/dcmnet/dulstruc.h"
#include "dulpriv.h"
#include "dcmtk/dcmnet/dcmtrans.h"
#include "dcmtk/dcmnet/diutil.h"
OFBool
DUL_dataWaiting(DUL_ASSOCIATIONKEY * callerAssociation, int timeout)
{
PRIVATE_ASSOCIATIONKEY * association = (PRIVATE_ASSOCIATIONKEY *)callerAssociation;
if ((association==NULL)||(association->connection == NULL)) return OFFalse;
return association->connection->networkDataAvailable(timeout);
}
DcmTransportConnection *DUL_getTransportConnection(DUL_ASSOCIATIONKEY * callerAssociation)
{
if (callerAssociation == NULL) return NULL;
else return ((PRIVATE_ASSOCIATIONKEY *)callerAssociation)->connection;
}
DcmNativeSocketType DUL_networkSocket(DUL_NETWORKKEY * callerNet)
{
if (callerNet == NULL) return DCMNET_INVALID_SOCKET;
PRIVATE_NETWORKKEY *net = (PRIVATE_NETWORKKEY*)callerNet;
return net->networkSpecific.TCP.listenSocket;
}
OFBool
DUL_associationWaiting(DUL_NETWORKKEY * callerNet, int timeout)
{
PRIVATE_NETWORKKEY *net;
DcmNativeSocketType s;
OFBool assocWaiting = OFFalse;
struct timeval t;
int nfound;
if (callerNet == NULL)
return OFFalse;
net = (PRIVATE_NETWORKKEY*)callerNet;
s = net->networkSpecific.TCP.listenSocket;
#ifndef DCMTK_HAVE_POLL
fd_set fdset;
FD_ZERO(&fdset);
FD_SET(s, &fdset);
#endif
t.tv_sec = timeout;
t.tv_usec = 0;
#ifdef DCMTK_HAVE_POLL
struct pollfd pfd[] =
{
{ s, POLLIN, 0 }
};
nfound = poll(pfd, 1, t.tv_sec*1000+(t.tv_usec/1000));
#else
// This is safe because on Windows the first select() parameter is ignored anyway
nfound = select(OFstatic_cast(int, s + 1), &fdset, NULL, NULL, &t);
#endif /* DCMTK_HAVE_POLL */
if (DCM_dcmnetLogger.isEnabledFor(OFLogger::DEBUG_LOG_LEVEL))
{
DU_logSelectResult(nfound);
}
if (nfound <= 0) assocWaiting = OFFalse;
else
{
#ifdef DCMTK_HAVE_POLL
if (pfd[0].revents & POLLIN)
assocWaiting = OFTrue;
else /* This one should not really happen */
assocWaiting = OFFalse;
#else
if (FD_ISSET(s, &fdset))
assocWaiting = OFTrue;
else /* This one should not really happen */
assocWaiting = OFFalse;
#endif
}
return assocWaiting;
}
|