erpc_inter_thread_buffer_transport.hpp

Go to the documentation of this file.

/*
 * Copyright (c) 2014, Freescale Semiconductor, Inc.
 * Copyright 2016 NXP
 * All rights reserved.
 *
 *
 * SPDX-License-Identifier: BSD-3-Clause
 */

#ifndef _EMBEDDED_RPC__INTER_THREAD_BUFFER_TRANSPORT_H_
#define _EMBEDDED_RPC__INTER_THREAD_BUFFER_TRANSPORT_H_

#include "erpc_message_buffer.hpp"
#include "erpc_threading.h"
#include "erpc_transport.hpp"

// Classes

namespace erpc {
class InterThreadBufferTransport : public Transport
{
public:
    InterThreadBufferTransport(void) :
    Transport(), m_state(NULL), m_peer(NULL), m_inSem(), m_outSem(1), m_inBuffer(NULL)
    {
    }
    virtual ~InterThreadBufferTransport(void);

    void linkWithPeer(InterThreadBufferTransport *peer);

    virtual erpc_status_t receive(MessageBuffer *message) override;
    virtual erpc_status_t send(MessageBuffer *message) override;

    virtual int32_t getAvailable(void) const { return 0; }

protected:
    struct SharedState
    {
        Mutex m_mutex;
    };

    SharedState *m_state;               
    InterThreadBufferTransport *m_peer; 
    Semaphore m_inSem;                  
    Semaphore m_outSem;                 
    MessageBuffer *m_inBuffer;          
};

} // namespace erpc

#endif // _EMBEDDED_RPC__INTER_THREAD_BUFFER_TRANSPORT_H_