BroadcastDownsampler.h

Go to the documentation of this file.

 
#pragma once
 
#include "RobotRaconteur/RobotRaconteurConfig.h"
#include <boost/unordered_map.hpp>
 
namespace RobotRaconteur
{
class ROBOTRACONTEUR_CORE_API ServerContext;
class ROBOTRACONTEUR_CORE_API PipeBroadcasterBase;
class ROBOTRACONTEUR_CORE_API WireBroadcasterBase;

class ROBOTRACONTEUR_CORE_API BroadcastDownsampler : public RR_ENABLE_SHARED_FROM_THIS<BroadcastDownsampler>
{
  public:
    BroadcastDownsampler();

    void Init(const RR_SHARED_PTR<ServerContext>& context, uint32_t default_downsample = 0);

    uint32_t GetClientDownsample(uint32_t ep);

    void SetClientDownsample(uint32_t ep, uint32_t downsample);

    void BeginStep();

    void EndStep();

    void AddPipeBroadcaster(const RR_SHARED_PTR<PipeBroadcasterBase>& broadcaster);

    void AddWireBroadcaster(const RR_SHARED_PTR<WireBroadcasterBase>& broadcaster);
 
  protected:
    RR_WEAK_PTR<ServerContext> context;
 
    uint32_t default_downsample;
    uint64_t step_count;
    RR_UNORDERED_MAP<uint32_t, uint32_t> client_downsamples;
 
    boost::mutex this_lock;
 
    static bool wire_predicate(RR_WEAK_PTR<BroadcastDownsampler> this_, const RR_SHARED_PTR<WireBroadcasterBase>& wire,
                               uint32_t ep);
    static bool pipe_predicate(RR_WEAK_PTR<BroadcastDownsampler> this_, const RR_SHARED_PTR<PipeBroadcasterBase>& wire,
                               uint32_t ep, uint32_t index);
 
    static void server_event(RR_WEAK_PTR<BroadcastDownsampler> this_, const RR_SHARED_PTR<ServerContext>& ctx,
                             ServerServiceListenerEventType evt, const RR_SHARED_PTR<void>& p);
};

class ROBOTRACONTEUR_CORE_API BroadcastDownsamplerStep
{
    RR_SHARED_PTR<BroadcastDownsampler>& _downsampler;
 
  public:
    BroadcastDownsamplerStep(RR_SHARED_PTR<BroadcastDownsampler>& downsampler);
    ~BroadcastDownsamplerStep();
};
 
#ifndef ROBOTRACONTEUR_NO_CXX11_TEMPLATE_ALIASES
using BroadcastDownsamplerPtr = RR_SHARED_PTR<BroadcastDownsampler>;
#endif
} // namespace RobotRaconteur