Packages

erlkaf

2.1.2
2.2.1 2.2.0 2.1.9 2.1.8 2.1.7 2.1.6 2.1.5 2.1.4 2.1.3 2.1.2 2.1.1 2.1.0 2.0.9 2.0.8 2.0.7 2.0.6 2.0.5 2.0.4 2.0.3 2.0.2 2.0.1 2.0.0 1.2.0 1.1.9 1.1.8 1.1.7 1.1.6 1.1.5 1.1.4 1.1.3

erlkaf - Erlang Kafka library based on librdkafka

HexDocs

Current section

Files

Jump to
Readme
30 Versions
3 Dependencies
Dependants
Files
Activity
erlkaf c_src critical_section.h
Raw

c_src/critical_section.h 

#ifndef C_SRC_CRITICAL_SECTION_H_

#define C_SRC_CRITICAL_SECTION_H_



#include "erl_nif.h"

#include "macros.h"



class CriticalSection

{

public:



    CriticalSection() { mutex_ = enif_mutex_create(const_cast<char*>("erlkaf_critical_section"));}

    ~CriticalSection() {enif_mutex_destroy(mutex_);}



    void Enter() {enif_mutex_lock(mutex_);}

    void Leave() {enif_mutex_unlock(mutex_);}



private:

    ErlNifMutex *mutex_;



    DISALLOW_COPY_AND_ASSIGN(CriticalSection);

};



class CritScope

{

public:



    explicit CritScope(CriticalSection *pp) : pcrit_(pp) { pcrit_->Enter();}

    ~CritScope() {pcrit_->Leave();}



private:

    CriticalSection *pcrit_;



    DISALLOW_COPY_AND_ASSIGN(CritScope);

};



#endif  // C_SRC_CRITICAL_SECTION_H_