TAO/tao/Compression/Compression_Manager.cpp

   1 #include "tao/Compression/Compression_Manager.h"
   2 #include "tao/ORB_Constants.h"
   3
   4 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
   5
   6 namespace TAO
   7 {
   8   CompressionManager::~CompressionManager ()
   9   {
  10     // Require to guard the deletion of the list
  11     ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->mutex_);
  12     this->factories_.length (0u);
  13   }
  14
  15   void
  16   CompressionManager::register_factory (::Compression::CompressorFactory_ptr
  17                                         compressor_factory)
  18   {
  19     if (!::CORBA::is_nil (compressor_factory))
  20       {
  21         ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->mutex_);
  22         CORBA::ULong const length = this->factories_.length ();
  23
  24         for (CORBA::ULong i = 0u; i < length; ++i)
  25           {
  26             ::Compression::CompressorId const current =
  27               this->factories_[i]->compressor_id ();
  28
  29             if (compressor_factory->compressor_id () == current)
  30               {
  31                 throw ::Compression::FactoryAlreadyRegistered ();
  32               }
  33           }
  34         factories_.length (length + 1u);
  35         factories_[length] = ::Compression::CompressorFactory::_duplicate (
  36           compressor_factory);
  37       }
  38     else
  39       {
  40         // @todo Standardize this minor code
  41         throw ::CORBA::BAD_PARAM (CORBA::OMGVMCID | 44, CORBA::COMPLETED_NO);
  42       }
  43   }
  44
  45   void
  46   CompressionManager::unregister_factory (::Compression::CompressorId
  47                                           compressor_id)
  48   {
  49     ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, this->mutex_);
  50     CORBA::ULong const length = this->factories_.length ();
  51
  52     for (CORBA::ULong i = 0u; i < length; ++i)
  53       {
  54         ::Compression::CompressorId const current =
  55           this->factories_[i]->compressor_id ();
  56
  57         if (current == compressor_id)
  58           {
  59             // Shuffle down the remainder
  60             while (i < length-1u)
  61               {
  62                  this->factories_[i] = this->factories_[i+1u];
  63                  ++i;
  64               }
  65             this->factories_.length (length - 1u);
  66             return;
  67           }
  68       }
  69
  70     // todo exception
  71     throw ::Compression::UnknownCompressorId ();
  72   }
  73
  74   ::Compression::CompressorFactory_ptr
  75   CompressionManager::get_factory (::Compression::CompressorId compressor_id)
  76   {
  77     ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->mutex_,
  78             ::Compression::CompressorFactory::_nil ());
  79
  80     CORBA::ULong const length = this->factories_.length ();
  81
  82     for (CORBA::ULong i = 0u; i < length; ++i)
  83       {
  84         ::Compression::CompressorId const current =
  85           this->factories_[i]->compressor_id ();
  86
  87         if (current == compressor_id)
  88           {
  89             return ::Compression::CompressorFactory::_duplicate (
  90               this->factories_[i]);
  91           }
  92       }
  93
  94     throw ::Compression::UnknownCompressorId ();
  95   }
  96
  97   ::Compression::Compressor_ptr
  98   CompressionManager::get_compressor (::Compression::CompressorId
  99                                       compressor_id,
 100                                       ::Compression::CompressionLevel
 101                                       compression_level)
 102   {
 103     ::Compression::CompressorFactory_var factory = this->get_factory (
 104       compressor_id);
 105
 106     return factory->get_compressor (compression_level);
 107   }
 108
 109   ::Compression::CompressorFactorySeq *
 110   CompressionManager::get_factories ()
 111   {
 112     // todo
 113     return 0;
 114   }
 115
 116 }
 117
 118 TAO_END_VERSIONED_NAMESPACE_DECL