CBInputStream

Handler

Reader

STLInputStream

StorageInputStream

StorageWrap

XMLDocument

XMLInputSourceWrapper

XMLSimpleStr

XMLUniStr

XercesPlatform

Macros

Line Code
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194
#ifndef GeneratorInterface_LHEInterface_XMLUtils_h
#define GeneratorInterface_LHEInterface_XMLUtils_h

#include <iostream>
#include <string>
#include <memory>
#include <vector>

#include <xercesc/util/XMLString.hpp>
#include <xercesc/util/XMLUni.hpp>
#include <xercesc/util/XMLChar.hpp>
#include <xercesc/util/BinInputStream.hpp>
#include <xercesc/framework/XMLPScanToken.hpp>
#include <xercesc/sax/InputSource.hpp>
#include <xercesc/sax2/DefaultHandler.hpp>
#include <xercesc/sax2/SAX2XMLReader.hpp>
#include <lzma.h>

namespace edm::storage {
  class Storage;
}

namespace lhef {

  class StorageWrap {
  public:
    using Storage = edm::storage::Storage;

    StorageWrap(std::unique_ptr<Storage> storage);
    ~StorageWrap();

    Storage *operator->() { return storage.get(); }
    const Storage *operator->() const { return storage.get(); }

  private:
    std::unique_ptr<Storage> storage;
  };

  class XMLDocument {
  public:
    class Handler : public XERCES_CPP_NAMESPACE_QUALIFIER DefaultHandler {};

    XMLDocument(std::unique_ptr<std::istream> &in, Handler &handler);
    XMLDocument(std::unique_ptr<StorageWrap> &in, Handler &handler);
    virtual ~XMLDocument();

    bool parse();

    static std::shared_ptr<void> platformHandle() { return std::make_shared<XercesPlatform>(); }

  private:
    class XercesPlatform {
    public:
      XercesPlatform();
      // do not make any kind of copies
      XercesPlatform(const XercesPlatform &orig) = delete;
      XercesPlatform &operator=(const XercesPlatform &orig) = delete;
      ~XercesPlatform();

    private:
      static unsigned int instances;
    };

    void init(Handler &handler);

    std::unique_ptr<XercesPlatform> platform;

    std::unique_ptr<XERCES_CPP_NAMESPACE_QUALIFIER InputSource> source;
    std::unique_ptr<XERCES_CPP_NAMESPACE_QUALIFIER SAX2XMLReader> parser;

    XERCES_CPP_NAMESPACE_QUALIFIER XMLPScanToken token;

    bool done;
  };

  class XMLSimpleStr {
  public:
    XMLSimpleStr(const XMLCh *str) : string(XERCES_CPP_NAMESPACE_QUALIFIER XMLString::transcode(str)) {}

    ~XMLSimpleStr() { XERCES_CPP_NAMESPACE_QUALIFIER XMLString::release(&string); }

    inline operator const char *() const { return string; }

    inline static bool isAllSpaces(const XMLCh *str, unsigned int length) {
      return XERCES_CPP_NAMESPACE_QUALIFIER XMLChar1_0::isAllSpaces(str, length);
    }

    inline static bool isSpace(XMLCh ch) { return XERCES_CPP_NAMESPACE_QUALIFIER XMLChar1_0::isWhitespace(ch); }

  private:
    char *string;
  };

  class XMLUniStr {
  public:
    XMLUniStr(const char *str) : unicode(XERCES_CPP_NAMESPACE_QUALIFIER XMLString::transcode(str)) {}

    ~XMLUniStr() { XERCES_CPP_NAMESPACE_QUALIFIER XMLString::release(&unicode); }

    operator const XMLCh *() const { return unicode; }

  private:
    XMLCh *unicode;
  };

  template <typename T>
  class XMLInputSourceWrapper : public XERCES_CPP_NAMESPACE_QUALIFIER InputSource {
  public:
    typedef typename T::Stream_t Stream_t;

    XMLInputSourceWrapper(std::unique_ptr<Stream_t> &obj) : obj(std::move(obj)) {}
    ~XMLInputSourceWrapper() override {}

    XERCES_CPP_NAMESPACE_QUALIFIER BinInputStream *makeStream() const override { return new T(*obj); }

  private:
    std::unique_ptr<Stream_t> obj;
  };

  class CBInputStream : public XERCES_CPP_NAMESPACE_QUALIFIER BinInputStream {
  public:
    class Reader {
    public:
      virtual ~Reader();
      virtual const std::string &data() = 0;
    };

    typedef Reader Stream_t;

    CBInputStream(Reader &in);
    ~CBInputStream() override;

    XMLFilePos curPos() const override { return pos; }

    XMLSize_t readBytes(XMLByte *const buf, const XMLSize_t size) override;

    const XMLCh *getContentType() const override { return nullptr; }

  private:
    Reader &reader;
    std::string buffer;
    unsigned int pos;
  };

  class STLInputStream : public XERCES_CPP_NAMESPACE_QUALIFIER BinInputStream {
  public:
    typedef std::istream Stream_t;

    STLInputStream(std::istream &in);
    ~STLInputStream() override;

    XMLFilePos curPos() const override { return pos; }

    XMLSize_t readBytes(XMLByte *const buf, const XMLSize_t size) override;

    const XMLCh *getContentType() const override { return nullptr; }

  private:
    std::istream &in;
    unsigned int pos;
  };

  class StorageInputStream : public XERCES_CPP_NAMESPACE_QUALIFIER BinInputStream {
  public:
    typedef StorageWrap Stream_t;

    StorageInputStream(StorageWrap &in);
    ~StorageInputStream() override;

    XMLFilePos curPos() const override { return pos; }

    XMLSize_t readBytes(XMLByte *const buf, const XMLSize_t size) override;

    const XMLCh *getContentType() const override { return nullptr; }

  private:
    StorageWrap &in;
    unsigned int pos;
    lzma_stream lstr;
    bool compression_;
    unsigned int lasttotal_;

    unsigned int buffLoc_ = 0, buffTotal_ = 0;
    std::vector<uint8_t> buffer_;
    static constexpr unsigned bufferSize_ = 16 * 1024 * 1024;
  };

  typedef XMLInputSourceWrapper<CBInputStream> CBInputSource;
  typedef XMLInputSourceWrapper<STLInputStream> STLInputSource;
  typedef XMLInputSourceWrapper<StorageInputStream> StorageInputSource;

}  // namespace lhef

#endif  // GeneratorInterface_LHEInterface_XMLUtils_h