C#
C++/CLI
public static void Shutdown()
public:
static void Shutdown();
This method shuts down the LEADTOOLS DICOM DLL. This must be the last method that is called to free up any memory that is associated with the DICOM DLL. No other DICOM network operations method can be used after Shutdown is called. If you wish to use other methods after calling this method, Startup must be called again. You must initialize the LEADTOOLS DICOM DLL using Startup before calling this method.
This is a comprehensive sample that shows how to process a DICOM C-Get operation on both the SCP (server) and the SCU (client) sides.
using Leadtools;
using Leadtools.Dicom;
[StructLayout(LayoutKind.Sequential)]
public struct MSG
{
public IntPtr hwnd;
public uint message;
public IntPtr wParam;
public IntPtr lParam;
public uint time;
public System.Drawing.Point p;
}
public enum WaitReturn
{
Complete,
Timeout,
}
class Utils
{
[DllImport("user32.dll")]
[return: MarshalAs(UnmanagedType.Bool)]
static extern bool PeekMessage(out MSG lpMsg, IntPtr hWnd,
uint wMsgFilterMin, uint wMsgFilterMax,
uint wRemoveMsg);
[DllImport("user32.dll")]
static extern bool TranslateMessage([In] ref MSG lpMsg);
[DllImport("user32.dll")]
static extern IntPtr DispatchMessage([In] ref MSG lpmsg);
const uint PM_REMOVE = 1;
public static WaitReturn WaitForComplete(double mill, WaitHandle wh)
{
TimeSpan goal = new TimeSpan(DateTime.Now.AddMilliseconds(mill).Ticks);
do
{
MSG msg = new MSG();
if (PeekMessage(out msg, IntPtr.Zero, 0, 0, PM_REMOVE))
{
TranslateMessage(ref msg);
DispatchMessage(ref msg);
}
if (wh.WaitOne(new TimeSpan(0, 0, 0), false))
{
return WaitReturn.Complete;
}
if (goal.CompareTo(new TimeSpan(DateTime.Now.Ticks)) < 0)
{
return WaitReturn.Timeout;
}
} while (true);
}
}
class Client : DicomNet
{
DicomExceptionCode _LastError = DicomExceptionCode.Success;
AutoResetEvent waitEvent = new AutoResetEvent(false);
public Client()
: base(null, DicomNetSecurityMode.None)
{
}
public DicomExceptionCode LastError
{
get
{
return _LastError;
}
}
public bool Wait()
{
WaitReturn ret;
_LastError = DicomExceptionCode.Success;
ret = Utils.WaitForComplete((5 * 60) * 1000, waitEvent);
return (ret == WaitReturn.Complete);
}
protected override void OnConnect(DicomExceptionCode error)
{
_LastError = error;
waitEvent.Set();
}
protected override void OnReceiveAssociateAccept(DicomAssociate association)
{
waitEvent.Set();
}
protected override void OnReceiveCGetResponse(byte presentationID, int messageID, string affectedClass, DicomCommandStatusType status, int remaining, int completed, int failed, int warning, DicomDataSet dataSet)
{
StackTrace st = new StackTrace();
Debug.WriteLine(st.GetFrame(0).GetMethod().DeclaringType.Name +
":" + st.GetFrame(0).GetMethod().Name);
Debug.Assert(messageID == 1, "Invalid message id. Should be 1");
Debug.Assert(affectedClass == DicomUidType.PatientRootQueryGet, "Affected class should be PatientRootQueryMove: " + DicomUidType.PatientRootQueryMove);
Debug.Assert(status == DicomCommandStatusType.Success, "Status should be success");
Debug.Assert(remaining == 0, "Remaining should be 0");
Debug.Assert(completed == 1, "Completed should be 1");
Debug.Assert(failed == 0, "Failed should be 0");
Debug.Assert(warning == 0, "Warning should be 0");
waitEvent.Set();
}
}
class ServerConnection : DicomNet
{
public ServerConnection()
: base(null, DicomNetSecurityMode.None)
{
}
protected override void OnReceiveAssociateRequest(DicomAssociate association)
{
DicomAssociate retAssociation = new DicomAssociate(false);
Debug.Assert(association.Called == "ServerTest", "Called AETitle should be ServerTest");
Debug.Assert(association.Calling == "ClientTest", "Calling AETitle should be ClientTest");
Debug.Assert(association.ImplementClass == "1.2.840.114257.1", "Implementation class should be 1.2.840.114257.1");
Debug.Assert(association.ImplementationVersionName == "1", "Implementation version should be 1");
Debug.Assert(association.MaxLength == 0x100000, "Max length should be 0x100000");
Debug.Assert(association.GetAbstract(1) == DicomUidType.VerificationClass, "Presentation index 1 should be " + DicomUidType.VerificationClass);
Debug.Assert(association.GetTransfer(1, 0) == DicomUidType.ImplicitVRLittleEndian, "Abstract Syntax (1,0) should be " + DicomUidType.ImplicitVRLittleEndian);
//
// Build our Association Accept
//
retAssociation.Called = association.Called;
retAssociation.Calling = association.Calling;
retAssociation.ImplementClass = association.ImplementClass;
retAssociation.ImplementationVersionName = association.ImplementationVersionName;
for (int x = 0; x < association.PresentationContextCount; x++)
{
byte id = association.GetPresentationContextID(x);
string abSyntax = association.GetAbstract(id);
string trSyntax = DicomUidType.ImplicitVRLittleEndian;
retAssociation.AddPresentationContext(id, 0, abSyntax);
if (association.GetTransferCount(id) > 0)
{
trSyntax = association.GetTransfer(id, 0);
}
retAssociation.AddTransfer(id, trSyntax);
}
SendAssociateAccept(retAssociation);
}
protected override void OnReceiveCGetRequest(byte presentationID, int messageID, string affectedClass, DicomCommandPriorityType priority, DicomDataSet dataSet)
{
DicomElement element;
StackTrace st = new StackTrace();
Debug.WriteLine(st.GetFrame(0).GetMethod().DeclaringType.Name +
":" + st.GetFrame(0).GetMethod().Name);
Debug.Assert(dataSet != null, "Dataset should not be null");
Debug.Assert(priority == DicomCommandPriorityType.Medium, "Priority should be medium");
//
// Check dataset
//
element = dataSet.FindFirstElement(null, DicomTag.QueryRetrieveLevel, true);
Debug.Assert(element != null, "Element (QueryRetrieveLevel) should not be null");
Debug.Assert(dataSet.GetStringValue(element, 0) == "PATIENT", "QueryRetrieveLevel should be PATIENT");
element = dataSet.FindFirstElement(null, DicomTag.PatientName, true);
Debug.Assert(element != null, "Element (PatientName) should not be null");
Debug.Assert(dataSet.GetStringValue(element, 0) == "TEST", "PatientName should be TEST");
SendCGetResponse(presentationID, messageID, affectedClass, DicomCommandStatusType.Success, 0, 1, 0, 0, dataSet);
}
}
class Server : DicomNet
{
ServerConnection client;
public Server()
: base(null, DicomNetSecurityMode.None)
{
}
protected override void OnAccept(DicomExceptionCode error)
{
client = new ServerConnection();
Accept(client);
}
}
public void SendCGetRequestSample()
{
DicomEngine.Startup();
DicomNet.Startup();
using (Server server = new Server())
{
using (Client client = new Client())
{
//
// Connect to server
//
server.Listen("127.0.0.1", 104, 1); // start server
client.Connect(null, 1000, "127.0.0.1", 104); // connect to server
if (!client.Wait()) // wait for connection to finish
{
Debug.Fail("Connection timed out");
}
Debug.Assert(client.LastError == DicomExceptionCode.Success, "Connection failed");
Debug.Assert(client.IsConnected(), "Client not connected");
//
// Send associate request
//
DicomAssociate associate = new DicomAssociate(true);
associate.Called = "ServerTest";
associate.Calling = "ClientTest";
associate.ImplementClass = "1.2.840.114257.1";
associate.ImplementationVersionName = "1";
associate.MaxLength = 0x100000;
associate.AddPresentationContext(1, 0, DicomUidType.VerificationClass);
associate.AddTransfer(1, DicomUidType.ImplicitVRLittleEndian);
associate.AddPresentationContext(3, 0, DicomUidType.PatientRootQueryGet);
associate.AddTransfer(3, DicomUidType.ImplicitVRLittleEndian);
client.SendAssociateRequest(associate);
if (!client.Wait()) // wait for connection to finish
{
Debug.Fail("SendAssociateRequest timed out");
}
byte pid = client.Association.FindAbstract(DicomUidType.PatientRootQueryGet);
DicomDataSet ds = new DicomDataSet();
DicomElement element;
//
// Set up the get parameters
//
ds.Reset();
ds.Initialize(DicomClassType.PatientRootQueryPatient, DicomDataSetInitializeType.ExplicitVRLittleEndian);
element = ds.FindFirstElement(null, DicomTag.QueryRetrieveLevel, true);
if (element == null)
{
element = ds.InsertElement(null, false, DicomTag.QueryRetrieveLevel, DicomVRType.UN, false, 0);
}
ds.SetStringValue(element, "PATIENT", DicomCharacterSetType.Default);
element = ds.FindFirstElement(null, DicomTag.PatientName, true);
if (element == null)
{
element = ds.InsertElement(null, false, DicomTag.PatientName, DicomVRType.UN, false, 0);
}
ds.SetStringValue(element, "TEST", DicomCharacterSetType.Default);
client.SendCGetRequest(pid, 1, DicomUidType.PatientRootQueryGet, DicomCommandPriorityType.Medium, ds);
if (!client.Wait()) // wait for CGet to finish
{
Debug.Fail("SendCGetRequest timed out");
}
client.CloseForced(true);
}
server.CloseForced(true);
}
DicomEngine.Shutdown();
DicomNet.Shutdown();
}