v5_ESCompression.h

Go to the documentation of this file.

//Dear emacs, this is -*- c++ -*-
 
/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
 
#ifndef OFFLINE_EVENTSTORAGE_V5_ESCOMPRESSION_H
#define OFFLINE_EVENTSTORAGE_V5_ESCOMPRESSION_H
 
#include <string>
#include <sys/uio.h>
#include "ers/ers.h"
 
#include "ByteStreamCnvSvcLegacy/offline_EventStorage/v5_EventStorageRecords.h"
 
ERS_DECLARE_ISSUE(offline_EventStorage_v5,
          CompressionIssue,
          ERS_EMPTY, ERS_EMPTY)
 
ERS_DECLARE_ISSUE_BASE(offline_EventStorage_v5,
               ZlibFailed, 
               offline_EventStorage_v5::CompressionIssue,
               "" << message << " - Zlib return code: " 
               << return_code << " Zlib message: " << zlib_message,
               ERS_EMPTY,
               ((const char *) message )
               ((int)return_code)
               ((std::string) zlib_message)
               )
 
 
namespace offline_EventStorage_v5 {
      
  static const std::string compressiontag("Compression");
 

  class CompressionBuffer{
    
  public:
    using iovec_const = offline_EventStorage_v5::iovec_const;
 
    virtual ~CompressionBuffer() {};

    virtual void * handle() = 0;
    
    virtual void realloc(const uint32_t& newsize) = 0;

    virtual void grow(const uint32_t& newsize) = 0;

    virtual uint32_t buffersize() const = 0;
  };
  
  
  CompressionType string_to_type(const std::string& type);
  std::string type_to_string(const CompressionType& type);
 

 
  void zlibcompress(CompressionBuffer& compressed,
            uint32_t& compressedsize,
            const uint32_t& entries, 
            const struct iovec_const* iov,
            const uint32_t& totalsize,
            const uint32_t& level);
  

  void zlibdecompress(CompressionBuffer& decompressed,
              uint32_t& decompressedsize,
              const void * compressed,
              const uint32_t& compsize);
 
}
 
#endif