changeset 3823:897ca3103253 transcoding

new class: DicomStoreUserConnection
author Sebastien Jodogne <s.jodogne@gmail.com>
date Fri, 10 Apr 2020 14:39:20 +0200
parents 0d5f3a438e14
children 6762506ef4fb
files UnitTestsSources/FromDcmtkTests.cpp
diffstat 1 files changed, 344 insertions(+), 45 deletions(-) [+]
line wrap: on
line diff
--- a/UnitTestsSources/FromDcmtkTests.cpp	Fri Apr 10 11:39:40 2020 +0200
+++ b/UnitTestsSources/FromDcmtkTests.cpp	Fri Apr 10 14:39:20 2020 +0200
@@ -2680,7 +2680,7 @@
     
     struct ProposedPresentationContext
     {
-      std::string                    sopClassUid_;
+      std::string                    abstractSyntax_;
       std::set<DicomTransferSyntax>  transferSyntaxes_;
     };
 
@@ -2748,17 +2748,17 @@
       isOpen_ = false;
     }
 
-    void AddAccepted(const std::string& sopClassUid,
+    void AddAccepted(const std::string& abstractSyntax,
                      DicomTransferSyntax syntax,
                      uint8_t presentationContextId)
     {
-      AcceptedPresentationContexts::iterator found = accepted_.find(sopClassUid);
+      AcceptedPresentationContexts::iterator found = accepted_.find(abstractSyntax);
 
       if (found == accepted_.end())
       {
         std::map<DicomTransferSyntax, uint8_t> syntaxes;
         syntaxes[syntax] = presentationContextId;
-        accepted_[sopClassUid] = syntaxes;
+        accepted_[abstractSyntax] = syntaxes;
       }      
       else
       {
@@ -2766,8 +2766,8 @@
         {
           LOG(WARNING) << "The same transfer syntax ("
                        << GetTransferSyntaxUid(syntax)
-                       << ") was accepted twice for the same SOP class UID ("
-                       << sopClassUid << ")";
+                       << ") was accepted twice for the same abstract syntax UID ("
+                       << abstractSyntax << ")";
         }
         else
         {
@@ -2907,7 +2907,7 @@
       for (size_t i = 0; i < proposed_.size(); i++)
       {
         assert(presentationContextId <= 255);
-        const char* sopClassUid = proposed_[i].sopClassUid_.c_str();
+        const char* abstractSyntax = proposed_[i].abstractSyntax_.c_str();
 
         const std::set<DicomTransferSyntax>& source = proposed_[i].transferSyntaxes_;
           
@@ -2922,7 +2922,7 @@
 
         assert(!transferSyntaxes.empty());
         CheckConnecting(parameters, ASC_addPresentationContext(
-                          params_, presentationContextId, sopClassUid,
+                          params_, presentationContextId, abstractSyntax,
                           &transferSyntaxes[0], transferSyntaxes.size(), dcmtkRole));
 
         presentationContextId += 2;
@@ -2976,14 +2976,14 @@
     }
 
     bool LookupAcceptedPresentationContext(std::map<DicomTransferSyntax, uint8_t>& target,
-                                           const std::string& sopClassUid) const
+                                           const std::string& abstractSyntax) const
     {
       if (!IsOpen())
       {
         throw OrthancException(ErrorCode_BadSequenceOfCalls, "Connection not opened");
       }
       
-      AcceptedPresentationContexts::const_iterator found = accepted_.find(sopClassUid);
+      AcceptedPresentationContexts::const_iterator found = accepted_.find(abstractSyntax);
 
       if (found == accepted_.end())
       {
@@ -2996,21 +2996,21 @@
       }
     }
 
-    void ProposeGenericPresentationContext(const std::string& sopClassUid)
+    void ProposeGenericPresentationContext(const std::string& abstractSyntax)
     {
       std::set<DicomTransferSyntax> ts;
       ts.insert(DicomTransferSyntax_LittleEndianImplicit);
       ts.insert(DicomTransferSyntax_LittleEndianExplicit);
-      ts.insert(DicomTransferSyntax_BigEndianExplicit);
-      ProposePresentationContext(sopClassUid, ts);
+      ts.insert(DicomTransferSyntax_BigEndianExplicit);  // Retired
+      ProposePresentationContext(abstractSyntax, ts);
     }
 
-    void ProposePresentationContext(const std::string& sopClassUid,
+    void ProposePresentationContext(const std::string& abstractSyntax,
                                     DicomTransferSyntax transferSyntax)
     {
       std::set<DicomTransferSyntax> ts;
       ts.insert(transferSyntax);
-      ProposePresentationContext(sopClassUid, ts);
+      ProposePresentationContext(abstractSyntax, ts);
     }
 
     size_t GetRemainingPropositions() const
@@ -3019,7 +3019,7 @@
       return MAX_PROPOSED_PRESENTATIONS - proposed_.size();
     }
 
-    void ProposePresentationContext(const std::string& sopClassUid,
+    void ProposePresentationContext(const std::string& abstractSyntax,
                                     const std::set<DicomTransferSyntax>& transferSyntaxes)
     {
       if (transferSyntaxes.empty())
@@ -3040,7 +3040,7 @@
       }
 
       ProposedPresentationContext context;
-      context.sopClassUid_ = sopClassUid;
+      context.abstractSyntax_ = abstractSyntax;
       context.transferSyntaxes_ = transferSyntaxes;
 
       proposed_.push_back(context);
@@ -3791,26 +3791,12 @@
     }
     
   public:
-    DicomControlUserConnection()
-    {
-      SetupPresentationContexts();
-    }
-    
     DicomControlUserConnection(const DicomAssociationParameters& params) :
       parameters_(params)
     {
       SetupPresentationContexts();
     }
     
-    void SetParameters(const DicomAssociationParameters& params)
-    {
-      if (!parameters_.IsEqual(params))
-      {
-        association_.Close();
-        parameters_ = params;
-      }
-    }
-
     const DicomAssociationParameters& GetParameters() const
     {
       return parameters_;
@@ -4043,12 +4029,302 @@
   };
 
 
-  class DicomStorageUserConnection : public boost::noncopyable
+  class DicomStoreUserConnection : public boost::noncopyable
   {
   private:
-    std::unique_ptr<DicomAssociation>  association_;
-
+    typedef std::map<std::string, std::set<DicomTransferSyntax> > StorageClasses;
+    
+    DicomAssociationParameters  parameters_;
+    DicomAssociation            association_;
+    StorageClasses              storageClasses_;
+    bool                        proposeCommonClasses_;
+    bool                        proposeUncompressedSyntaxes_;
+    bool                        proposeRetiredBigEndian_;
+
+
+    /**
+
+       Orthanc < 1.7.0:
+
+       Input        | Output
+       -------------+---------------------------------------------
+       Compressed   | Same transfer syntax
+       Uncompressed | Same transfer syntax, or other uncompressed
+
+       Orthanc >= 1.7.0:
+
+       Input        | Output
+       -------------+---------------------------------------------
+       Compressed   | Same transfer syntax, or uncompressed
+       Uncompressed | Same transfer syntax, or other uncompressed
+
+     **/
+
+
+    // Return "false" if there is not enough room remaining in the association
+    bool ProposeStorageClass(const std::string& sopClassUid,
+                             const std::set<DicomTransferSyntax>& syntaxes)
+    {
+      size_t requiredCount = syntaxes.size();
+      if (proposeUncompressedSyntaxes_)
+      {
+        requiredCount += 1;
+      }
+      
+      if (association_.GetRemainingPropositions() <= requiredCount)
+      {
+        return false;  // Not enough room
+      }
+      
+      for (std::set<DicomTransferSyntax>::const_iterator
+             it = syntaxes.begin(); it != syntaxes.end(); ++it)
+      {
+        association_.ProposePresentationContext(sopClassUid, *it);
+      }
+
+      if (proposeUncompressedSyntaxes_)
+      {
+        std::set<DicomTransferSyntax> uncompressed;
+        
+        if (syntaxes.find(DicomTransferSyntax_LittleEndianImplicit) == syntaxes.end())
+        {
+          uncompressed.insert(DicomTransferSyntax_LittleEndianImplicit);
+        }
+        
+        if (syntaxes.find(DicomTransferSyntax_LittleEndianExplicit) == syntaxes.end())
+        {
+          uncompressed.insert(DicomTransferSyntax_LittleEndianExplicit);
+        }
+        
+        if (proposeRetiredBigEndian_ &&
+            syntaxes.find(DicomTransferSyntax_BigEndianExplicit) == syntaxes.end())
+        {
+          uncompressed.insert(DicomTransferSyntax_BigEndianExplicit);
+        }
+
+        if (!uncompressed.empty())
+        {
+          association_.ProposePresentationContext(sopClassUid, uncompressed);
+        }
+      }      
+
+      return true;
+    }
+
+
+    bool LookupPresentationContext(uint8_t& presentationContextId,
+                                   const std::string& sopClassUid,
+                                   DicomTransferSyntax transferSyntax)
+    {
+      typedef std::map<DicomTransferSyntax, uint8_t>  PresentationContexts;
+
+      PresentationContexts pc;
+      if (association_.IsOpen() &&
+          association_.LookupAcceptedPresentationContext(pc, sopClassUid))
+      {
+        PresentationContexts::const_iterator found = pc.find(transferSyntax);
+        if (found != pc.end())
+        {
+          presentationContextId = found->second;
+          return true;
+        }
+      }
+
+      return false;
+    }
+    
+    
+    bool NegotiatePresentationContext(uint8_t& presentationContextId,
+                                      const std::string& sopClassUid,
+                                      DicomTransferSyntax transferSyntax)
+    {
+      /**
+       * Step 1: Check whether this presentation context is already
+       * available in the previously negociated assocation.
+       **/
+
+      if (LookupPresentationContext(presentationContextId, sopClassUid, transferSyntax))
+      {
+        return true;
+      }
+
+      // The association must be re-negotiated
+      association_.ClearPresentationContexts();
+      PrepareStorageClass(sopClassUid, transferSyntax);
+
+      
+      /**
+       * Step 2: Propose at least the mandatory SOP class.
+       **/
+
+      {
+        StorageClasses::const_iterator mandatory = storageClasses_.find(sopClassUid);
+
+        if (mandatory == storageClasses_.end() ||
+            mandatory->second.find(transferSyntax) == mandatory->second.end())
+        {
+          throw OrthancException(ErrorCode_InternalError);
+        }
+
+        if (!ProposeStorageClass(sopClassUid, mandatory->second))
+        {
+          // Should never happen in real life: There are no more than
+          // 128 transfer syntaxes in DICOM!
+          throw OrthancException(ErrorCode_InternalError,
+                                 "Too many transfer syntaxes for SOP class UID: " + sopClassUid);
+        }
+      }
+
+      
+      /**
+       * Step 3: Propose all the previously spotted SOP classes, as
+       * registered through the "PrepareStorageClass()" method.
+       **/
+      
+      for (StorageClasses::const_iterator it = storageClasses_.begin();
+           it != storageClasses_.end(); ++it)
+      {
+        if (it->first != sopClassUid)
+        {
+          ProposeStorageClass(it->first, it->second);
+        }
+      }
+      
+
+      /**
+       * Step 4: As long as there is room left in the proposed
+       * presentation contexts, propose the uncompressed transfer syntaxes
+       * for the most common SOP classes, as can be found in the
+       * "dcmShortSCUStorageSOPClassUIDs" array from DCMTK. The
+       * preferred transfer syntax is "LittleEndianImplicit".
+       **/
+
+      if (proposeCommonClasses_)
+      {
+        std::set<DicomTransferSyntax> ts;
+        ts.insert(DicomTransferSyntax_LittleEndianImplicit);
+        
+        for (int i = 0; i < numberOfDcmShortSCUStorageSOPClassUIDs; i++)
+        {
+          std::string c(dcmShortSCUStorageSOPClassUIDs[i]);
+          
+          if (c != sopClassUid &&
+              storageClasses_.find(c) == storageClasses_.end())
+          {
+            ProposeStorageClass(c, ts);
+          }
+        }
+      }
+
+
+      /**
+       * Step 5: Open the association, and check whether the pair (SOP
+       * class UID, transfer syntax) was accepted by the remote host.
+       **/
+
+      association_.Open(parameters_);
+      return LookupPresentationContext(presentationContextId, sopClassUid, transferSyntax);
+    }
+    
   public:
+    DicomStoreUserConnection(const DicomAssociationParameters& params) :
+      parameters_(params),
+      proposeCommonClasses_(true),
+      proposeUncompressedSyntaxes_(true),
+      proposeRetiredBigEndian_(false)
+    {
+    }
+    
+    const DicomAssociationParameters& GetParameters() const
+    {
+      return parameters_;
+    }
+
+    void SetCommonClassesProposed(bool proposed)
+    {
+      proposeCommonClasses_ = proposed;
+    }
+
+    bool IsCommonClassesProposed() const
+    {
+      return proposeCommonClasses_;
+    }
+
+    void SetUncompressedSyntaxesProposed(bool proposed)
+    {
+      proposeUncompressedSyntaxes_ = proposed;
+    }
+
+    bool IsUncompressedSyntaxesProposed() const
+    {
+      return proposeUncompressedSyntaxes_;
+    }
+
+    void SetRetiredBigEndianProposed(bool propose)
+    {
+      proposeRetiredBigEndian_ = propose;
+    }
+
+    bool IsRetiredBigEndianProposed() const
+    {
+      return proposeRetiredBigEndian_;
+    }      
+
+    void PrepareStorageClass(const std::string& sopClassUid,
+                             DicomTransferSyntax syntax)
+    {
+      StorageClasses::iterator found = storageClasses_.find(sopClassUid);
+
+      if (found == storageClasses_.end())
+      {
+        std::set<DicomTransferSyntax> ts;
+        ts.insert(syntax);
+        storageClasses_[sopClassUid] = ts;
+      }
+      else
+      {
+        found->second.insert(syntax);
+      }
+    }
+
+
+    void Toto(const std::string& sopClassUid,
+              DicomTransferSyntax transferSyntax)
+    {
+      uint8_t id;
+      
+      if (NegotiatePresentationContext(id, sopClassUid, transferSyntax))
+      {
+        printf("**** OK, without transcoding !! %d\n", id);
+      }
+      else
+      {
+        // Transcoding - only in Orthanc >= 1.7.0
+
+        const DicomTransferSyntax uncompressed[] = {
+          DicomTransferSyntax_LittleEndianImplicit,  // Default transfer syntax
+          DicomTransferSyntax_LittleEndianExplicit,
+          DicomTransferSyntax_BigEndianExplicit
+        };
+
+        bool found = false;
+        for (size_t i = 0; i < 3; i++)
+        {
+          if (LookupPresentationContext(id, sopClassUid, uncompressed[i]))
+          {
+            printf("**** TRANSCODING to %s => %d\n",
+                   GetTransferSyntaxUid(uncompressed[i]), id);
+            found = true;
+            break;
+          }
+        }
+
+        if (!found)
+        {
+          printf("**** KO KO KO\n");
+        }
+      }
+    }
   };
 }
 
@@ -4085,23 +4361,46 @@
     printf("[%s] => %d\n", GetTransferSyntaxUid(it->first), it->second);
   }
 #else
-  DicomControlUserConnection assoc(params);
-
-  try
   {
+    DicomControlUserConnection assoc(params);
+
+    try
+    {
+      printf(">> %d\n", assoc.Echo());
+    }
+    catch (OrthancException&)
+    {
+    }
+  }
+    
+  params.SetRemoteApplicationEntityTitle("PACS");
+  params.SetRemotePort(2000);
+
+  {
+    DicomControlUserConnection assoc(params);
     printf(">> %d\n", assoc.Echo());
   }
-  catch (OrthancException&)
-  {
-  }
-
-  params.SetRemoteApplicationEntityTitle("PACS");
-  params.SetRemotePort(2000);
-  assoc.SetParameters(params);
-  printf(">> %d\n", assoc.Echo());
 
 #endif
 }
 
 
+TEST(Toto, DISABLED_Store)
+{
+  DicomAssociationParameters params;
+  params.SetLocalApplicationEntityTitle("ORTHANC");
+  params.SetRemoteApplicationEntityTitle("PACS");
+  params.SetRemotePort(2000);
+
+  DicomStoreUserConnection assoc(params);
+  assoc.PrepareStorageClass(UID_MRImageStorage, DicomTransferSyntax_JPEGProcess1);
+  assoc.PrepareStorageClass(UID_MRImageStorage, DicomTransferSyntax_JPEGProcess2_4);
+  //assoc.PrepareStorageClass(UID_MRImageStorage, DicomTransferSyntax_LittleEndianExplicit);
+
+  //assoc.SetUncompressedSyntaxesProposed(false);
+  //assoc.SetCommonClassesProposed(false);
+  assoc.Toto(UID_MRImageStorage, DicomTransferSyntax_JPEG2000);
+  //assoc.Toto(UID_MRImageStorage, DicomTransferSyntax_LittleEndianExplicit);
+}
+
 #endif