LStoreFile.h

Go to the documentation of this file.

#ifndef LSTORE_ADAPTOR_LSTORE_FILE_H
#define LSTORE_ADAPTOR_LSTORE_FILE_H

#include "Utilities/StorageFactory/interface/Storage.h"
#include "Utilities/StorageFactory/interface/IOFlags.h"
#include <string>
#include <pthread.h>
namespace edm::storage {
  class LStoreFile : public Storage {
  public:
    LStoreFile(void);
    LStoreFile(void *fd);
    LStoreFile(const char *name, int flags = IOFlags::OpenRead, int perms = 0666);
    LStoreFile(const std::string &name, int flags = IOFlags::OpenRead, int perms = 0666);
    ~LStoreFile(void) override;

    virtual void create(const char *name, bool exclusive = false, int perms = 0666);
    virtual void create(const std::string &name, bool exclusive = false, int perms = 0666);
    virtual void open(const char *name, int flags = IOFlags::OpenRead, int perms = 0666);
    virtual void open(const std::string &name, int flags = IOFlags::OpenRead, int perms = 0666);

    using Storage::position;
    using Storage::read;
    using Storage::write;

    IOSize read(void *into, IOSize n) override;
    IOSize write(const void *from, IOSize n) override;

    IOOffset position(IOOffset offset, Relative whence = SET) override;
    void resize(IOOffset size) override;

    void close(void) override;
    virtual void abort(void);

    class MutexWrapper {
    public:
      MutexWrapper(pthread_mutex_t *lock);
      ~MutexWrapper();
      pthread_mutex_t *m_lock;
    };

    static pthread_mutex_t m_dlopen_lock;

  private:
    // functions

    void loadLibrary();
    void closeLibrary();

    //data

    void *m_fd;
    bool m_close;
    std::string m_name;
    void *m_library_handle;
    bool m_is_loaded;

    // Prototypes for functions
    // These are data members that are function pointers.

    int32_t (*redd_init)();
    int64_t (*redd_read)(void *, char *, int64_t);
    int32_t (*redd_close)(void *);
    int64_t (*redd_lseek)(void *, int64_t, uint32_t);
    void *(*redd_open)(const char *, int32_t, int32_t);
    int64_t (*redd_write)(void *, const char *, int64_t);
    int32_t (*redd_term)();
    int32_t (*redd_errno)();
    const std::string &(*redd_strerror)();
  };
}  // namespace edm::storage
#endif  // LSTORE_ADAPTOR_LSTORE_FILE_H