erpc_server.hpp

Go to the documentation of this file.

/*
 * Copyright (c) 2014, Freescale Semiconductor, Inc.
 * Copyright 2016-2017 NXP
 * Copyright 2020 ACRIOS Systems s.r.o.
 * All rights reserved.
 *
 *
 * SPDX-License-Identifier: BSD-3-Clause
 */

#ifndef _EMBEDDED_RPC__SERVER_H_
#define _EMBEDDED_RPC__SERVER_H_

#include "erpc_client_server_common.hpp"
#include "erpc_config_internal.h"
#if ERPC_NESTED_CALLS
#include "erpc_client_manager.h"
#endif

// Classes

namespace erpc {
#if ERPC_NESTED_CALLS
class RequestContext;
#endif

class Service
{
public:
    Service(uint32_t serviceId) : m_serviceId(serviceId), m_next(NULL) {}

    virtual ~Service(void) {}

    uint32_t getServiceId(void) const { return m_serviceId; }

    Service *getNext(void) { return m_next; }

    void setNext(Service *next) { m_next = next; }

    virtual erpc_status_t handleInvocation(uint32_t methodId, uint32_t sequence, Codec *codec,
                                           MessageBufferFactory *messageFactory, Transport *transport) = 0;

protected:
    uint32_t m_serviceId; 
    Service *m_next;      
};

class Server : public ClientServerCommon
{
public:
    Server(void) : ClientServerCommon(), m_firstService(NULL) {}

    virtual ~Server(void) {}

    void addService(Service *service);

    void removeService(Service *service);

    virtual erpc_status_t run(void) = 0;

    virtual void stop(void) = 0;

protected:
    Service *m_firstService; 
    virtual erpc_status_t processMessage(Codec *codec, message_type_t msgType, uint32_t serviceId, uint32_t methodId,
                                         uint32_t sequence);

    virtual erpc_status_t readHeadOfMessage(Codec *codec, message_type_t &msgType, uint32_t &serviceId,
                                            uint32_t &methodId, uint32_t &sequence);

    virtual Service *findServiceWithId(uint32_t serviceId);

#if ERPC_NESTED_CALLS
    friend class ClientManager;
    friend class ArbitratedClientManager;

    virtual erpc_status_t run(RequestContext &request) = 0;
#endif

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

} // namespace erpc

#endif // _EMBEDDED_RPC__SERVER_H_