Ports.h

Go to the documentation of this file.

#ifndef _PORTS_H
#define _PORTS_H

#include "../constants.h"
#include "Policies.h"
#include "hashDefault.h"
//TODO: nao esquecer que na hora de dar o set no nome da biliboteca
//temos que passar a mesma no formato lib*.so

#ifndef _PORT_HANDLERS_
#define _PORT_HANDLERS_
// output port handler
typedef int OutputPortHandler; ///< index of the OutputPort int the FilterData, used for every operations the filter make to a stream. 
typedef int InputPortHandler; ///< Index of InputPort in the FilterData
#endif

#define OP_STATE_OPEN 1
#define OP_STATE_CLOSED 0

/* Output port stuff *************************************************/
/* Labeled stream data */
typedef void (GetLabel)(void *msg, int tamMsg, char label[]); ///< getLabel prototype
typedef int (Hash)(char *label, int image); ///< Hash function prototype
typedef void (MLSHash)(char *label, int  image, int destArray[]); ///< Multicast LS hash function prototype

typedef struct __LabeledStreamData {
        void *lsHandler; ///< handler for dynamic library that contains hash and getLabel
        char libname[MAX_LNAME_LENGTH+1];       ///< the library name with the functions
        Hash *hash; ///< pointer to the hash function, if used
        MLSHash *mlshash; ///< pointer to the mls hash, if used
        GetLabel *getLabel; ///< getLabel pointer
} LabeledStreamData;


//output port
typedef struct {
        char *name; ///< OutputPort Name
        int numDestinations; ///< number of destinations connected to this port
        int *tidsDestinations; ///< the array of tids
        writePolicy_t writePolicy; ///< the write policy used by this port
        int tag;  ///< stream tag
        int nextToSend; ///< who is the next instance to get our msgs?
        LabeledStreamData lsData; ///< the labeled stream data
        int state; ///< the port state
}OutputPort;

///constructor
OutputPort *createOutputPort();

///destroyer: must release the libraries
void destroyOutputPort(OutputPort *o);

///closes the door, must be called before finalizing if port is not closed
void closeOutputPort(OutputPort *o);

///resets the output port, i.e open it
void resetOutputPort(OutputPort *o);


/// set stuff, user can free the second argument after that
void setOPState(OutputPort *op, int state);
void setOPName(OutputPort *op, const char *name);
void setOPNumDestinations(OutputPort *op, int num);
void setOPWritePolicy(OutputPort *op, writePolicy_t p);
void setOPNextToSend(OutputPort *op, int next);
void setOPLibName(OutputPort *op, const char *libname);
void setOPTidsDestinations(OutputPort *op, const int *tids);
void setOPTag(OutputPort *op, int tag);

/// This function loads the libraries of the labeled stream, returns 1 on success 0 otherwise
int loadOPLSData(OutputPort *op);
int loadOPMLSData(OutputPort *op);
/* End outputport stuff ***************************************************/


/* Input port stuff *************************************************/

typedef struct {
        char *name; ///< InputPort name
        int numSources; ///< we receive from this number of sources
        int *tidsSources;  ///< the array of tids we receive from
        int tag; //< the stream tag
        int numEowRecv; ///< the number of EOW received so far
} InputPort;

///constructor
InputPort *createInputPort();
///destroyer: must release the libraries
void destroyInputPort(InputPort *o);

///reset an input port. Must be used before starting work
void resetInputPort(InputPort *ip);

// set stuff, user can free the second argument after that
void setIPName(InputPort *ip, const char *name);
void setIPNumSources(InputPort *ip, int num);
void setIPTag(InputPort *ip, int tag);
void setIPTidsSources(InputPort *ip, const int *tids);
void setNumEowRecv(InputPort *ip, int numRecv);
/*********************************************************************/

#endif

---