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_ */