communication.h

Go to the documentation of this file.

#ifndef SOFTWARE_INCLUDE_COMMUNICATION_COMMUNICATION_H_
#define SOFTWARE_INCLUDE_COMMUNICATION_COMMUNICATION_H_

#include "../../include/kernel_pkg.h"
#include "../include/api.h"


#define PIPE_SIZE       MAX_LOCAL_TASKS * 3 //24                
#define REQUEST_SIZE     MAX_LOCAL_TASKS*(MAX_TASKS_APP-1) //50 
#define MAX_TASK_SLOTS   PIPE_SIZE/MAX_LOCAL_TASKS              


enum PipeSlotStatus {EMPTY, LOCKED, USED};

typedef struct {
    int producer_task;          
    int consumer_task;          
    Message message;            
    char status;                
    unsigned int order;     
} PipeSlot;


typedef struct {
    int requester;              
    int requested;              
    int requester_proc;         
} MessageRequest;



void init_communication();

int add_PIPE(int, int, Message *);

unsigned int search_PIPE_producer(int);

unsigned int PIPE_msg_number();

PipeSlot * remove_PIPE(int,  int);

PipeSlot * get_PIPE_free_position();

int insert_message_request(int, int, int);

int search_message_request(int, int);

int remove_message_request(int, int);

int remove_all_requested_msgs(int, unsigned int *);




#endif /* SOFTWARE_INCLUDE_COMMUNICATION_COMMUNICATION_H_ */