erpc_transport_arbitrator.hpp

Go to the documentation of this file.

/*
 * Copyright (c) 2016, Freescale Semiconductor, Inc.
 * Copyright 2016-2017 NXP
 * All rights reserved.
 *
 *
 * SPDX-License-Identifier: BSD-3-Clause
 */
#if !defined(__embedded_rpc__transport_arbitrator__)
#define __embedded_rpc__transport_arbitrator__

#include "erpc_client_manager.h"
#include "erpc_codec.hpp"
#include "erpc_threading.h"
#include "erpc_transport.hpp"

// Classes

namespace erpc {
class Codec;

class TransportArbitrator : public Transport
{
public:
    typedef uintptr_t client_token_t;

    TransportArbitrator(void);

    virtual ~TransportArbitrator(void);

    virtual uint8_t reserveHeaderSize(void) override;

    virtual erpc_status_t receive(MessageBuffer *message) override;

    virtual erpc_status_t send(MessageBuffer *message) override;

    virtual bool hasMessage(void) override;

    virtual void setCrc16(Crc16 *crcImpl) override;

    virtual Crc16 *getCrc16(void) override;

    void setSharedTransport(Transport *shared);

    Transport *getSharedTransport(void);

    void setCodec(Codec *codec);

    Codec *getCodec(void);

    client_token_t prepareClientReceive(RequestContext &request);

    erpc_status_t clientReceive(client_token_t token);

    struct PendingClientInfo
    {
        RequestContext *m_request; 
        Semaphore m_sem;           
        bool m_isValid;            
        PendingClientInfo *m_next; 
        PendingClientInfo(void);

        ~PendingClientInfo(void);
    };

protected:
    Transport *m_sharedTransport; 
    Codec *m_codec;               

    PendingClientInfo *m_clientList;     
    PendingClientInfo *m_clientFreeList; 
    Mutex m_clientListMutex;             

    PendingClientInfo *createPendingClient(void);

    PendingClientInfo *addPendingClient(void);

    void removePendingClient(PendingClientInfo *info);

    void freeClientList(PendingClientInfo *list);

private:
    // Disable copy ctor.
    TransportArbitrator(const TransportArbitrator &other);            
    TransportArbitrator &operator=(const TransportArbitrator &other); 
};

} // namespace erpc

#endif // defined(__embedded_rpc__transport_arbitrator__)
// EOF