cond::BlobStreamingService Class Reference

Inheritance diagram for cond::BlobStreamingService:

Public Member Functions
	BlobStreamingService ()
void	read (const coral::Blob &blobData, void *addressOfContainer, Reflex::Type const &classDictionary) override
	Reads an object from a Blob and fills-in the container. More...
boost::shared_ptr< coral::Blob >	write (const void *addressOfInputData, Reflex::Type const &classDictionary, bool useCompression=true) override
virtual	~BlobStreamingService ()
Public Member Functions inherited from ora::IBlobStreamingService
virtual	~IBlobStreamingService ()
	Empty destructor. More...

Private Types
typedef std::pair< unsigned long long, unsigned long long >	uuid
enum	Variant { OLD, COMPRESSED_TBUFFER, COMPRESSED_CHARS }

Static Private Member Functions
static boost::shared_ptr < coral::Blob >	compress (const void *addr, size_t isize)
static boost::shared_ptr < coral::Blob >	expand (const coral::Blob &blobIn)
static Variant	findVariant (const void *address)
static int	isVectorChar (Reflex::Type const &classDictionary)

Private Attributes
boost::shared_ptr < ora::IBlobStreamingService >	rootService

Static Private Attributes
static const size_t	m_idsize =sizeof(uuid)
static const size_t	m_offset = m_idsize + sizeof(unsigned long long)
static const size_t	nVariants =3
static uuid const	variantIds [nVariants]

Detailed Description

Definition at line 23 of file BlobStreamingService.cc.

Member Typedef Documentation

typedef std::pair<unsigned long long, unsigned long long> cond::BlobStreamingService::uuid

private

Definition at line 38 of file BlobStreamingService.cc.

Member Enumeration Documentation

enum cond::BlobStreamingService::Variant

private

Enumerator
OLD
COMPRESSED_TBUFFER
COMPRESSED_CHARS

Definition at line 44 of file BlobStreamingService.cc.

{ OLD, COMPRESSED_TBUFFER, COMPRESSED_CHARS }; 

Constructor & Destructor Documentation

cond::BlobStreamingService::BlobStreamingService

(

)

Definition at line 61 of file BlobStreamingService.cc.

: rootService(new cond::TBufferBlobStreamingService()){}

cond::BlobStreamingService::~BlobStreamingService ( )

virtual

Definition at line 63 of file BlobStreamingService.cc.

{}

Member Function Documentation

boost::shared_ptr< coral::Blob > cond::BlobStreamingService::compress ( const void *  addr, size_t  isize  )

staticprivate

Definition at line 183 of file BlobStreamingService.cc.

References m_idsize, m_offset, and spu::zerr().

Referenced by write().

                                                                                          {
    uLongf destLen = compressBound(isize);
    size_t usize = destLen + m_offset;
    boost::shared_ptr<coral::Blob> theBlob( new coral::Blob(usize));
     void * startingAddress = (unsigned char*)(theBlob->startingAddress())+ m_offset;
    int zerr =  compress2( (unsigned char*)(startingAddress), &destLen,
               (unsigned char*)(addr), isize,
              9);
    if (zerr!=0) edm::LogError("BlobStreamingService")<< "Compression error " << zerr;
    destLen+= m_idsize + sizeof(unsigned long long);
    theBlob->resize(destLen);

    startingAddress = (unsigned char*)(theBlob->startingAddress())+ m_idsize;
    // write expanded size;
    *reinterpret_cast<unsigned long long*>(startingAddress)=isize; 
    return theBlob;
  }

boost::shared_ptr< coral::Blob > cond::BlobStreamingService::expand ( const coral::Blob &  blobIn )

staticprivate

Definition at line 201 of file BlobStreamingService.cc.

References compareJSON::const, m_idsize, m_offset, and spu::zerr().

Referenced by read().

                                                                                 {
    if (size_t(blobIn.size()) < m_offset) return boost::shared_ptr<coral::Blob>(new coral::Blob());
    long long csize =  blobIn.size() - m_offset;
    unsigned char const * startingAddress = (unsigned char const*)(blobIn.startingAddress())+ m_idsize;
    unsigned long long usize = *reinterpret_cast<unsigned long long const*>(startingAddress);
    startingAddress +=  sizeof(unsigned long long);
    boost::shared_ptr<coral::Blob> theBlob( new coral::Blob(usize));
    uLongf destLen = usize;
    int zerr =  uncompress((unsigned char *)(theBlob->startingAddress()),  &destLen,
               startingAddress, csize);
    if (zerr!=0 || usize!=destLen) 
      edm::LogError("BlobStreamingService")<< "uncompressing error " << zerr
                   << " original size was " << usize
                   << " new size is " << destLen;
    
     return theBlob; 
  }

BlobStreamingService::Variant cond::BlobStreamingService::findVariant ( const void *  address )

staticprivate

Definition at line 176 of file BlobStreamingService.cc.

References compareJSON::const, spr::find(), nVariants, OLD, findQualityFiles::v, and variantIds.

Referenced by read().

                                                                                   {
    uuid const & id = *reinterpret_cast<uuid const*>(address);
    uuid const *  v = std::find(variantIds,variantIds+nVariants,id);
    return (v==variantIds+nVariants) ? OLD : (Variant)(v-variantIds);
  }

int cond::BlobStreamingService::isVectorChar ( Reflex::Type const &  classDictionary )

staticprivate

Definition at line 167 of file BlobStreamingService.cc.

References edmStreamStallGrapher::t.

