InterProcessMutex.h

Go to the documentation of this file.

#ifndef ZYPP_BASE_INTER_PROCESS_MUTEX_H
#define ZYPP_BASE_INTER_PROCESS_MUTEX_H

#include <string>
#include "zypp/base/Fd.h"
#include "zypp/base/Exception.h"
#include "zypp/base/NonCopyable.h"
#include "zypp/Pathname.h"

namespace zypp
{
namespace base
{

class ZYppLockedException : public Exception
{
public:
    ZYppLockedException( const std::string & msg_r,
                         const std::string &name,
                         pid_t locker_pid );
    virtual ~ZYppLockedException() throw();
    pid_t locker_pid() const { return _locker_pid; }
    std::string name() const { return _name; }
private:
    pid_t _locker_pid;
    std::string _name;
};

class InterProcessMutex : private base::NonCopyable
{
public:
    enum ConsumerType
    {
        Reader,
        Writer
    };

   class Options
   {
   public:
       Options( ConsumerType ptype,
                const std::string &pname = "zypp",
                int ptimeout = -1 );

       void setPath( const Pathname &base );

       std::string name;
       int timeout;
       ConsumerType type;
       Pathname base;
   };
    
    InterProcessMutex( const Options &poptions );

    ~InterProcessMutex();

private:
    bool isProcessRunning(pid_t pid_r);
    Pathname lockFilePath() const;
private:
    shared_ptr<Fd> _fd;
    Options _options;
};


} }


#endif