StreamTransport.hxx

Go to the documentation of this file.

 
#ifndef _OPENLCB_STREAMTRANSPORT_HXX_
#define _OPENLCB_STREAMTRANSPORT_HXX_
 
#include "utils/Destructable.hxx"
#include "utils/Queue.hxx"
 
#include <inttypes.h>
 
namespace openlcb
{
 
class StreamSender;
class IfCan;
class If;
 
class StreamTransport : public Destructable
{
public:
    StreamTransport(If *iface);
 
    ~StreamTransport();
 
    uint8_t get_send_stream_id()
    {
        int ret = -1;
        for (int i = 0; i < MAX_SEND_STREAM_ID && ret < 0; ++i)
        {
            if ((inUseSendStreamIds_ & (1u << nextSendStreamId_)) == 0)
            {
                ret = nextSendStreamId_;
                inUseSendStreamIds_ |= (1u << nextSendStreamId_);
            }
            if (++nextSendStreamId_ > MAX_SEND_STREAM_ID)
            {
                nextSendStreamId_ = 0;
            }
        }
        return ret & 0xFF;
    }
 
    void release_send_stream_id(uint8_t stream_id)
    {
        inUseSendStreamIds_ &= ~(1u << stream_id);
    }
 
    TypedQAsync<StreamSender> *sender_allocator()
    {
        return &senders_;
    }
 
    uint8_t get_next_stream_receive_id()
    {
        return nextReceiveStreamId_++;
    }
 
protected:
    TypedQAsync<StreamSender> senders_;
 
private:
    static constexpr uint8_t MAX_SEND_STREAM_ID = 26;
    unsigned inUseSendStreamIds_ : 27;
    unsigned nextSendStreamId_ : 5;
 
protected:    
    uint8_t nextReceiveStreamId_{0x50};
};
 
class StreamTransportCan : public StreamTransport
{
public:
    StreamTransportCan(IfCan *iface, unsigned num_senders);
 
    ~StreamTransportCan();
};
 
} // namespace openlcb
 
#endif // _OPENLCB_STREAMTRANSPORT_HXX_