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