mpciimpl.h

Go to the documentation of this file.

/* SPDX-License-Identifier: BSD-2-Clause */

 
/*
 *  COPYRIGHT (c) 1989-2009.
 *  On-Line Applications Research Corporation (OAR).
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGE.
 */
 
#ifndef _RTEMS_SCORE_MPCIIMPL_H
#define _RTEMS_SCORE_MPCIIMPL_H
 
#include <rtems/score/mpci.h>
#include <rtems/score/thread.h>
#include <rtems/score/threadq.h>
#include <rtems/score/watchdog.h>
#include <rtems/score/status.h>
 
#ifdef __cplusplus
extern "C" {
#endif


#define MPCI_DEFAULT_TIMEOUT    0xFFFFFFFF

typedef void (*MPCI_Packet_processor)( MP_packet_Prefix * );

typedef enum {
  MPCI_PACKETS_SYSTEM_VERIFY  =  0
}   MPCI_Internal_Remote_operations;

typedef struct {
  MP_packet_Prefix                 Prefix;
  MPCI_Internal_Remote_operations  operation;
  uint32_t                         maximum_nodes;
  uint32_t                         maximum_global_objects;
}    MPCI_Internal_packet;

extern Thread_queue_Control _MPCI_Remote_blocked_threads;

extern MPCI_Control *_MPCI_table;

extern Thread_Control *_MPCI_Receive_server_tcb;

extern MPCI_Packet_processor
_MPCI_Packet_processors[ MP_PACKET_CLASSES_LAST + 1 ];

void _MPCI_Register_packet_processor(
  MP_packet_Classes      the_class,
  MPCI_Packet_processor  the_packet_processor
 
);

MP_packet_Prefix *_MPCI_Get_packet ( void );

void _MPCI_Return_packet (
  MP_packet_Prefix *the_packet
);

void _MPCI_Send_process_packet (
  uint32_t          destination,
  MP_packet_Prefix *the_packet
);

Status_Control _MPCI_Send_request_packet(
  uint32_t          destination,
  MP_packet_Prefix *the_packet,
  States_Control    extra_state
);

void _MPCI_Send_response_packet (
  uint32_t          destination,
  MP_packet_Prefix *the_packet
);

MP_packet_Prefix  *_MPCI_Receive_packet ( void );

Thread_Control *_MPCI_Process_response (
  MP_packet_Prefix *the_packet
);

void _MPCI_Receive_server(
  Thread_Entry_numeric_type ignored
);

void _MPCI_Announce ( void );

void _MPCI_Internal_packets_Send_process_packet (
   MPCI_Internal_Remote_operations operation
);



void _MPCI_Internal_packets_Process_packet (
  MP_packet_Prefix *the_packet_prefix
);



MPCI_Internal_packet *_MPCI_Internal_packets_Get_packet ( void );

 
static inline bool _Mp_packet_Is_valid_packet_class (
  MP_packet_Classes the_packet_class
)
{
  return ( the_packet_class <= MP_PACKET_CLASSES_LAST );
}

 
#ifdef __cplusplus
}
#endif
 
#endif
/* end of include file */