Channel.h

Go to the documentation of this file.

 
#ifndef _CHANNEL_H
#define _CHANNEL_H
 
#include <NSC.h>
#include "ClientPP.h"
#include <queue>
#include <shared_mutex>

enum class ChannelState { Active, Inactive };

enum class ChannelType { 
    SLEEPING = 0, 
    DATA = 1 << 0,
    METADATA = 1 << 1, 
    GLOBAL = 1 << 2 
};

inline ChannelType operator|(ChannelType a, ChannelType b) {
    return static_cast<ChannelType>(static_cast<int>(a) | static_cast<int>(b));
}

inline bool hasType(ChannelType channelType, ChannelType flag) {
    return (static_cast<int>(channelType) & static_cast<int>(flag)) != 0;
}
 
class Channel {
public: 
    Channel(const std::string& key);
    
    void setKey(const std::string& key);
    
    const std::string& getKey();
    
    void setState(ChannelState state);
    
    void push(ClientData data);
    
    ClientData pull();

    bool available();
    
    virtual void run(std::stop_token st) = 0;
 
protected: 
    std::string key;

    std::queue<ClientData> dataQueue;

    ChannelState state;
 
private: 
    std::shared_mutex mtx; // .lock_shared() for read-only access | .lock() to write access
};
 
#endif //_CHANNEL_H