fuse_evict.h

Go to the documentation of this file.

#ifndef CVMFS_FUSE_EVICT_H_
#define CVMFS_FUSE_EVICT_H_

#include <pthread.h>
#include <stdint.h>

#include "bigvector.h"
#include "duplex_fuse.h"
#include "gtest/gtest_prod.h"
#include "shortstring.h"
#include "util/atomic.h"
#include "util/concurrency.h"
#include "util/single_copy.h"

namespace glue {
class InodeTracker;
class DentryTracker;
}

class MountPoint;

class FuseInvalidator : SingleCopy {
  friend class T_FuseInvalidator;  // for T_FuseInvalidator.SetUp()
  FRIEND_TEST(T_FuseInvalidator, StartStop);
  FRIEND_TEST(T_FuseInvalidator, InvalidateTimeout);
  FRIEND_TEST(T_FuseInvalidator, InvalidateOps);

 public:
  static bool HasFuseNotifyInval();

  class Handle : SingleCopy {
    friend class FuseInvalidator;

   public:
    explicit Handle(unsigned timeout_s);
    ~Handle();
    bool IsDone() const { return atomic_read32(status_) == 1; }
    void Reset() { atomic_write32(status_, 0); }
    void WaitFor();

   private:
    void SetDone() { atomic_cas32(status_, 0, 1); }

    unsigned timeout_s_;
    atomic_int32 *status_;
  };

  struct Command {
    virtual ~Command() {}
  };
  struct QuitCommand : public Command {};
  struct InvalInodesCommand : public Command {
    Handle *handle;
  };
  struct InvalDentryCommand : public Command {
    uint64_t parent_ino;
    NameString name;
  };

  FuseInvalidator(MountPoint *mountpoint,
                  void **fuse_channel_or_session,
                  bool fuse_notify_invalidation);
  ~FuseInvalidator();
  void Spawn();
  void InvalidateInodes(Handle *handle);

  void InvalidateDentry(uint64_t parent_ino, const NameString &name);

 private:
  FuseInvalidator(glue::InodeTracker *inode_tracker,
                glue::DentryTracker *dentry_tracker,
                void **fuse_channel_or_session,
                bool fuse_notify_invalidation);
  static const unsigned kTimeoutSafetyMarginSec;  // = 1;
  static const unsigned kCheckTimeoutFreqMs;  // = 100;
  static const unsigned kCheckTimeoutFreqOps;  // = 256

  static void *MainInvalidator(void *data);

  MountPoint *mount_point_;

  glue::InodeTracker *inode_tracker_;
  glue::DentryTracker *dentry_tracker_;
  void **fuse_channel_or_session_;
  bool spawned_;
  Channel<Command> channel_;
  pthread_t thread_invalidator_;
  atomic_int32 terminated_;
  BigVector<uint64_t> evict_list_;

  static bool g_fuse_notify_invalidation_;
};  // class FuseInvalidator

#endif  // CVMFS_FUSE_EVICT_H_