fd_refcount_mgr.h

Go to the documentation of this file.

#ifndef CVMFS_FD_REFCOUNT_MGR_H_
#define CVMFS_FD_REFCOUNT_MGR_H_

#include <string>

#include "cache.h"
#include "smallhash.h"


// for map of file descriptors; as in kvstore.cc
static inline uint32_t hasher_any(const shash::Any &key) {
  // We'll just do the same thing as hasher_md5, since every hash is at
  // least as large.
  return *const_cast<uint32_t *>(reinterpret_cast<const uint32_t *>(key.digest)
                                 + 1);
}
static inline uint32_t hasher_int(const int &key) {
  return MurmurHash2(&key, sizeof(key), 0x07387a4f);
}

class FdRefcountMgr {
 public:
  struct FdRefcountInfo {
    int refcount;   
    shash::Any id;  

    FdRefcountInfo() : refcount(-1) { }
  };

  FdRefcountMgr();

  ~FdRefcountMgr();

  FdRefcountMgr(const SmallHashDynamic<int, FdRefcountInfo> &map_refcount,
                const SmallHashDynamic<shash::Any, int> &map_fd);

  void AssignFrom(FdRefcountMgr *other);

  SmallHashDynamic<int, FdRefcountInfo> *GetRefcountMapPtr();

  SmallHashDynamic<shash::Any, int> *GetFdMapPtr();

  int Open(const shash::Any id, const std::string &path);

  int Close(int fd);

  int Dup(int fd);

  FdRefcountMgr *Clone();

 private:
  SmallHashDynamic<int, FdRefcountInfo> map_refcount_;
  SmallHashDynamic<shash::Any, int> map_fd_;
  pthread_mutex_t *lock_cache_refcount_;
};

#endif  // CVMFS_FD_REFCOUNT_MGR_H_