repository_util.h

Go to the documentation of this file.

#ifndef CVMFS_PUBLISH_REPOSITORY_UTIL_H_
#define CVMFS_PUBLISH_REPOSITORY_UTIL_H_

#include <string>

#include "crypto/hash.h"
#include "util/single_copy.h"

namespace publish {

class CheckoutMarker {
 public:
  CheckoutMarker(const std::string &t,
                 const std::string &b,
                 const shash::Any &h,
                 const std::string &p)
      : tag_(t), branch_(b), hash_(h), previous_branch_(p) { }

  static CheckoutMarker *CreateFrom(const std::string &path);
  void SaveAs(const std::string &path) const;

  std::string tag() const { return tag_; }
  std::string branch() const { return branch_; }
  shash::Any hash() const { return hash_; }
  std::string previous_branch() const { return previous_branch_; }

 private:
  std::string tag_;
  std::string branch_;
  shash::Any hash_;
  std::string previous_branch_;
};


class ServerLockFile {
 public:
  explicit ServerLockFile(const std::string &path) : path_(path), fd_(-1) { }

  void Lock();
  bool TryLock();
  void Unlock();

  const std::string &path() const { return path_; }

 private:
  std::string path_;
  int fd_;
};

class ServerLockFileCheck : SingleCopy {
 public:
  explicit ServerLockFileCheck(ServerLockFile &lock) : lock_(lock) {
    owns_lock_ = lock_.TryLock();
  }
  ~ServerLockFileCheck() {
    if (owns_lock_)
      lock_.Unlock();
  }

  const bool owns_lock() const { return owns_lock_; }

 private:
  ServerLockFile &lock_;
  bool owns_lock_;
};

class ServerLockFileGuard : SingleCopy {
 public:
  explicit ServerLockFileGuard(ServerLockFile &lock) : lock_(lock) {
    lock_.Lock();
  }
  ~ServerLockFileGuard() { lock_.Unlock(); }

 private:
  ServerLockFile &lock_;
};

class ServerFlagFile {
 public:
  explicit ServerFlagFile(const std::string &path) : path_(path) { }

  void Set();
  void Clear();
  bool IsSet() const;

  const std::string &path() const { return path_; }

 private:
  std::string path_;
};

void RunSuidHelper(const std::string &verb, const std::string &fqrn);


void SetInConfig(const std::string &path, const std::string &key,
                 const std::string &value);

std::string SendTalkCommand(const std::string &socket, const std::string &cmd);

}  // namespace publish

#endif  // CVMFS_PUBLISH_REPOSITORY_UTIL_H_