Referenced by read(), and write().

                                                                           {
    std::type_info const & t = classDictionary.TypeInfo();
    if (t==typeid(std::vector<unsigned char>) ) return 1;
    if (t==typeid(std::vector<char>) ) return 2;
    return 0;
  }

void cond::BlobStreamingService::read ( const coral::Blob &  blobData, void *  addressOfContainer, Reflex::Type const &  classDictionary  )

overridevirtual

Reads an object from a Blob and fills-in the container.

Implements ora::IBlobStreamingService.

Definition at line 111 of file BlobStreamingService.cc.

References COMPRESSED_CHARS, COMPRESSED_TBUFFER, expand(), findVariant(), isVectorChar(), roll_playback::k, m_offset, OLD, rootService, and findQualityFiles::v.

Referenced by Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor::goto(), and Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor::setFilterBranches().

                                                                                                                            {
    // protect against small blobs...
    Variant v =  (size_t(blobData.size()) < m_offset) ? OLD : findVariant(blobData.startingAddress());
    switch (v) {
    case OLD :
      {
    rootService->read( blobData, addressOfContainer, classDictionary);
      }
      break;
    case COMPRESSED_TBUFFER :
      {
    boost::shared_ptr<coral::Blob> blobIn = expand(blobData);
    rootService->read( *blobIn, addressOfContainer, classDictionary);
      }
      break;
    case COMPRESSED_CHARS :
      {
    boost::shared_ptr<coral::Blob> blobIn = expand(blobData);
    int const k = isVectorChar(classDictionary);
    switch (k) {
    case 0 : 
      {
        // error!!!
      }
      break;
    case 1:
      {
        std::vector<unsigned char> & v = *reinterpret_cast< std::vector<unsigned char> *> (addressOfContainer);
        // we should avoid the copy!
        v.resize(blobIn->size());
        std::memcpy(&v.front(),blobIn->startingAddress(),v.size());
      }
      break;
    case 2:
      {
        std::vector<char> & v = *reinterpret_cast< std::vector<char> *> (addressOfContainer);
        // we should avoid the copy!
        v.resize(blobIn->size());
        std::memcpy(&v.front(),blobIn->startingAddress(),v.size());
      }
      break;
    }
      }
    }
  }

boost::shared_ptr< coral::Blob > cond::BlobStreamingService::write ( const void *  addressOfInputData, Reflex::Type const &  classDictionary, bool  useCompression = true  )

overridevirtual

Implements ora::IBlobStreamingService.

Definition at line 65 of file BlobStreamingService.cc.

References compress(), COMPRESSED_CHARS, COMPRESSED_TBUFFER, isVectorChar(), roll_playback::k, rootService, findQualityFiles::v, and variantIds.

Referenced by pkg.AbstractPkg::generate().

                                                                                                                                                   {
    boost::shared_ptr<coral::Blob> blobOut;
    int const k = isVectorChar(classDictionary);
    switch (k) {
    case 0 : 
      {
    // at the moment we write TBuffer compressed, than we see....
    // we may wish to avoid one buffer copy...
    boost::shared_ptr<coral::Blob> buffer = rootService->write(addressOfInputData, classDictionary);
        if( useCompression ){
          blobOut = compress(buffer->startingAddress(),buffer->size());
          *reinterpret_cast<uuid*>(blobOut->startingAddress()) = variantIds[COMPRESSED_TBUFFER];
    } else {
          blobOut = buffer;
    }
      }
      break;
    case 1 : 
      {
        if( useCompression ){
      std::vector<unsigned char> const & v = *reinterpret_cast< std::vector<unsigned char> const *> (addressOfInputData);
      blobOut = compress(&v.front(),v.size());
      *reinterpret_cast<uuid*>(blobOut->startingAddress()) = variantIds[COMPRESSED_CHARS];
    } else {
          blobOut = rootService->write(addressOfInputData,classDictionary);
    }
      }
      break;
    case 2 : 
      {
        if( useCompression ){
          std::vector<char> const & v = *reinterpret_cast<std::vector<char> const *> (addressOfInputData);
      blobOut = compress(&v.front(),v.size());
      *reinterpret_cast<uuid*>(blobOut->startingAddress()) = variantIds[COMPRESSED_CHARS];
    } else {
          blobOut = rootService->write(addressOfInputData,classDictionary);
    }
      }
      break;
      
    }
    return blobOut;

  }

Member Data Documentation

const size_t cond::BlobStreamingService::m_idsize =sizeof(uuid)

staticprivate

Definition at line 40 of file BlobStreamingService.cc.

Referenced by compress(), and expand().

const size_t cond::BlobStreamingService::m_offset = m_idsize + sizeof(unsigned long long)

staticprivate

Definition at line 41 of file BlobStreamingService.cc.

Referenced by compress(), expand(), and read().

const size_t cond::BlobStreamingService::nVariants =3

staticprivate

Definition at line 42 of file BlobStreamingService.cc.

Referenced by findVariant().

boost::shared_ptr<ora::IBlobStreamingService> cond::BlobStreamingService::rootService

private

Definition at line 56 of file BlobStreamingService.cc.

Referenced by read(), and write().

const BlobStreamingService::uuid cond::BlobStreamingService::variantIds

staticprivate

Initial value:

= {
    BlobStreamingService::uuid(0,0)
    ,BlobStreamingService::uuid(0xf4e92f169c974e8eLL, 0x97851f372586010dLL)
    ,BlobStreamingService::uuid(0xc9a95a45e60243cfLL, 0x8dc549534f9a9274LL)
  }

Definition at line 45 of file BlobStreamingService.cc.

Referenced by findVariant(), and write().