H264Carrier.h

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: 2006-2021 Istituto Italiano di Tecnologia (IIT)
 * SPDX-License-Identifier: BSD-3-Clause
 */
 
#ifndef H264CARRIER_INC
#define H264CARRIER_INC
 
#include <yarp/os/Carrier.h>
#include <yarp/os/Face.h>
#include "H264Decoder.h"
 
 
class H264Carrier :
        public yarp::os::Carrier
{
private:
    std::string envelope;
    h264Decoder_cfgParamters cfgParams;
public:
    H264Carrier()
    {}
 
    Carrier *create() const override
    {
        return new H264Carrier();
    }
 
    std::string getName() const override;
 
    bool isConnectionless() const override;
 
    bool canAccept() const override;
 
    bool canOffer() const override;
 
    bool isTextMode() const override;
 
    bool canEscape() const override;
 
    void handleEnvelope(const std::string& envelope) override;
 
    bool requireAck() const override;
 
    bool supportReply() const override;
 
    bool isLocal() const override;
 
    // this is important - flips expected flow of messages
    bool isPush() const override;
 
    std::string toString() const override;
 
    void getHeader(yarp::os::Bytes& header) const override;
 
    bool checkHeader(const yarp::os::Bytes& header) override;
 
    void setParameters(const yarp::os::Bytes& header) override;
 
 
    // Now, the initial hand-shaking
 
    bool prepareSend(yarp::os::ConnectionState& proto) override;
 
    bool sendHeader(yarp::os::ConnectionState& proto) override;
 
    bool expectSenderSpecifier(yarp::os::ConnectionState& proto) override;
 
    bool expectExtraHeader(yarp::os::ConnectionState& proto) override;
 
    bool respondToHeader(yarp::os::ConnectionState& proto) override;
 
    bool expectReplyToHeader(yarp::os::ConnectionState& proto) override;
 
    bool isActive() const override;
 
 
    // Payload time!
 
    bool write(yarp::os::ConnectionState& proto, yarp::os::SizedWriter& writer) override;
 
    bool reply(yarp::os::ConnectionState& proto, yarp::os::SizedWriter& writer) override;
 
    virtual bool sendIndex(yarp::os::ConnectionState& proto, yarp::os::SizedWriter& writer);
 
    bool expectIndex(yarp::os::ConnectionState& proto) override;
 
    bool sendAck(yarp::os::ConnectionState& proto) override;
 
    bool expectAck(yarp::os::ConnectionState& proto) override;
 
    std::string getBootstrapCarrierName() const override;
 
    yarp::os::Face* createFace() const override;
 
};
 
#endif