PortCorePacket.h

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: 2006-2021 Istituto Italiano di Tecnologia (IIT)
 * SPDX-FileCopyrightText: 2006-2010 RobotCub Consortium
 * SPDX-License-Identifier: BSD-3-Clause
 */
 
#ifndef YARP_OS_IMPL_PORTCOREPACKET_H
#define YARP_OS_IMPL_PORTCOREPACKET_H
 
#include <yarp/os/NetType.h>
#include <yarp/os/PortWriter.h>
 
namespace yarp::os::impl {
 
class PortCorePacket
{
public:
    PortCorePacket* prev_;                
    PortCorePacket* next_;                
    const yarp::os::PortWriter* content;  
    const yarp::os::PortWriter* callback; 
    int ct;                               
    bool owned;                           
    bool ownedCallback;                   
    bool completed;                       
 
    PortCorePacket() :
            prev_(nullptr),
            next_(nullptr),
            content(nullptr),
            callback(nullptr),
            ct(0),
            owned(false),
            ownedCallback(false),
            completed(false)
    {
        reset();
    }
 
    virtual ~PortCorePacket()
    {
        complete();
        reset();
    }
 
    int getCount()
    {
        return ct;
    }
 
    void inc()
    {
        ct++;
    }
 
    void dec()
    {
        ct--;
    }
 
    const yarp::os::PortWriter* getContent()
    {
        return content;
    }
 
    const yarp::os::PortWriter* getCallback()
    {
        return (callback != nullptr) ? callback : content;
    }
 
    void setContent(const yarp::os::PortWriter* writable,
                    bool owned = false,
                    const yarp::os::PortWriter* callback = nullptr,
                    bool ownedCallback = false)
    {
        content = writable;
        this->callback = callback;
        ct = 1;
        this->owned = owned;
        this->ownedCallback = ownedCallback;
        completed = false;
    }
 
    void reset()
    {
        if (owned) {
            delete content;
        }
        if (ownedCallback) {
            delete callback;
        }
        content = nullptr;
        callback = nullptr;
        ct = 0;
        owned = false;
        ownedCallback = false;
        completed = false;
    }
 
    void complete()
    {
        if (!completed) {
            if (getContent() != nullptr) {
                getCallback()->onCompletion();
                completed = true;
            }
        }
    }
};
 
} // namespace yarp::os::impl
 
#endif // YARP_OS_IMPL_PORTCOREPACKET_H